[Spring] WebSocket 怎么做到集群？

[nnegier]

[hly9469]

nginx ，跟 spring 关系不大

[YIsion]

啊？ WebSocket 是有状态的协议，你说的集群的意思应该是指客户端发起请求能连接到一堆服务器中负载压力小的服务器吧。

[seedhk]

nginx 做负载均衡啊

[m2276699]

盲猜你是不是在问主动推送不知道怎么推？

[zzzzyg]

MQ

[liangkang1436]

一开始跟客户端建立连接的是哪台服务器，后续就必须一直是这台服务器与此客户端通信，在使用 NGINX 进行反向代理的时候，必须保证这一点，否则，在客户端看来，就会断链，为了保证这一点，可以配置 NGINX 的负载均衡策略，保证来自某一个客户端的请求固定映射到某一台服务器，不过为了保险起见，还是应该用一个回话管理器

[kiracyan]

你要的应该是网关服务器，然后再动态分配业务服务器

[qinxi]

自己维护一份 userId 跟服务的映射关系呗. 给他发消息就找映射关系到对应的服务

[dlmy]

网关，Session 会话管理器，一致性 Hash ？

[jimrok]

后端用一个 etcd 或者 zookeeper 管理群集，然后根据客户的 id 用算法映射到群集上，引导客户的连接群集使用的 ip 地址和端口，客户就上了船了。如果群集要下线，发送 websocket 的消息给客户，自己断线然后重新查询群集地址，再连接。

[interim]

先把具体问题抛出来，别把方向整错了。

[yalin]

我们是 AWS 云上面，结合 API Gateway 和 Spring 一起做的

[monkeyk]

若是做推送服务，何不尝试用这类小而美的服务呢，https://www.goeasy.io/

[visper]

估计你说的是，集群系统里面，websocket 连接到了其中一台，但是后续任务在其他台运行怎么推送到特定的人。这种需要后台集群间有自己的通讯机制。比如任务发消息了广播到其他集群机器然后直接推送到连到这台机的 websocket 。

[luobingit]

#14 +1

[ionfev]

简单实现过，使用 Redis 发布订阅，查资料看到还有 MQ 、Zookeeper 、微服务的服务发现。笔记： https://www.cnblogs.com/ioufev/p/17559480.html

[jorneyr]

这个问题其实主要是解决跨 WebSocket Server 发送消息。

A 在 Server-1
B 在 Server-2

A 要给 B 发送私有消息:
1. A 给 Server-1 发送消息
2. Server-1 收到消息，先在自己的连接列表里找 B 得连接
2.1. 如果找到 B 的连接则直接给 B 发送消息
2.2. 如果没有找到 B 的连接则给所有 WebSocket Server 广播给 B 发送消息
3. WebSocket Server 收到广播，然后查看如果消息是自己广播的则抛弃，不是则执行消息的动作

[Masoud2023]

这问题我还真没想过，ws 怎么做负载均衡？

[Aresxue]

这问题想问的是推送，如何把某个用户的信息反向推送到浏览器，浏览器到用户有 nginx 代理 tcp 直接就能找到，这问题说大不大说小不小，简单来说就是维护 user 和 server 的关系，但如果 server 的量级超过 100 就会复杂的多，多活容灾每个细节都值得大费篇章。

[XCFOX]

如果是服务端主动推送的场景的话，可以考虑一下使用消息中间件 NATS: https://nats.io/

NATS 内置了楼上提到的负载均衡、广播等功能。
NATS 能够通过 SDK 与前端、客户端直接连接。
NATS 能够很方便地实现水平扩展，NATS 能够与你的用户权限体系集成。

https://docs.nats.io/running-a-nats-service/configuration/websocket/websocket_conf