心跳机制

common/src/main/java/com/wecloud/im/netty/core/NettyChannelInitializer.java

@@ -9,7 +9,6 @@ import io.netty.handler.codec.http.HttpServerCodec;
 import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
 import io.netty.handler.stream.ChunkedWriteHandler;
 import io.netty.handler.timeout.IdleStateHandler;
-import io.netty.handler.timeout.ReadTimeoutHandler;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -32,7 +31,7 @@ public class NettyChannelInitializer extends ChannelInitializer<SocketChannel> {
         pipeline.addLast("SingleHttpRequestHandler", channelInboundHandler);
 
         // 连接超时管理 (判断通道是否有数据写入)
-        pipeline.addLast("readTimeoutHandler", new ReadTimeoutHandler(60));
+//        pipeline.addLast("readTimeoutHandler", new ReadTimeoutHandler(60));
 
         // "/appws"路径 升级长连接
         pipeline.addLast("appWebSocketServerotocolHandler", new WebSocketServerProtocolHandler(WsConstants.WS_URL));
@@ -45,7 +44,7 @@ public class NettyChannelInitializer extends ChannelInitializer<SocketChannel> {
          * allIdleTime—状态为IdleState的IdleStateEvent。在一定时间内不读不写会触发ALL_IDLE。指定0禁用。
          * unit—readerIdleTime、writeIdleTime和allIdleTime的时间单位
          */
-        pipeline.addLast(new IdleStateHandler(2, 2, 10, TimeUnit.SECONDS));
+        pipeline.addLast(new IdleStateHandler(15, 0, 0, TimeUnit.SECONDS));
     }
 
 }