文件名称:spring-wesocket-cluster:weboscket 集群方案 http
文件大小:93KB
文件格式:ZIP
更新时间:2024-06-06 01:09:12
Java
redis 用来存用户与服务器的关系(redis可以任意替换为一种存储形式) 服务器 A 会订阅topic 为 WebSocket-A 的消息 服务器 B 会订阅topic 为 WebSocket-B 的消息 kafka 用来接收推送消息(替换为任意一种mq) 如果用户1需要给用户3发送信息,如果在单机情况下,由于用户3没有与server-A建立链接,所以推送不到。但是现在因为在redis存储了用户3和server-B的关联关系,所以直接推送到WebSocket-B主题之中即可。由server-B接受消息并推送给用户3。 优点: 解决了集群情况下跨机器通讯问题。 缺点: 没有达到随意增减节点的需求,新加机器需要配置server-id。 编程复杂,需要手动注册kafka-listener消息节点。 再宕机的情况下,假如A服务器宕机了,WEBSOCKET-A的消息就没有消费者了,所以只要在能重
【文件预览】:
spring-wesocket-cluster-master
----pom.xml(5KB)
----wuhulala-cache()
--------pom.xml(1KB)
--------src()
----LICENSE(11KB)
----websocket-config-test()
--------pom.xml(2KB)
--------src()
----.gitignore(12B)
----README.md(3KB)
----.gitattributes(89B)