如何用C#订阅远程Redis事件？现有实现是否存在遗漏？

1. ConnectionMultiplexer的生命周期问题 #

你把ConnectionMultiplexer放在using块里了——当代码执行到using块末尾，连接会被自动释放，你的监听也就直接停止了！Windows服务需要长期运行，ConnectionMultiplexer应该是全局单例，在服务启动时初始化，停止时再手动释放，绝对不能用using包裹。

2. Redis键空间通知默认是关闭的 #

Redis默认不会发送任何键空间事件通知，你必须先修改Redis的配置文件（redis.conf），设置notify-keyspace-events参数。如果要监听所有类型的事件，配置成：

notify-keyspace-events AKE

• A表示所有事件
• K表示键空间通知（也就是你订阅的__keyspace@db__:*）
• E表示键事件通知（如果需要的话，不过你当前只关注键空间，至少要开K）
  修改后重启Redis服务才会生效。

3. 监听范围可能不全 #

你现在订阅的是__keyspace@0__:*，这只能监听第0个数据库的事件。如果你的Redis实例有多个数据库（比如db1、db2），这些库的事件你就收不到了。如果要监听所有数据库的事件，应该订阅：

subscriber.Subscribe("__keyspace@*__:*", ...);

4. 计数器的线程安全问题 #

你的int f在订阅回调里被修改，但StackExchange.Redis的订阅回调是在多线程环境下触发的，普通的int自增不是原子操作，会导致计数错误。必须用Interlocked.Increment来保证线程安全：

Interlocked.Increment(ref f);

5. 连接状态的异常处理 #

Redis连接可能会因为网络问题断开，StackExchange.Redis会自动重连，但你最好监听连接状态事件，方便排查问题或做降级处理：

connection.ConnectionFailed += (sender, args) => {
    // 记录连接失败日志，比如用NLog/Serilog
};
connection.ConnectionRestored += (sender, args) => {
    // 记录连接恢复日志
};

修复后的示例代码（适配Windows服务） #

// 全局单例的连接实例
private static ConnectionMultiplexer _redisConnection;
private static int _eventCounter;

protected override void OnStart(string[] args)
{
    var endp = "x.x.x.x:xxxx";
    // 初始化连接（带配置选项，比如重连策略）
    var config = ConfigurationOptions.Parse(endp);
    config.AbortOnConnectFail = false; // 避免初始连接失败直接崩溃
    _redisConnection = ConnectionMultiplexer.Connect(config);

    // 监听连接状态
    _redisConnection.ConnectionFailed += (sender, args) =>
    {
        Console.WriteLine($"Redis连接失败: {args.Exception.Message}");
    };

    _redisConnection.ConnectionRestored += (sender, args) =>
    {
        Console.WriteLine("Redis连接已恢复");
    };

    var subscriber = _redisConnection.GetSubscriber();
    // 订阅所有数据库的键空间事件
    subscriber.Subscribe("__keyspace@*__:*", (channel, value) =>
    {
        // 线程安全地增加计数器
        Interlocked.Increment(ref _eventCounter);
        // 调试时可以打印事件详情
        Console.WriteLine($"收到事件: 通道={channel}, 操作={value}");
    });
}

protected override void OnStop()
{
    // 服务停止时释放连接
    _redisConnection?.Dispose();
}

额外注意事项 #

• 确保你的Windows服务账号有访问远程Redis的权限（防火墙开放端口，Redis配置允许远程连接）
• 如果Redis设置了密码，要在连接字符串里加上password=你的密码，或者在ConfigurationOptions里设置config.Password = "你的密码"
• 生产环境一定要加日志记录，方便排查监听异常

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