From d78624caa783c00c0e6387bc17c25ae386e84f03 Mon Sep 17 00:00:00 2001 From: DJX Date: Wed, 20 Sep 2023 12:39:03 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BC=98=E5=8C=96]=E9=81=BF=E5=85=8D=E5=A4=9A?= =?UTF-8?q?=E6=AC=A1=E5=88=9B=E5=BB=BANettyWebSocketServerHandler?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../abin/mallchat/common/websocket/NettyWebSocketServer.java | 3 ++- .../mallchat/common/websocket/NettyWebSocketServerHandler.java | 2 ++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServer.java b/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServer.java index 88780dd..ec24883 100644 --- a/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServer.java +++ b/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServer.java @@ -27,6 +27,7 @@ import javax.annotation.PreDestroy; @Configuration public class NettyWebSocketServer { public static final int WEB_SOCKET_PORT = 8090; + public static final NettyWebSocketServerHandler NETTY_WEB_SOCKET_SERVER_HANDLER = new NettyWebSocketServerHandler(); // 创建线程池执行器 private EventLoopGroup bossGroup = new NioEventLoopGroup(1); private EventLoopGroup workerGroup = new NioEventLoopGroup(NettyRuntime.availableProcessors()); @@ -90,7 +91,7 @@ public class NettyWebSocketServer { */ pipeline.addLast(new WebSocketServerProtocolHandler("/")); // 自定义handler ，处理业务逻辑 - pipeline.addLast(new NettyWebSocketServerHandler()); + pipeline.addLast(NETTY_WEB_SOCKET_SERVER_HANDLER); } }); // 启动服务器，监听端口，阻塞直到启动成功 diff --git a/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServerHandler.java b/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServerHandler.java index 040ee0b..2c258b8 100644 --- a/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServerHandler.java +++ b/mallchat-chat-server/src/main/java/com/abin/mallchat/common/websocket/NettyWebSocketServerHandler.java @@ -7,6 +7,7 @@ import com.abin.mallchat.common.user.domain.enums.WSReqTypeEnum; import com.abin.mallchat.common.user.domain.vo.request.ws.WSAuthorize; import com.abin.mallchat.common.user.domain.vo.request.ws.WSBaseReq; import com.abin.mallchat.common.user.service.WebSocketService; +import io.netty.channel.ChannelHandler.Sharable; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.SimpleChannelInboundHandler; import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; @@ -17,6 +18,7 @@ import lombok.extern.slf4j.Slf4j; @Slf4j +@Sharable public class NettyWebSocketServerHandler extends SimpleChannelInboundHandler { private WebSocketService webSocketService;