diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/HeartBeatClientHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/HeartBeatClientHandler.java index 74e3a156..72f89527 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/HeartBeatClientHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/HeartBeatClientHandler.java @@ -8,13 +8,12 @@ import io.netty.handler.timeout.IdleStateEvent; import java.util.Date; public class HeartBeatClientHandler extends ChannelInboundHandlerAdapter { - private int lossConnectCount = 0; + private final int lossConnectCount = 0; @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { System.out.println("客户端循环心跳监测发送: " + new Date()); - if (evt instanceof IdleStateEvent) { - IdleStateEvent event = (IdleStateEvent) evt; + if (evt instanceof IdleStateEvent event) { if (event.state() == IdleState.WRITER_IDLE) { ctx.writeAndFlush("biubiu"); } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/NettyClientHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/NettyClientHandler.java index 2a4b5cdc..ec103891 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/NettyClientHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/wu/framework/lazy/cloud/heartbeat/client/netty/handler/NettyClientHandler.java @@ -1,9 +1,5 @@ package wu.framework.lazy.cloud.heartbeat.client.netty.handler; -import wu.framework.lazy.cloud.heartbeat.client.netty.socket.NettyClientSocket; -import wu.framework.lazy.cloud.heartbeat.common.MessageType; -import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg; -import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter; import io.netty.channel.Channel; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.EventLoop; @@ -11,6 +7,10 @@ import io.netty.channel.SimpleChannelInboundHandler; import io.netty.handler.timeout.IdleState; import io.netty.handler.timeout.IdleStateEvent; import lombok.extern.slf4j.Slf4j; +import wu.framework.lazy.cloud.heartbeat.client.netty.socket.NettyClientSocket; +import wu.framework.lazy.cloud.heartbeat.common.MessageType; +import wu.framework.lazy.cloud.heartbeat.common.NettyProxyMsg; +import wu.framework.lazy.cloud.heartbeat.common.adapter.ChannelTypeAdapter; import java.nio.charset.StandardCharsets; import java.util.Date; @@ -91,8 +91,7 @@ public class NettyClientHandler extends SimpleChannelInboundHandler 2) { diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java index e2eaaeaa..28d2cae6 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java @@ -54,8 +54,7 @@ public class NettyServerHandler extends SimpleChannelInboundHandler