From 630558f4d69c704024f08b029dba2009911ad5e0 Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Sat, 28 Feb 2026 18:00:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=86=E5=8F=B2=E6=B5=81=E9=87=8F=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF=E6=9C=80=E5=90=8E=E4=B8=80=E4=B8=AA=E6=96=87=E4=BB=B6?=
 =?UTF-8?q?=E5=BB=B6=E8=BF=9F1=E5=88=86=E9=92=9F=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../agent/client/service/impl/AgentServiceImpl.java       | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java b/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java
index fe2e4d5..f4b2fda 100644
--- a/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java
+++ b/src/main/java/com/tongran/agent/client/service/impl/AgentServiceImpl.java
@@ -2414,7 +2414,13 @@ public class AgentServiceImpl implements AgentService {
 
                     // 获取当前文件的时间戳用于日志
                     String currentTimestamp = file.getName().replace(".conf", "");
-
+                    // 特殊处理：如果是最后一个文件，等待1分钟再发送
+                    if (isLastTraffic) {
+                        long lastMessageDelay = 60000; // 1分钟
+                        AssertLog.info("最后一个文件 {} 已发送，等待 {}ms 确保前面消息都被消费",
+                                currentTimestamp, lastMessageDelay);
+                        Thread.sleep(lastMessageDelay);
+                    }
                     processSingleFile(file, isLastTraffic);
                     batchProcessed++;
                     totalProcessed++;