From dca3e301410be4aee5a7895a1c2c1bbf90f3d03b Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Wed, 16 Mar 2022 15:21:36 +0800 Subject: [PATCH] 20222223 --- src/main/java/com/xcong/excoin/netty/server/WebSocketServer.java | 9 ++++----- 1 files changed, 4 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/server/WebSocketServer.java b/src/main/java/com/xcong/excoin/netty/server/WebSocketServer.java index 84b1290..8ef1aef 100644 --- a/src/main/java/com/xcong/excoin/netty/server/WebSocketServer.java +++ b/src/main/java/com/xcong/excoin/netty/server/WebSocketServer.java @@ -19,14 +19,13 @@ @Component("webSocketServer") public class WebSocketServer implements ChatServer { - private EventLoopGroup boss = new NioEventLoopGroup(); private EventLoopGroup work = new NioEventLoopGroup(); private ChannelFuture channelFuture; - @Autowired - private WebSocketServerInitializer webSocketServerInitializer; +// @Autowired +// private WebSocketServerInitializer webSocketServerInitializer; @Override public void start() throws Exception { @@ -35,9 +34,9 @@ ServerBootstrap b = new ServerBootstrap(); b.group(boss, work) .channel(NioServerSocketChannel.class) - .childHandler(webSocketServerInitializer); + .childHandler(new WebSocketServerInitializer()); - channelFuture = b.bind(9999).sync(); + channelFuture = b.bind(9998).sync(); log.info("[websocket服务器启动完成]-->{}", channelFuture.channel().localAddress()); } finally { -- Gitblit v1.9.1