init otc

Helius

2022-03-09 38179780b2f728abe6dd0e5aaa284c6ee6aa8380

 src/main/java/com/xcong/excoin/netty/server/WebSocketServer.java

@@ -19,27 +19,26 @@
@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 {
        log.info("[websocket服务器启动]");
        log.info("[netty websocket服务器启动]");
        try {
            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());
            log.info("[netty websocket服务器启动完成 : {}]", channelFuture.channel().localAddress());
        } finally {
            Runtime.getRuntime().addShutdownHook(new Thread() {
                @Override