From 8658a7bef87c6a4b047689ebf5c7b4de179a0be3 Mon Sep 17 00:00:00 2001 From: qiminbao Date: Tue, 23 Sep 2025 09:32:29 +0800 Subject: [PATCH] =?UTF-8?q?tcp=E6=95=B0=E6=8D=AE=E7=B2=98=E5=8C=85?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../agent/server/netty/handler/AgentDecoderHandler.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/tongran/agent/server/netty/handler/AgentDecoderHandler.java b/src/main/java/com/tongran/agent/server/netty/handler/AgentDecoderHandler.java index 7c6b547..79df7d7 100644 --- a/src/main/java/com/tongran/agent/server/netty/handler/AgentDecoderHandler.java +++ b/src/main/java/com/tongran/agent/server/netty/handler/AgentDecoderHandler.java @@ -86,8 +86,13 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter { if(!endsWith){ lruCache.remove(sessionManager.client(ctx)); tmpMsgSize = 0; - sb.append(arr_msg[0]+"@tong-ran"); - lruCache.put(sessionManager.client(ctx), arr_msg[1], DateUnit.SECOND.getMillis() * 5000); + for (int i = 0; i < arr_msg.length; i++) { + if(i == arr_msg.length -1){ + lruCache.put(sessionManager.client(ctx), arr_msg[i], DateUnit.SECOND.getMillis() * 5000); + }else{ + sb.append(arr_msg[i].replaceAll("agent-client:","")+"@tong-ran"); + } + } }else{ lruCache.remove(sessionManager.client(ctx)); tmpMsgSize = 0;