历史流量信息最后一个文件延迟1分钟处理

2026-02-28 18:00:00 +08:00
parent f453f17903
commit 630558f4d6
1 changed files with 7 additions and 1 deletions
@@ -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++;