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;