Austin/mihomo
1
0
Fork 0
mirror of https://github.com/MetaCubeX/mihomo.git synced 2024-11-16 19:56:51 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: sticky-sessions异常

Browse Source
This commit is contained in:
gVisor bot 2022-05-18 22:29:27 +08:00
parent fb3472c53a
commit 4e984588f1
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
adapter/outboundgroup/loadbalance.go
View File

@ -152,12 +152,14 @@ func strategyConsistentHashing() strategyFn {
func strategyStickySessions() strategyFn {
ttl := time.Minute * 10
c := cache.New[uint64, int](1 * time.Second)
lruCache := cache.NewLRUCache[uint64, int](
cache.WithAge[uint64, int](int64(ttl.Seconds())),
cache.WithSize[uint64, int](1000))
return func(proxies []C.Proxy, metadata *C.Metadata) C.Proxy {
key := uint64(murmur3.Sum32([]byte(getKeyWithSrcAndDst(metadata))))
length := len(proxies)
idx, expireTime := c.GetWithExpire(key)
if expireTime.IsZero() {
idx, has := lruCache.Get(key)
if !has {
idx = int(jumpHash(key+uint64(time.Now().UnixMilli()), int32(length)))
}
@ -166,8 +168,8 @@ func strategyStickySessions() strategyFn {
proxy := proxies[nowIdx]
if proxy.Alive() {
if nowIdx != idx {
c.Put(key, idx, -1)
c.Put(key, nowIdx, ttl)
lruCache.Delete(key)
lruCache.Set(key, nowIdx)
}
return proxy