08dd1c7f75
功能特性： - 用户端充值记录页面，从使用日志中分离 - 充值记录中的去开发票功能 - 管理员发票管理页面 - 发票申请、处理、邮件通知功能 - 侧边栏菜单更新 - UI优化和控制台清理 - Docker部署配置 - 生产环境安全配置
71 lines
1.5 KiB
Go
71 lines
1.5 KiB
Go
package common
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
type InMemoryRateLimiter struct {
|
|
store map[string]*[]int64
|
|
mutex sync.Mutex
|
|
expirationDuration time.Duration
|
|
}
|
|
|
|
func (l *InMemoryRateLimiter) Init(expirationDuration time.Duration) {
|
|
if l.store == nil {
|
|
l.mutex.Lock()
|
|
if l.store == nil {
|
|
l.store = make(map[string]*[]int64)
|
|
l.expirationDuration = expirationDuration
|
|
if expirationDuration > 0 {
|
|
go l.clearExpiredItems()
|
|
}
|
|
}
|
|
l.mutex.Unlock()
|
|
}
|
|
}
|
|
|
|
func (l *InMemoryRateLimiter) clearExpiredItems() {
|
|
for {
|
|
time.Sleep(l.expirationDuration)
|
|
l.mutex.Lock()
|
|
now := time.Now().Unix()
|
|
for key := range l.store {
|
|
queue := l.store[key]
|
|
size := len(*queue)
|
|
if size == 0 || now-(*queue)[size-1] > int64(l.expirationDuration.Seconds()) {
|
|
delete(l.store, key)
|
|
}
|
|
}
|
|
l.mutex.Unlock()
|
|
}
|
|
}
|
|
|
|
// Request parameter duration's unit is seconds
|
|
func (l *InMemoryRateLimiter) Request(key string, maxRequestNum int, duration int64) bool {
|
|
l.mutex.Lock()
|
|
defer l.mutex.Unlock()
|
|
// [old <-- new]
|
|
queue, ok := l.store[key]
|
|
now := time.Now().Unix()
|
|
if ok {
|
|
if len(*queue) < maxRequestNum {
|
|
*queue = append(*queue, now)
|
|
return true
|
|
} else {
|
|
if now-(*queue)[0] >= duration {
|
|
*queue = (*queue)[1:]
|
|
*queue = append(*queue, now)
|
|
return true
|
|
} else {
|
|
return false
|
|
}
|
|
}
|
|
} else {
|
|
s := make([]int64, 0, maxRequestNum)
|
|
l.store[key] = &s
|
|
*(l.store[key]) = append(*(l.store[key]), now)
|
|
}
|
|
return true
|
|
}
|