From 14bf9ee7665cf043d70d6f08f4f06d0a7042c293 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Fri, 28 May 2021 14:58:25 +0800 Subject: [PATCH] 20210528 --- 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