59 lines
1.0 KiB
Go
59 lines
1.0 KiB
Go
package limiter
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"golang.org/x/time/rate"
|
|
)
|
|
|
|
func init() {
|
|
SetupIpRateLimiter()
|
|
}
|
|
|
|
type IpRateLimiter struct {
|
|
ips map[string]*rate.Limiter
|
|
mu *sync.RWMutex
|
|
r rate.Limit // float64 速率 1秒
|
|
b int // 并发 1次请求
|
|
}
|
|
|
|
var RateLimiter *IpRateLimiter
|
|
|
|
// 创建一个RateLimiter
|
|
func SetupIpRateLimiter() error {
|
|
var r rate.Limit = 10
|
|
b := 1
|
|
RateLimiter = &IpRateLimiter{
|
|
ips: make(map[string]*rate.Limiter),
|
|
mu: &sync.RWMutex{},
|
|
r: r, // 速率
|
|
b: b, // 并发
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// 添加一个ip到map
|
|
func (i *IpRateLimiter) AddIp(ip string) *rate.Limiter {
|
|
i.mu.Lock()
|
|
defer i.mu.Unlock()
|
|
|
|
limiter := rate.NewLimiter(i.r, i.b)
|
|
i.ips[ip] = limiter
|
|
return limiter
|
|
}
|
|
|
|
// 通过ip得到limiter
|
|
func (i *IpRateLimiter) GetLimiter(ip string) *rate.Limiter {
|
|
i.mu.Lock()
|
|
|
|
limiter, exists := i.ips[ip]
|
|
if !exists {
|
|
i.mu.Unlock()
|
|
// 注意：这里面也上了锁，所以当前的锁要先释放，不然死锁
|
|
return i.AddIp(ip)
|
|
}
|
|
// 这里不能忘
|
|
i.mu.Unlock()
|
|
return limiter
|
|
}
|