From 61d5fd4ace2f9b6455dcf13df54a7ba7fa2baf36 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Thu, 27 May 2021 16:25:32 +0800 Subject: [PATCH] Merge branch 'otc' of http://120.27.238.55:7000/r/exchange into otc --- src/main/java/com/xcong/excoin/netty/initalizer/WebSocketServerInitializer.java | 7 ++----- 1 files changed, 2 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/initalizer/WebSocketServerInitializer.java b/src/main/java/com/xcong/excoin/netty/initalizer/WebSocketServerInitializer.java index 54cb224..25f3130 100644 --- a/src/main/java/com/xcong/excoin/netty/initalizer/WebSocketServerInitializer.java +++ b/src/main/java/com/xcong/excoin/netty/initalizer/WebSocketServerInitializer.java @@ -19,9 +19,6 @@ @Component public class WebSocketServerInitializer extends ChannelInitializer<NioSocketChannel> { - @Autowired - private WebSocketServerHandler webSocketServerHandler; - @Override protected void initChannel(NioSocketChannel ch) throws Exception { ChannelPipeline cp = ch.pipeline(); @@ -32,8 +29,8 @@ cp.addLast(new HttpObjectAggregator(65536)); cp.addLast(new ChunkedWriteHandler()); // 心跳 - ch.pipeline().addLast(new IdleStateHandler(0, 10, 0)); + ch.pipeline().addLast(new IdleStateHandler(10, 0, 0)); // 自定义业务handler - cp.addLast(webSocketServerHandler); + cp.addLast(new WebSocketServerHandler()); } } -- Gitblit v1.9.1