From 2ad6ea2ad50a7af9357b2325e8985ca9d1969614 Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Fri, 26 Dec 2025 18:32:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=B3=A8=E5=86=8C=E9=87=8D?= =?UTF-8?q?=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tongran/agent/client/netty/handler/AgentDecoderHandler.java | 2 +- .../tongran/agent/client/scheduler/service/BusinessTasks.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/tongran/agent/client/netty/handler/AgentDecoderHandler.java b/src/main/java/com/tongran/agent/client/netty/handler/AgentDecoderHandler.java index a12ba6c..5bb34a3 100644 --- a/src/main/java/com/tongran/agent/client/netty/handler/AgentDecoderHandler.java +++ b/src/main/java/com/tongran/agent/client/netty/handler/AgentDecoderHandler.java @@ -143,7 +143,7 @@ public class AgentDecoderHandler extends ChannelInboundHandlerAdapter { } byteBuf.release(); // 释放 ByteBuf 资源（重要！） } else { - System.out.println("Unexpected message type: " + msg.getClass()); + AssertLog.error("Unexpected message type: " + msg.getClass()); } } diff --git a/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java b/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java index 86421a7..528e6a7 100644 --- a/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java +++ b/src/main/java/com/tongran/agent/client/scheduler/service/BusinessTasks.java @@ -781,7 +781,7 @@ public class BusinessTasks { boolean success = true; int activeConnect = client.getActiveConnections(); AssertLog.info("注册重试定时任务执行 - 时间: {}，activeConnect={}", LocalDateTime.now(), activeConnect); - if(activeConnect == 0){ + if(activeConnect == 0 || count > 1){ success = agentService.connection(); } if(success){