diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java index 187a93c..a61cf53 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/socket/NettyClientPermeateClientRealSocket.java @@ -134,7 +134,7 @@ public class NettyClientPermeateClientRealSocket { future.addListener((ChannelFutureListener) futureListener -> { Channel visitorChannel = futureListener.channel(); if (futureListener.isSuccess()) { - + realChannel.config().setOption(ChannelOption.AUTO_READ, true); // 通知服务端访客连接成功 NettyProxyMsg nettyProxyMsg = new NettyProxyMsg(); nettyProxyMsg.setVisitorId(visitorId);