使用 STOMP over SockJS 实现的 SpringBoot 脚手架项目,可用于快速搭建 WebSocket 工程(支持集群)
- 启动项目
- 浏览器打开 http://localhost:8025
- 登录 (账号: admin 密码: 123456)
- 发送任意的文本内容,服务器将回复相同的内容并加上 Echo 前缀
效果展示:
当收到消息时,服务端会打印当前在线人数:
当前本系统总在线人数: 1, 当前用户: admin, 该用户的客户端连接数: 1
Spring 是支持 WebSocket 集群的,但是网上很少有资料介绍,官方文档对于相关的配置说明也比较模糊
为此,作者查了许多资料和源码,具体配置可以查看 WebSocketConfig类,里面有非常详细的注释说明
WebSocket 集群必须依赖全功能的消息Broker(full-featured message broker),推荐使用 RabbitMQ
具体查看 RabbitMQ安装和集群搭建教程
websocket:
broker:
use-simple-broker: false
username: test
password: Passw0rd
virtualHost: "/stomp"
# 地址可配置一个或多个,当其中一个不可用时,会自动切换以保证高可用
addresses:
- 127.0.0.1:61613
WebSocket 在连接的时候需要做一次连接升级,而 Nginx 默认是不支持连接升级的,因此如果需要使用 Nginx 做负载均衡的话,要添加以下配置
location /ws{
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
# 指定域名
proxy_pass 域名;
proxy_redirect off;
}
当然,如果不添加此配置,SockJS 会为我们自动降级,也能保证可用,但是性能会降低。
- Websocket Stomp Handle Broker Relay
- STOMP Protocol Specification
- STOMP Over WebSocket
- CentOS6和CentOS7环境下RabbitMQ安装配置和非ROOT权限启动及集群搭建最完整教程
- CentOs7.3 搭建 RabbitMQ 3.6 Cluster 集群服务与使用
- Using RabbitMQ stomp adapter to relay message across subscriptions in different servers
- What is MultiServerUserRegistry in spring websocket?
- Spring Websockets Broker relay supporting a cluster of STOMP endpoint addresses
- spring-framework#diff-11144739384955df1f8f38cbcde8d95b