From 402f6f0ac101626c65897354b15056b369a2c1ee Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Sun, 6 Apr 2025 22:18:22 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=20bug=20fix?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...eDistributeHttpClientProxyClientTransferRequestAdvanced.java | 2 ++ .../handler/NettyHttpClientProxyClientTransferRealHandler.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced.java index 1467c53..7a9b8a0 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/advanced/ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced.java @@ -40,6 +40,8 @@ public class ClientHandleDistributeHttpClientProxyClientTransferRequestAdvanced ByteBuf buf = channel.config().getAllocator().buffer(nettyProxyMsg.getData().length); buf.writeBytes(nettyProxyMsg.getData()); nextChannel.writeAndFlush(buf); + }else { + log.info("客户端代理到另一个客户端,发送请求到目标客户端但是未找到真实通道"); } } diff --git a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/handler/NettyHttpClientProxyClientTransferRealHandler.java b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/handler/NettyHttpClientProxyClientTransferRealHandler.java index b261ffe..8a20c88 100644 --- a/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/handler/NettyHttpClientProxyClientTransferRealHandler.java +++ b/wu-lazy-cloud-heartbeat-client/src/main/java/org/framework/lazy/cloud/network/heartbeat/client/netty/proxy/http/handler/NettyHttpClientProxyClientTransferRealHandler.java @@ -39,7 +39,7 @@ public class NettyHttpClientProxyClientTransferRealHandler extends SimpleChannel String clientId = ChannelAttributeKeyUtils.getClientId(ctx.channel()); String visitorId = ChannelAttributeKeyUtils.getVisitorId(ctx.channel()); Channel nextChannel = ChannelAttributeKeyUtils.getNextChannel(ctx.channel()); - log.warn("close client permeate client transfer real clientId:{} visitorId:{}", clientId, visitorId); + log.warn("close client proxy client transfer real clientId:{} visitorId:{}", clientId, visitorId); // 关闭访客 if (nextChannel != null) { // 上报关闭这个客户端的访客通道