语境与问题
我们正在建立一个通知系统。
发布服务器用户可以向其他online订阅者用户发送消息。
在线订阅者用户将收到发送的消息。
发布者用户和订阅者用户处于不同的实例中,没有直接的方法可以相互联系。
在罕见的情况下,订阅者可以忽略一些通知(提供了其他检索所有通知的方法)。
解决方案
-出版
Publisher用户将消息发布到RabbitMQ中。
业务逻辑应用于RabbitMQ使用者中的消息。
RabbitMQ使用者将消息发布到Redis事件notification_[subscriber_id]。
-签署
订阅服务器用户连接到WebSocket服务器。
WebSocket服务器与Redis有连接,并在用户连接上订阅Redis事件notification_[subscriber_id]。
在notification_[subscriber_id]上接收消息时,将通过WebSocket向用户发送一条消息。
问题
发行者用户和订阅者用户都可以是任意数量(无限),根据我的研究,Redis似乎对订阅的数量没有限制(如果有,大约40亿),所以
这种在Redis中创建订阅的“动态”方式是可伸缩的吗?
发布于 2022-03-19 12:05:20
是,
您可以在Redis群集模式下水平缩放,这将允许您在缩放过程中继续服务请求。
另外,
设计应用程序来清理订阅也是明智的,因为您似乎正在计划处理数百万/数十亿的订阅,因此在实现之前进行良好的计划是非常重要的。
https://stackoverflow.com/questions/71388787
复制相似问题