From d797b918a410f10a99a69dbf21fcd56e218fcb2b Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Sun, 11 Jan 2026 17:35:31 +0800 Subject: [PATCH] =?UTF-8?q?[update]=20=E4=BB=A3=E7=90=86=E6=A8=A1=E5=BC=8F?= =?UTF-8?q?=E6=97=A0=E6=B3=95=E5=85=B3=E9=97=AD=E7=AC=AC=E4=B8=89=E6=96=B9?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../heartbeat/common/utils/ChannelUtils.java | 11 ++++++----- ...ProtocolHandleSocketLocalProxyTypeAdvanced.java | 4 ++-- .../handler/NettySocketBackendHandler.java | 14 ++++++++++---- .../handler/NettySocks5CommandRequestHandler.java | 2 +- 4 files changed, 19 insertions(+), 12 deletions(-) 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