spring中使用netty-socketio部署到服务器（SSL、nginx转发）

spring中使用netty-socketio部署到服务器（SSL、nginx转发）

本文实现前端socket.io-client连接后端netty-socketio，并且部署到服务器上的示例，以及说明一些实现过程中可能遇到的错误。

socketio默认基于的路径是/socket.io

传输方式有三种分别是：

1、polling

polling是最传统的基于http的方式、兼容性强，定期向服务端循环是否还保持链接，这种方式也是websocket无法使用时的降级选择。

2、websocket

全双工通信、维持客户端和服务端之间的持久连接，它比轮询更有效，因为它消除了HTTP请求/响应周期。浏览器基本上都支持。

3、webtransport

基于HTTP/3和QUIC的较新的传输协议、提供低延迟、双向、多路通信、支持可靠（类似tcp）和不可靠（类似udp）的数据传输、专为高性能应用程序，如游戏和视频流、对比WebSockets有更好的拥塞控制和连接迁移，但它还没有像WebSockets那样被广泛支持。

如果你选择polling模式，可以使用extraHeaders，因为它基于http，但是使用websocket模式时，extraHeaders无效，但是也有替换方案，websocket可以把参数传到url里面中。

坑①：用polling模式本地连接正常，但是部署到服务器出现PollingTransport:167 - <sessionId> is not registered. Closing connection，一致没搞懂为什么。

由于坑①，前端指定使用websocket模式连接，假设后端netty-socketio开放9000端口，首先编写一个socket实例

const socket = *ref*<Socket | null>(null);
socket.value = io("http://127.0.0.1:9000",{path: "/socket.io",// 默认是socket.iowithCredentials: true,// 允许跨域transports: ["websocket"],// 指定传输模式}
);

path路径默认是socket.io，当然可以后端通过配置修改

后端基于spring编写一个bean

@Bean
public SocketIOServer socketIOServer() {Configuration config = new Configuration();config.setPort(9000);config.setHostname("0.0.0.0");config.setJsonSupport(new JacksonJsonSupport());config.setExceptionListener(new DefaultExceptionListener());config.setHttpCompression(false);config.setWebsocketCompression(false);config.setKeyStore(getCertJks());// 如果你有证书这样配置config.setKeyStorePassword("8di1g1a8");// 证书密码，没有可以删除这两行return new SocketIOServer(config);
}

坑②：如果你使用的是polling模式，传了请求头，那么后端必须在配置中允许该请求头，否则接收不到

config.setAllowHeaders(tokenName);

再写个启动服务类

@Component
@Slf4j
public class SocketIOEventListener {private final SocketIOServer socketIOServer;private final WebSocketService webSocketService;@Autowiredpublic SocketIOEventListener(SocketIOServer socketIOServer, WebSocketService webSocketService) {this.socketIOServer = socketIOServer;this.webSocketService = webSocketService;}@PostConstructprivate void init() {socketIOServer.addConnectListener(client -> {webSocketService.connect(client);});socketIOServer.addDisconnectListener(client -> {webSocketService.disconnect(client);});socketIOServer.start();}@PreDestroyprivate void destroy() {// 关闭服务器socketIOServer.stop();}
}

WebSocketService.class如下

@Service
@Slf4j
@RequiredArgsConstructor
public class WebSocketService {public void connect(SocketIOClient client) {//....连接成功}public void disconnect(SocketIOClient client) {//....断开成功}
}

前端本地测试成功连通，之后尝试部署服务器，我有一个域名xxx.cn服务器，其中nginx在这个服务器上，我的后端服务在另一个服务器上，我需要使用xxx.cn/socket把服务转发到另一个后端服务器上去，于是编写nginx配置

location /socket{proxy_pass http://120.11.111.11:9000;# 随便编的IPrewrite "^/socket/(.*)$" /$1 break;
}

因为要通过socket转发，前端socket我这样写

socket.value = io("https://www.guetzjb.cn/socket",{path: "/socket/socket.io",withCredentials: true,transports: ["websocket"],}
);

看起来很合理，结果现实马上就能给你当头一棒

后端一连接上就立马断开了，秒断

5247fb7d-804b-403f-8ca7-84d876fb017c连接成功，当前在线人数1
5247fb7d-804b-403f-8ca7-84d876fb017c断开成功，当前在线人数0

前端socket数据是这样的

0{"sid":"5247fb7d-804b-403f-8ca7-84d876fb017c","upgrades":[],"pingInterval":25000,"pingTimeout":60000}
40/socket
44/draw-socket,"Invalid namespace"

收集到关键词Invalid namespace，经过服务器得靠socket转发，这是识别成namespace了？

正确姿势👇

修改启动类新增namespace

@Component
@Slf4j
public class SocketIOEventListener {//........@PostConstructprivate void init() {//其他代码SocketIONamespace ns = socketIOServer.addNamespace("/socket");// 必须斜杠开头ns.addConnectListener(client -> {// 之后的监听器需要网该命名空间上加});//其他代码}//.........
}

注意新增命名空间必须是 / 开头，否则无效，默认明明空间就是/，但是加入你这样做

SocketIONamespace ns = socketIOServer.addNamespace("/");
ns.addConnectListener(client -> {// 无效做法，连不上
});

坑③：上面这也连不上，默认命名空间必须使用socketIOServer.addConnectListener

当然，使用/socket就可以正常连接了

此时本地代码和线上代码都使用一个namespace就可以了

socket.value = io("http://127.0.0.1:9000/socket",//使用socket namespace{path: "/socket.io",withCredentials: true,transports: ["websocket"],}
);

部署到线上需要通过socket转发

所以线上的path需要这样

socket.value = io("http://127.0.0.1:9000/socket",//使用socket namespace{path: "/socket/socket.io",withCredentials: true,transports: ["websocket"],}
);

配置上nginx

location /socket/socket.io{proxy_pass http://120.11.111.11:9000;rewrite "^/socket/(.*)$" /$1 break;proxy_http_version 1.1;proxy_set_header Upgrade $http_upgrade;proxy_set_header Connection "Upgrade";
}

socket.io需要升级为长链接，原先的/socket正常转发

再次部署

本地和线上都跑起来啦！

测试是不用设置setKeyStore的，当然你也可以设置上👇

@Bean
public SocketIOServer socketIOServer() {Configuration config = new Configuration();// 其他配置
//        config.setKeyStore(getCertJks());
//        config.setKeyStorePassword("zfs2k32p");return new SocketIOServer(config);
}private InputStream getCertJks() {ClassPathResource classPathResource = new ClassPathResource("xxxx.cn.jks");return classPathResource.getStream();
}