Function NewTokenBucketLimiter

server/ratelimit/limiter.go:43–55

NewTokenBucketLimiter 创建令牌桶限流器

(rate, capacity int, window time.Duration)

// NewTokenBucketLimiter 创建令牌桶限流器
func NewTokenBucketLimiter(rate, capacity int, window time.Duration) *TokenBucketLimiter {
	limiter := &TokenBucketLimiter{
		buckets:  make(map[string]*bucket),
		rate:     rate,
		capacity: capacity,
		window:   window,
	}

	// 启动清理 goroutine
	go limiter.cleanup()

	return limiter
}

// Allow 检查是否允许请求
func (l *TokenBucketLimiter) Allow(key string) bool {