Micrometer自定义Gauge指标无法正常更新问题排查

首次尝试（直接传数值）不更新的原因 #

Metrics.gauge("e2e_latency", metricTags, e2eTimeTakenMillis)这个重载方法存在隐藏陷阱：它会将传入的数值包装成**弱引用（WeakReference）**绑定到Gauge上。当myFunction执行完毕，局部变量e2eTimeTakenMillis没有强引用支撑，会被GC回收。后续调用时，由于指标的唯一标识（名称+标签组合）已存在，Micrometer不会重新创建Gauge，导致指标值永远停留在第一次的数值。

第二次尝试（Builder+共享AtomicLong）标签覆盖的原因 #

你共用了同一个AtomicLong实例给所有标签组合的Gauge。Gauge本质是通过读取绑定对象的当前值来上报指标，所以不管哪个标签的Gauge，都会读取同一个AtomicLong的数值。当你调用latency.set()时，所有关联这个实例的Gauge都会返回新值，自然出现不同标签的指标被统一覆盖的问题。strongReference方法只是让Gauge强引用AtomicLong，但无法解决“多标签共享同一数据源”的核心问题。

正确解决方案：为每个标签组合维护独立数据源 #

需要为每个唯一的标签组合分配独立的AtomicLong实例，用线程安全的Map缓存这些实例，确保不同标签的Gauge绑定各自的数据源。

代码示例 #

// 用ConcurrentHashMap缓存标签组合与对应AtomicLong的映射，保证线程安全
private final Map<List<Tag>, AtomicLong> latencyGaugeMap = new ConcurrentHashMap<>();

public void myFunction() {
    long e2eStartTime = System.nanoTime();
    // 执行业务逻辑
    ....
    long e2eEndTime = System.nanoTime();
    long e2eTimeTakenMillis = TimeUnit.NANOSECONDS.toMillis(e2eEndTime - e2eStartTime);
    List<Tag> metricTags = getMetricTags();

    // 针对当前标签组合，获取或创建对应的AtomicLong并注册Gauge
    AtomicLong latencyValue = latencyGaugeMap.computeIfAbsent(metricTags, tags -> {
        AtomicLong newValue = new AtomicLong();
        Gauge.builder("e2e_latency", newValue, AtomicLong::get)
                .tags(tags)
                .register(Metrics.globalRegistry);
        return newValue;
    });

    // 更新当前标签组合对应的指标值
    latencyValue.set(e2eTimeTakenMillis);
}

原理说明 #

1. ConcurrentHashMap：保证多线程下创建和获取AtomicLong的线程安全，避免并发冲突。
2. computeIfAbsent：仅当标签组合不存在时，才创建新的AtomicLong并注册对应的Gauge，确保每个标签组合只绑定一个独立的数据源。
3. 独立数据源：不同标签组合的Gauge绑定不同的AtomicLong，更新值时互不干扰，完美解决标签覆盖问题。

内容的提问来源于stack exchange，提问作者Yash Mehta