From 006fa9a1726d3c3db52284584e769f4560d4f4be Mon Sep 17 00:00:00 2001 From: wood chen Date: Sun, 9 Mar 2025 12:16:44 +0800 Subject: [PATCH] =?UTF-8?q?refactor(metrics):=20=E7=A7=BB=E9=99=A4?= =?UTF-8?q?=E5=BB=B6=E8=BF=9F=E5=88=86=E5=B8=83=E7=BB=9F=E8=AE=A1=E7=9A=84?= =?UTF-8?q?=E5=86=97=E4=BD=99=E6=97=A5=E5=BF=97=E8=BE=93=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除 RecordRequest 和 GetStats 方法中的详细日志记录 - 保留核心的延迟分布统计逻辑，提高代码简洁性 - 减少不必要的日志输出，优化性能和可读性 --- internal/metrics/collector.go | 12 +----------- 1 file changed, 1 insertion(+), 11 deletions(-) diff --git a/internal/metrics/collector.go b/internal/metrics/collector.go index 31d772d..2a40e48 100644 --- a/internal/metrics/collector.go +++ b/internal/metrics/collector.go @@ -143,17 +143,12 @@ func (c *Collector) RecordRequest(path string, status int, latency time.Duration bucketKey = "gt1s" } - log.Printf("[Metrics] 更新延迟分布: 路径=%s, 延迟=%dms, 桶=%s", path, latencyMs, bucketKey) - if counter, ok := c.latencyBuckets.Load(bucketKey); ok { - oldValue := atomic.LoadInt64(counter.(*int64)) - newValue := atomic.AddInt64(counter.(*int64), 1) - log.Printf("[Metrics] 延迟分布桶 %s: %d -> %d", bucketKey, oldValue, newValue) + atomic.AddInt64(counter.(*int64), 1) } else { counter := new(int64) *counter = 1 c.latencyBuckets.Store(bucketKey, counter) - log.Printf("[Metrics] 新建延迟分布桶: %s = 1", bucketKey) } // 更新路径统计 @@ -359,19 +354,14 @@ func (c *Collector) GetStats() map[string]interface{} { if counter != nil { value := atomic.LoadInt64(counter.(*int64)) latencyDistribution[bucket] = value - log.Printf("[Metrics] 延迟分布桶 %s = %d", bucket, value) } else { latencyDistribution[bucket] = 0 - log.Printf("[Metrics] 延迟分布桶 %s = 0 (counter is nil)", bucket) } } else { latencyDistribution[bucket] = 0 - log.Printf("[Metrics] 延迟分布桶 %s = 0 (bucket not found)", bucket) } } - log.Printf("[Metrics] 延迟分布: %v", latencyDistribution) - // 获取最近请求记录（使用读锁） recentRequests := c.recentRequests.GetAll()