| | |
| | | @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 { |
| | |
| | | ServerBootstrap b = new ServerBootstrap(); |
| | | b.group(boss, work) |
| | | .channel(NioServerSocketChannel.class) |
| | | .childHandler(webSocketServerInitializer); |
| | | .childHandler(new WebSocketServerInitializer() ); |
| | | |
| | | channelFuture = b.bind(9999).sync(); |
| | | channelFuture = b.bind(9982).sync(); |
| | | |
| | | log.info("[websocket服务器启动完成]-->{}", channelFuture.channel().localAddress()); |
| | | } finally { |