Spring Boot集成Micrometer Gauge指标值不更新问题求助

你当前的代码存在两个核心问题导致指标无法更新：

1. 重复注册被忽略：Micrometer的MeterRegistry会自动去重，同名同标签的Meter仅能注册一次，后续的register()调用会被直接忽略，因此初始注册的Gauge值永远不会被替换。
2. 数据源固定化：你使用entry::getValue作为Gauge的数据源，这个Supplier只会返回注册时的固定数值，不会随着后续定时任务的统计结果动态更新。

我们可以通过维护全局映射来复用Gauge实例，每次定时任务统计完成后直接更新数值，同时处理失败任务数归零的租户（可选）。

方案一：直接维护Gauge实例映射 #

@Component
@RequiredArgsConstructor
public class FailedJobsGaugeReporter {
    private final ManagementService managementService;
    private final PrometheusMeterRegistry meterRegistry;
    // 线程安全的映射，保存租户ID到对应Gauge的引用
    private final Map<String, Gauge> tenantGauges = new ConcurrentHashMap<>();
    private static final String GAUGE_NAME = "rc_job_failed_gauge";

    @Scheduled(fixedDelayString = "3000", initialDelayString = "1000")
    public void reportFailedJobGauge() {
        // 统计各租户失败任务数
        List<Job> failedJobs = managementService.createFailedJobQuery().listPage(0, 999);
        Map<String, Long> countByTenantId = failedJobs.stream()
                .collect(Collectors.groupingBy(Job::getTenantId, Collectors.counting()));

        // 更新已有Gauge或创建新Gauge
        countByTenantId.forEach((tenantId, count) -> {
            tenantGauges.computeIfAbsent(tenantId, id -> 
                Gauge.builder(GAUGE_NAME, () -> 0)
                    .tags(Tag.of("tenant", id))
                    .strongReference(true)
                    .register(meterRegistry)
            ).set(count);
        });

        // 可选：移除无失败任务的租户对应的Gauge（若需保留0值可跳过此步骤）
        Set<String> currentTenants = countByTenantId.keySet();
        tenantGauges.keySet().removeIf(tenantId -> !currentTenants.contains(tenantId));
    }
}

方案二：使用AtomicLong作为中间数据源 #

借助AtomicLong的可变性，让Gauge动态获取最新数值：

@Component
@RequiredArgsConstructor
public class FailedJobsGaugeReporter {
    private final ManagementService managementService;
    private final PrometheusMeterRegistry meterRegistry;
    private static final String GAUGE_NAME = "rc_job_failed_gauge";
    // 保存租户ID到计数的映射，供Gauge动态取值
    private final Map<String, AtomicLong> tenantCounts = new ConcurrentHashMap<>();

    @Scheduled(fixedDelayString = "3000", initialDelayString = "1000")
    public void reportFailedJobGauge() {
        List<Job> failedJobs = managementService.createFailedJobQuery().listPage(0, 999);
        Map<String, Long> countByTenantId = failedJobs.stream()
                .collect(Collectors.groupingBy(Job::getTenantId, Collectors.counting()));

        // 更新计数并自动维护Gauge
        countByTenantId.forEach((tenantId, count) -> {
            AtomicLong atomicCount = tenantCounts.computeIfAbsent(tenantId, k -> new AtomicLong(0));
            atomicCount.set(count);
            // 自动复用已存在的Gauge，无需手动判断
            Gauge.gauge(GAUGE_NAME, Tags.of("tenant", tenantId), atomicCount, AtomicLong::get);
        });

        // 可选：清理无失败任务的租户计数
        tenantCounts.keySet().removeIf(tenantId -> !countByTenantId.containsKey(tenantId));
    }
}

关键改动说明 #

• 复用实例：通过ConcurrentHashMap确保每个租户仅创建一次Gauge，避免重复注册被忽略。
• 动态更新：通过gauge.set(count)或AtomicLong.set(count)直接修改Gauge的数据源数值，确保每次定时任务都能同步最新统计结果。
• 清理无效指标：可选步骤，避免指标列表中保留无意义的0值租户（根据业务需求选择是否保留）。

内容的提问来源于stack exchange，提问作者Sagar Kalburgi