ASP.NET Core如何列出并遍历所有当前活跃会话？

在ASP.NET Core中，Session的管理机制和传统非Core版本差异较大，没有原生的Session_Start/Session_End事件，但可以通过以下几种方案实现活跃会话的追踪及超时处理：

1. 基于分布式缓存的过期回调 #

ASP.NET Core默认将Session数据存储在分布式缓存（如Redis、SQL Server缓存）中，大部分分布式缓存支持键过期通知机制：

• 以Redis为例，可开启键空间通知，监听expired事件，当Session对应的缓存键过期时，触发自定义逻辑处理会话结束业务。
• 若使用自定义分布式缓存实现，可在缓存提供器中封装过期回调逻辑，当Session键过期时主动通知应用程序。

示例代码（Redis键空间通知处理）：

// 配置Redis连接并开启键空间通知
var redis = ConnectionMultiplexer.Connect("localhost,allowAdmin=true");
var server = redis.GetServer("localhost");
server.ConfigSet("notify-keyspace-events", "Ex"); // 开启过期事件通知

// 订阅过期事件
var subscriber = redis.GetSubscriber();
subscriber.Subscribe("__keyevent@0__:expired", (channel, key) => {
    var sessionKeyPrefix = "AspNetCoreSession_";
    if (key.ToString().StartsWith(sessionKeyPrefix)) {
        var sessionId = key.ToString().Replace(sessionKeyPrefix, "");
        // 处理Session结束逻辑，比如移除活跃会话列表记录
        RemoveActiveSession(sessionId);
    }
});

2. 自定义Session存储提供器 #

通过实现ISessionStore接口，自定义Session的存储逻辑，直接处理会话的创建和过期：

• 会话首次创建时（对应Session_Start），将SessionID加入活跃会话列表。
• 重写存储逻辑，在会话过期或被主动清除时，触发会话结束的处理逻辑。

示例代码（自定义Session存储片段）：

public class CustomSessionStore : ISessionStore
{
    private readonly IActiveSessionTracker _sessionTracker;
    private readonly IDistributedCache _cache;

    public CustomSessionStore(IActiveSessionTracker sessionTracker, IDistributedCache cache)
    {
        _sessionTracker = sessionTracker;
        _cache = cache;
    }

    public async Task<ISession> CreateSessionAsync(string sessionId, TimeSpan idleTimeout, CancellationToken cancellationToken = default)
    {
        // 会话创建时加入活跃列表
        await _sessionTracker.AddActiveSessionAsync(sessionId);
        return new CustomSession(sessionId, idleTimeout, _cache, _sessionTracker);
    }

    // 其他接口实现...
}

// 自定义Session类，在过期时移除活跃列表
public class CustomSession : ISession
{
    private readonly string _sessionId;
    private readonly IActiveSessionTracker _sessionTracker;
    // 其他字段...

    public async Task CommitAsync(CancellationToken cancellationToken = default)
    {
        if (IsExpired)
        {
            await _sessionTracker.RemoveActiveSessionAsync(_sessionId);
        }
        // 其他提交逻辑...
    }
}

3. 客户端心跳+服务端定时扫描 #

通过客户端定时发送心跳请求，服务端记录每个Session的最后活跃时间，再通过后台定时任务扫描并清理超时会话：

• 客户端：用JavaScript定时（如每隔5分钟）向服务端发送AJAX请求，更新当前Session的活跃时间。
• 服务端：维护一个存储活跃会话的集合（如内存缓存或数据库），后台任务每隔一段时间（如10分钟）扫描集合，移除超过Session超时时间的会话，并触发结束逻辑。

示例代码（服务端定时扫描）：

// 注册后台服务
services.AddHostedService<SessionCleanupService>();

public class SessionCleanupService : BackgroundService
{
    private readonly IActiveSessionTracker _sessionTracker;
    private readonly IConfiguration _configuration;

    public SessionCleanupService(IActiveSessionTracker sessionTracker, IConfiguration configuration)
    {
        _sessionTracker = sessionTracker;
        _configuration = configuration;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var sessionTimeout = _configuration.GetValue<int>("Session:Timeout"); // 读取Session超时时间（分钟）
        while (!stoppingToken.IsCancellationRequested)
        {
            await _sessionTracker.CleanupExpiredSessionsAsync(TimeSpan.FromMinutes(sessionTimeout));
            await Task.Delay(TimeSpan.FromMinutes(10), stoppingToken); // 每10分钟扫描一次
        }
    }
}

// 活跃会话追踪接口实现
public class ActiveSessionTracker : IActiveSessionTracker
{
    private readonly ConcurrentDictionary<string, DateTime> _activeSessions = new();

    public Task AddActiveSessionAsync(string sessionId)
    {
        _activeSessions.AddOrUpdate(sessionId, DateTime.UtcNow, (_, __) => DateTime.UtcNow);
        return Task.CompletedTask;
    }

    public Task UpdateSessionActivityAsync(string sessionId)
    {
        if (_activeSessions.ContainsKey(sessionId))
        {
            _activeSessions[sessionId] = DateTime.UtcNow;
        }
        return Task.CompletedTask;
    }

    public Task CleanupExpiredSessionsAsync(TimeSpan timeout)
    {
        var cutoffTime = DateTime.UtcNow.Subtract(timeout);
        var expiredSessionIds = _activeSessions.Where(kv => kv.Value < cutoffTime).Select(kv => kv.Key).ToList();
        foreach (var sessionId in expiredSessionIds)
        {
            _activeSessions.TryRemove(sessionId, out _);
            // 触发Session结束逻辑，如记录日志、清理关联资源
            OnSessionEnd(sessionId);
        }
        return Task.CompletedTask;
    }

    private void OnSessionEnd(string sessionId)
    {
        // 自定义会话结束处理逻辑
        Console.WriteLine($"Session {sessionId} has ended.");
    }
}

内容的提问来源于stack exchange，提问作者Jack Miller