blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2021-05-26 21f93fe6b95e868659bc1af9658a0cd7ba43b203 
 src/main/java/com/xcong/excoin/netty/initalizer/WebSocketServerInitializer.java


@@ -19,8 +19,8 @@


@Component


public class WebSocketServerInitializer extends ChannelInitializer<NioSocketChannel> {




    @Autowired


    private WebSocketServerHandler webSocketServerHandler;


//    @Autowired


//    private WebSocketServerHandler webSocketServerHandler;




    @Override


    protected void initChannel(NioSocketChannel ch) throws Exception {


@@ -32,8 +32,8 @@


        cp.addLast(new HttpObjectAggregator(65536));


        cp.addLast(new ChunkedWriteHandler());


        // 心跳


        ch.pipeline().addLast(new IdleStateHandler(0, 10, 0));


//        ch.pipeline().addLast(new IdleStateHandler(0, 10, 0));


        // 自定义业务handler


        cp.addLast(webSocketServerHandler);


        cp.addLast(new WebSocketServerHandler());


    }


}