From 63b01db83d9aad8a15276b4236a9a22e4aeef065 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 05 五月 2026 12:30:59 +0800
Subject: [PATCH] # Agent数据分析V3.0.1.7
---
src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java b/src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java
index c366e70..d56af70 100644
--- a/src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java
+++ b/src/main/java/com/zy/core/trace/StationTaskTraceRegistry.java
@@ -11,6 +11,7 @@
import com.zy.core.model.command.StationCommand;
import com.zy.core.enums.RedisKeyType;
import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -22,6 +23,7 @@
import java.util.Objects;
import java.util.concurrent.ConcurrentHashMap;
+@Slf4j
@Component
public class StationTaskTraceRegistry {
@@ -302,7 +304,13 @@
if (loadedFromRedis) {
return;
}
+ long redisStartNs = System.nanoTime();
Map<Object, Object> cacheMap = redisUtil == null ? null : redisUtil.hmget(TRACE_CACHE_KEY);
+ long redisCostMs = (System.nanoTime() - redisStartNs) / 1_000_000L;
+ if (redisCostMs > 100) {
+ log.info("StationTaskTraceRegistry Redis鍔犺浇鑰楁椂={}ms, entries={}", redisCostMs,
+ cacheMap == null ? 0 : cacheMap.size());
+ }
if (cacheMap != null && !cacheMap.isEmpty()) {
long now = System.currentTimeMillis();
for (Map.Entry<Object, Object> entry : cacheMap.entrySet()) {
--
Gitblit v1.9.1