Micrometer搭配Prometheus Pushgateway无法发送最新指标问题

问题核心 #

PrometheusMeterRegistry与CloudWatchMeterRegistry的调度逻辑存在差异：CloudWatch会按配置的cloudwatch.step定期后台上报，而Prometheus Push Gateway的自动推送依赖预设的间隔周期。对于短生命周期的CommandLineRunner应用，若在推送间隔内就关闭，自动上报逻辑还未触发，导致最后一次指标丢失；仅调用meterRegistry.close()无法触发最终推送，因为该方法仅负责关闭注册表，不包含主动上报逻辑。

解决方案 #

1. 手动触发指标推送（最直接有效）

在计算逻辑完成后，显式调用PushGateway的推送方法，确保指标在应用关闭前被发送。Micrometer的PushGateway.push()是同步方法，调用后会等待请求完成，无需额外处理异步等待。

示例代码：

@Component
public class CalculationRunner implements CommandLineRunner {
    private final PrometheusMeterRegistry meterRegistry;
    private final PushGateway pushGateway;
    private static final String JOB_NAME = "calculation-task";

    public CalculationRunner(PrometheusMeterRegistry meterRegistry, PushGateway pushGateway) {
        this.meterRegistry = meterRegistry;
        this.pushGateway = pushGateway;
    }

    @Override
    public void run(String... args) throws Exception {
        // 执行计算逻辑
        Counter successCounter = meterRegistry.counter("calculation.executions", "status", "success");
        successCounter.increment();

        // 手动推送最新指标到Push Gateway
        pushGateway.push(meterRegistry, JOB_NAME);

        // 关闭注册表（可选，确保资源释放）
        meterRegistry.close();
    }
}

2. 注册ShutdownHook处理异常关闭场景

若应用可能因异常提前终止，可注册JVM关闭钩子，在进程退出前强制推送最后一次指标：

@Component
public class CalculationRunner implements CommandLineRunner {
    // 省略注入代码...

    @PostConstruct
    public void registerShutdownHook() {
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            try {
                pushGateway.push(meterRegistry, JOB_NAME);
                meterRegistry.close();
            } catch (IOException e) {
                // 按需处理推送失败异常，比如日志记录
                System.err.println("Failed to push final metrics: " + e.getMessage());
            }
        }));
    }

    // 省略run方法逻辑...
}

3. 验证推送逻辑

若仍存在丢失情况，可检查：

• PushGateway的地址、认证配置是否正确
• 指标是否已正确注册到PrometheusMeterRegistry
• 确保推送调用在所有计算逻辑之后执行

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