使用 Booksleeve 维护开放的 Redis PubSub 订阅

Question

我正在使用 Redis 发布订阅通道将消息从工作进程池发送到我的 ASP.NET 应用程序。收到消息后，我的应用程序会使用 SignalR 将消息转发到客户端的浏览器。

我发现 this solution 可以保持与 Redis 的开放连接，但它在重新创建连接时不考虑订阅。

我目前正在我的 Global.asax 文件中处理 Redis 发布订阅消息：

public class Application : HttpApplication
{
    protected void Application_Start()
    {
        var gateway = Resolve<RedisConnectionGateway>();
        var connection = gateway.GetConnection();
        var channel = connection.GetOpenSubscriberChannel();

        channel.PatternSubscribe("workers:job-done:*", OnExecutionCompleted);
    }

    /// <summary>
    /// Handle messages received from workers through Redis.</summary>
    private static void OnExecutionCompleted(string key, byte[] message)
    {
        /* forwarded the response to the client that requested it */
    }
}

当当前的 RedisConnection 出于某种原因关闭时，就会出现问题。最简单的解决方案是在连接重置后从RedisConnectionGateway 类中触发一个事件，然后使用新的RedisSubscriberChannel 重新订阅。但是，在重置连接时发布到通道的任何消息都将丢失。

是否有处理这种情况的推荐方法示例？

Answer 1

是的，如果连接中断（网络不稳定、重新控制等），那么您将需要重新应用您所做的任何订阅。重新连接和重新订阅的事件是很正常的，与我们在 SE/SO 上使用的没有太大区别（除了我们通常跟踪更精细的订阅，并有一些处理所有这些的包装代码）。

是的，在您的连接中断时发布的所有事件都已消失。这就是 redis pub/sub 的本质；它不保证交付给断开连接的客户端。要么使用 确实 承诺这一点的工具，要么使用 redis 来驱动队列 - 向/从列表的两端推送/弹出通常是一个合理的选择，并确保不会丢失任何东西（只要因为您的软件在从列表中弹出它后不会删除它）。如果有帮助，我的列表中有一个添加阻塞弹出方法的请求——它们完全破坏了多路复用器的意图，但在某些情况下它们确实有用，所以我不反对添加它们。