diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/utils/ChannelUtils.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/utils/ChannelUtils.java index fb5b33ef..3b6c51f6 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/utils/ChannelUtils.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/utils/ChannelUtils.java @@ -94,11 +94,12 @@ public class ChannelUtils { // 第二步:获取底层Socket,强制关闭(核心!抖音场景必须) if (channel instanceof NioSocketChannel) { NioSocketChannel nioChannel = (NioSocketChannel) channel; - Socket socket = nioChannel.javaChannel().socket(); - if (socket != null && !socket.isClosed()) { - socket.setSoLinger(true, 0); // 禁用SO_LINGER,立即关闭 - socket.close(); // 强制关闭Socket,切断TCP连接 - } + +// Socket socket = nioChannel.javaChannel().socket(); +// if (socket != null && !socket.isClosed()) { +// socket.setSoLinger(true, 0); // 禁用SO_LINGER,立即关闭 +// socket.close(); // 强制关闭Socket,切断TCP连接 +// } } // 第三步:关闭Netty通道(兜底) diff --git a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/advanced/NettySocketProtocolHandleSocketLocalProxyTypeAdvanced.java b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/advanced/NettySocketProtocolHandleSocketLocalProxyTypeAdvanced.java index e39d52b5..ba6c6c50 100644 --- a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/advanced/NettySocketProtocolHandleSocketLocalProxyTypeAdvanced.java +++ b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/advanced/NettySocketProtocolHandleSocketLocalProxyTypeAdvanced.java @@ -48,8 +48,8 @@ public class NettySocketProtocolHandleSocketLocalProxyTypeAdvanced b.group(group) .channel(NioSocketChannel.class) - .option(ChannelOption.SO_KEEPALIVE, true) // 开启TCP保活,检测无效连接 - .option(ChannelOption.TCP_NODELAY, true) // 关闭Nagle算法,适配直播流低延迟 +// .option(ChannelOption.SO_KEEPALIVE, true) // 开启TCP保活,检测无效连接 +// .option(ChannelOption.TCP_NODELAY, true) // 关闭Nagle算法,适配直播流低延迟 .option(ChannelOption.SO_RCVBUF, 2048 * 1024)// 设置读缓冲区为2M .option(ChannelOption.SO_SNDBUF, 1024 * 1024)// 设置写缓冲区为1M .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 1000 * 60)//连接超时时间设置为 60 秒 diff --git a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocketBackendHandler.java b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocketBackendHandler.java index fac76f4e..234c636e 100644 --- a/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocketBackendHandler.java +++ b/wu-lazy-cloud-heartbeat-protocol-proxy/src/main/java/org/framework/lazy/cloud/network/heartbeat/protocol/handler/NettySocketBackendHandler.java @@ -2,7 +2,10 @@ package org.framework.lazy.cloud.network.heartbeat.protocol.handler; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; -import io.netty.channel.*; +import io.netty.channel.Channel; +import io.netty.channel.ChannelFutureListener; +import io.netty.channel.ChannelHandlerContext; +import io.netty.channel.SimpleChannelInboundHandler; import io.netty.util.ReferenceCountUtil; import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.NettyByteBuf; @@ -12,10 +15,8 @@ import org.framework.lazy.cloud.network.heartbeat.protocol.properties.ProtocolPr import org.framework.wu.framework.queue.Message; import org.framework.wu.framework.queue.MessageQueue; import org.framework.wu.framework.queue.MessageQueueFactory; -import org.wu.framework.core.utils.ObjectUtils; import org.wu.framework.spring.utils.SpringContextHolder; -import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; @@ -23,6 +24,7 @@ import java.nio.charset.StandardCharsets; public class NettySocketBackendHandler extends SimpleChannelInboundHandler { + @Override public void channelActive(ChannelHandlerContext ctx) { ctx.writeAndFlush(Unpooled.EMPTY_BUFFER); @@ -72,6 +74,8 @@ public class NettySocketBackendHandler extends SimpleChannelInboundHandler