如何使用Go语言中的HTTP服务器函数实现动态路由的限流功能？

package main

import (
    "fmt"
    "net/http"
    "sync"
    "time"
)

// 路由统计信息
type RouteStats struct {
    Count      int       // 当前请求数
    LastAccess time.Time // 最近一次访问时间
}

// 路由限流器
type RouteLimiter struct {
    stats      map[string]*RouteStats // 路由统计信息
    maxReq     int                    // 最大请求数
    interval   time.Duration          // 统计时间间隔
    expiration time.Duration          // 统计信息过期时间
    lock       sync.Mutex             // 互斥锁
}

// 初始化路由限流器
func NewRouteLimiter(maxReq int, interval, expiration time.Duration) *RouteLimiter {
    return &RouteLimiter{
        stats:      make(map[string]*RouteStats),
        maxReq:     maxReq,
        interval:   interval,
        expiration: expiration,
    }
}

// 中间件，负责限流检查
func (rl *RouteLimiter) LimitHandler(next http.Handler) http.Handler {
    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        // 获取路由
        route := r.URL.Path

        rl.lock.Lock()

        // 如果路由不存在，初始化统计信息
        if _, ok := rl.stats[route]; !ok {
            rl.stats[route] = &RouteStats{Count: 0}
        }

        stats := rl.stats[route]
        rl.lock.Unlock()

        // 检查请求数是否超过上限
        if stats.Count >= rl.maxReq {
            w.WriteHeader(http.StatusTooManyRequests)
            return
        }

        // 更新统计信息
        stats.Count++
        stats.LastAccess = time.Now()

        // 定时清理过期的统计信息
        go func() {
            time.Sleep(rl.expiration)
            rl.lock.Lock()
            defer rl.lock.Unlock()

            if time.Since(stats.LastAccess) >= rl.expiration {
                delete(rl.stats, route)
            }
        }()

        // 调用下一个处理程序
        next.ServeHTTP(w, r)
    })
}

// 处理路由
func handleRoute(w http.ResponseWriter, r *http.Request) {
    fmt.Fprint(w, "Hello, World!")
}

func main() {
    // 创建路由限流器
    limiter := NewRouteLimiter(10, time.Minute, time.Hour)

    // 设置路由处理函数
    http.HandleFunc("/", limiter.LimitHandler(http.HandlerFunc(handleRoute)))

    // 启动HTTP服务器
    http.ListenAndServe(":8080", nil)
}