与业务系统解耦的WebSocket中间件架构图

......

Bind

使用获取到的WebSocket服务地址建立长连接

WebSocketRouter（路由服务）

RabbitMQ

交换机（Exchange）E.F.message.websocket.push（fanout类型：单个消息会同时发送给多个绑定的队列中）

注册中心

WebSocketServer

调用路由服务获取WebSocket服务地址

业务服务

发送消息订阅请求channel、数据id

主动推送消息到前端

IWebSocketPush：推送消息到MQ中（channel、数据id、消息）

访问业务系统

队列（Queue）

framework-websocket-server集群，每个服务的外网地址需不同。每个WebSocket收到推送消息后，各自都根据channel和id查找对应的连接，如果存在连接，则将消息通过连接发送出去。

通过注册中心拿到所有WebSocket服务的外网地址

服务注册外网地址提供