09-16-01

xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServer.java

@@ -68,12 +68,12 @@ public class ChatServer  {
                 });
 
             log.info("Netty聊天服务器启动，端口：" + port);
-//            bootstrap.bind(port).sync();
-            ChannelFuture future = bootstrap.bind(port).sync();
-            future.channel().closeFuture().sync();
+            bootstrap.bind(port).sync();
+//            ChannelFuture future = bootstrap.bind(port).sync();
+//            future.channel().closeFuture().sync();
         } finally {
-            workerGroup.shutdownGracefully().sync();
-            bossGroup.shutdownGracefully().sync();
+//            workerGroup.shutdownGracefully().sync();
+//            bossGroup.shutdownGracefully().sync();
         }
     }
 

xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/ChatServerHandler.java

@@ -441,6 +441,7 @@ public class ChatServerHandler extends SimpleChannelInboundHandler<TextWebSocket
 
         ctx.channel().writeAndFlush(new TextWebSocketFrame(message));
     }
+
     //发送群消息,此时其他客户端也能收到群消息
     private void sendAllMessage(){
         String message = "我是服务器，这里发送的是群消息";