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 连接状态(带超时)