表名修改

xiangpei

2024-04-23 ab4e150d41e0200b64a75c59b668a9385b7782fd

 ycl-server/src/main/java/com/ycl/websocket/WebsocketServer.java

@@ -10,6 +10,7 @@
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import lombok.extern.slf4j.Slf4j;

/**
 * webscoket 服务
@@ -17,6 +18,7 @@
 * @author：xp
 * @date：2024/4/11 17:47
 */
@Slf4j
public class WebsocketServer {

    public static void runWebsocket() throws Exception {
@@ -45,12 +47,13 @@

            // 绑定服务器到指定的端口，并且等待绑定操作完成。
            ChannelFuture f = b.bind(8084).sync();

            log.info("websocket启动成功");
            // 等待服务器的通道关闭。
            f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
            log.info("websocket关闭");
        }
    }