Java父子进程场景下Micrometer与Prometheus无HTTP监控方案咨询

问题1：如何配置Prometheus采集无HTTP服务的Worker子进程指标？ #

直接配置Prometheus无法实现。Prometheus的核心工作模式是拉取式（Pull-Based），必须依赖目标服务暴露HTTP/HTTPS端点提供指标数据。你的Worker子进程既没有HTTP服务，又排除了Push Gateway方案，所以没有直接的Prometheus配置方式能完成对Worker的指标采集。

问题2：将Worker指标发送至父进程统一导出的可行性与实现方案 #

这个方案完全可行，是这类场景下的标准解决方案之一，以下是具体实现细节：

1. 核心思路 #

Worker子进程通过已有的TCP连接将自身的Micrometer指标数据发送给父进程，父进程接收后将Worker指标与自身指标合并，最后通过父进程已有的HTTP端点统一暴露给Prometheus拉取。

2. Micrometer相关实现支持 #

Micrometer本身没有直接提供TCP传输完整指标注册表的现成工具，但可以基于Micrometer的API自定义实现：

• Worker端：利用Micrometer的MeterRegistry接口，定期（或按需）将注册表中的指标序列化为可传输的格式（比如Prometheus的文本格式、JSON），通过已有的TCP连接发送给父进程。可以用PrometheusMeterRegistry的scrape()方法直接获取标准的Prometheus文本格式指标，这种格式无需额外解析，父进程可以直接复用。
• 父进程端：维护一个自定义的MeterRegistry，或者扩展现有的PrometheusMeterRegistry，接收Worker发送的指标数据后，将其注入到自身的注册表中。

3. 指标合并的具体实现 #

• 标识Worker实例：为了区分不同Worker的指标，Worker在发送指标时需要给每个指标添加唯一的标签（比如worker_id、instance_id），避免指标冲突。
• 父进程接收与合并：
  • 简单实现：父进程接收到Worker发送的Prometheus文本格式指标后，直接将这些内容追加到自身暴露的指标端点响应中；
  • 规范实现：父进程维护一个CompositeMeterRegistry，将自身的PrometheusMeterRegistry和一个用于接收Worker指标的自定义注册表组合起来。Worker发送的指标可以被解析为Meter对象后，注册到自定义注册表中，由CompositeMeterRegistry统一对外暴露。
• 生命周期同步：父进程需要和Worker的生命周期绑定，当Worker退出时，及时清理对应的指标，避免无效指标堆积。

4. 代码示例片段 #

Worker端发送指标

// 假设已有TCP连接对象tcpSocket
PrometheusMeterRegistry workerRegistry = new PrometheusMeterRegistry(PrometheusConfig.DEFAULT);
// 定期发送指标
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
scheduler.scheduleAtFixedRate(() -> {
    String metrics = workerRegistry.scrape();
    // 通过TCP连接发送metrics文本
    OutputStream out = tcpSocket.getOutputStream();
    out.write(metrics.getBytes(StandardCharsets.UTF_8));
    out.flush();
}, 0, 15, TimeUnit.SECONDS);

父进程合并指标

// 父进程自身的Prometheus注册表
PrometheusMeterRegistry parentRegistry = new PrometheusMeterRegistry(PrometheusConfig.DEFAULT);
// 暴露HTTP端点，这里用Spring Boot为例，其他框架类似
@GetMapping("/actuator/prometheus")
public String prometheus() {
    StringBuilder sb = new StringBuilder(parentRegistry.scrape());
    // 遍历所有活跃Worker的指标，追加到响应中
    for (Worker worker : activeWorkers) {
        sb.append(worker.getLatestMetrics());
    }
    return sb.toString();
}

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