Shikong/Clash.Meta
1
0
Fork 0
mirror of https://gitclone.com/github.com/MetaCubeX/Clash.Meta synced 2025-02-23 20:52:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: sticky-sessions异常

Browse Source
This commit is contained in:
Skyxim 2022-05-18 22:29:27 +08:00
parent 8b09db5f7f
commit 7aff9aac82
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 { func strategyStickySessions() strategyFn {
ttl := time.Minute * 10 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 { return func(proxies []C.Proxy, metadata *C.Metadata) C.Proxy {
key := uint64(murmur3.Sum32([]byte(getKeyWithSrcAndDst(metadata)))) key := uint64(murmur3.Sum32([]byte(getKeyWithSrcAndDst(metadata))))
length := len(proxies) length := len(proxies)
idx, expireTime := c.GetWithExpire(key) idx, has := lruCache.Get(key)
if expireTime.IsZero() { if !has {
idx = int(jumpHash(key+uint64(time.Now().UnixMilli()), int32(length))) idx = int(jumpHash(key+uint64(time.Now().UnixMilli()), int32(length)))
} }
@ -166,8 +168,8 @@ func strategyStickySessions() strategyFn {
proxy := proxies[nowIdx] proxy := proxies[nowIdx]
if proxy.Alive() { if proxy.Alive() {
if nowIdx != idx { if nowIdx != idx {
c.Put(key, idx, -1) lruCache.Delete(key)
c.Put(key, nowIdx, ttl) lruCache.Set(key, nowIdx)
} }
return proxy return proxy