From 144b914106a3732684c4ce178367711e79c85446 Mon Sep 17 00:00:00 2001 From: qiminbao Date: Tue, 23 Sep 2025 11:31:10 +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 --- .../netty/handler/AgentDecoderHandler.java | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 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 c2fdc94..d85b19e 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 @@ -71,14 +71,14 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter { if(endsWith){ lruCache.remove(sessionManager.client(ctx)); tmpMsgSize = 0; - sb.append(arr_msg[0]+"@tong-ran"); -// content = arr_msg[0]+"@tong-ran"; +// sb.append(arr_msg[0]+"@tong-ran"); + content = arr_msg[0]+"@tong-ran"; }else{ lruCache.remove(sessionManager.client(ctx)); tmpMsgSize = 0; - sb.append(arr_msg[0]); -// content = arr_msg[0]; - lruCache.put(sessionManager.client(ctx), sb.toString(), DateUnit.SECOND.getMillis() * 5000); +// sb.append(arr_msg[0]); + content = arr_msg[0]; + lruCache.put(sessionManager.client(ctx), content, DateUnit.SECOND.getMillis() * 5000); } } //判定是否粘包 @@ -90,17 +90,19 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter { 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"); + content += arr_msg[i].replaceAll("agent-client:","")+"@tong-ran"; +// sb.append(arr_msg[i].replaceAll("agent-client:","")+"@tong-ran"); } } }else{ lruCache.remove(sessionManager.client(ctx)); tmpMsgSize = 0; - sb.append(String.join("@tong-ran", arr_msg)); +// sb.append(String.join("@tong-ran", arr_msg)); + content = String.join("@tong-ran", arr_msg); } } } - content = sb.toString(); +// content = sb.toString(); if (tmpMsgSize > 0) { content = tempMsg + messages; endsWith = content.endsWith("@tong-ran");