From a9b6dddf701f8c3e9b21b5f9163bf31820b14f48 Mon Sep 17 00:00:00 2001 From: Victor_Jay Date: Sun, 31 May 2026 12:22:26 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=BF=81=E7=A7=BB=E6=88=90=E5=8A=9F?= =?UTF-8?q?=E5=90=8E=E7=AB=8B=E5=8D=B3=E6=B8=85=E7=90=86=E5=86=85=E5=AD=98?= =?UTF-8?q?=E4=B8=AD=E5=B7=B2=E8=BF=81=E7=A7=BB=E7=9A=84=E4=BC=9A=E8=AF=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - migrateSessions() 写入 Redis 后删除 MemoryStore 中对应数据 - 避免残留数据等到 TTL 自然过期才清理（最长 30 天） --- internal/session/fallback_store.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/internal/session/fallback_store.go b/internal/session/fallback_store.go index 2dcfed9..cb24da0 100644 --- a/internal/session/fallback_store.go +++ b/internal/session/fallback_store.go @@ -136,7 +136,12 @@ func (fs *FallbackStore) migrateSessions() { return } - log.Printf("[FallbackStore] Redis 已恢复，静默迁移 %d 条会话", len(sessions)) + // 迁移成功后清理内存中的残留数据 + for _, s := range sessions { + _ = fs.memory.Delete(s.ID) + } + + log.Printf("[FallbackStore] Redis 已恢复，静默迁移 %d 条会话（内存已清理）", len(sessions)) } // ping 检查 Redis 连接状态（带超时）