From d4846a88486829dd24b939774c094a0b39ff0609 Mon Sep 17 00:00:00 2001 From: qiminbao Date: Mon, 25 Aug 2025 18:03:16 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF=E5=88=B0mq?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tongran/agenttcp/server/handler/AgentDecoderHandler.java | 4 ++-- .../tongran/agenttcp/server/handler/AgentEncoderHandler.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/tongran/agenttcp/server/handler/AgentDecoderHandler.java b/src/main/java/com/tongran/agenttcp/server/handler/AgentDecoderHandler.java index 9b28199..3343d96 100644 --- a/src/main/java/com/tongran/agenttcp/server/handler/AgentDecoderHandler.java +++ b/src/main/java/com/tongran/agenttcp/server/handler/AgentDecoderHandler.java @@ -46,7 +46,7 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter { if (msg instanceof ByteBuf) { ByteBuf byteBuf = (ByteBuf) msg; String messages = byteBuf.toString(CharsetUtil.UTF_8); // 指定字符集解码 -// AssertLog.info("<<[up1]:IP:{},[up-content]==>{}", sessionManager.client(ctx),messages); + AssertLog.info("<<[up1]:IP:{},[up-content]==>{}", sessionManager.client(ctx),messages); String content = ""; boolean isClear = false; @@ -91,7 +91,7 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter { content = tempMsg + messages; isClear = true; } - AssertLog.info("<<[up]:IP:{},[up-content]==>{}", sessionManager.client(ctx),content); + AssertLog.info("<<[up2]:IP:{},[up-content]==>{}", sessionManager.client(ctx),content); endsWith = content.endsWith("@tong-ran"); //判断是否是整包 if(endsWith){ diff --git a/src/main/java/com/tongran/agenttcp/server/handler/AgentEncoderHandler.java b/src/main/java/com/tongran/agenttcp/server/handler/AgentEncoderHandler.java index 2aa13e8..5555cf4 100644 --- a/src/main/java/com/tongran/agenttcp/server/handler/AgentEncoderHandler.java +++ b/src/main/java/com/tongran/agenttcp/server/handler/AgentEncoderHandler.java @@ -37,7 +37,7 @@ public class AgentEncoderHandler extends ChannelOutboundHandlerAdapter { return; } AssertLog.info(">>[down]:IP:{},[content]==>{}", sessionManager.client(ctx), entity.getData()); - String json = "agent-server:"+JSON.toJSONString(entity)+"@tong-ran"; + String json = JSON.toJSONString(entity); byte[] bytes = json.getBytes(StandardCharsets.UTF_8); // 显式指定 UTF-8 // byte[] bytes = EscapeUtil.hexStringToByteArray(entity.getContent()); ByteBuf buf = Unpooled.wrappedBuffer(bytes);