如何将Prometheus指标重定向到默认的Spring Boot服务器

Question

我正在尝试从我的Spring Boot应用程序中揭示自定义量规指标。我正在将千分尺与Prometheus注册表一起使用。我已经设置了PrometheusRegistry并按照 - 千分尺样本 - github ，但它创建了另一台HTTP服务器，用于公开Prometheus指标。我需要将所有指标重定向或将所有指标置于Spring Boot的默认上下文路径 - /coletuator/Prometheus，而不是新端口上的新上下文路径。到目前为止，我已经实施了以下代码 -

PrometheusRegistry.java-

package com.xyz.abc.prometheus;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.time.Duration;

import com.sun.net.httpserver.HttpServer;

import io.micrometer.core.lang.Nullable;
import io.micrometer.prometheus.PrometheusConfig;
import io.micrometer.prometheus.PrometheusMeterRegistry;

public class PrometheusRegistry {

    public static PrometheusMeterRegistry prometheus() {
        PrometheusMeterRegistry prometheusRegistry = new PrometheusMeterRegistry(new PrometheusConfig() {
            @Override
            public Duration step() {
                return Duration.ofSeconds(10);
            }

            @Override
            @Nullable
            public String get(String k) {
                return null;
            }
        });

        try {
            HttpServer server = HttpServer.create(new InetSocketAddress(8081), 0);
            server.createContext("/sample-data/prometheus", httpExchange -> {
                String response = prometheusRegistry.scrape();
                httpExchange.sendResponseHeaders(200, response.length());
                OutputStream os = httpExchange.getResponseBody();
                os.write(response.getBytes());
                os.close();
            });

            new Thread(server::start).run();
        } catch (IOException e) {
            throw new RuntimeException(e);
        }

        return prometheusRegistry;
    }
    
}

micrometerConfig.java-

package com.xyz.abc.prometheus;

import io.micrometer.core.instrument.MeterRegistry;


public class MicrometerConfig {

    public static MeterRegistry carMonitoringSystem() {
        // Pick a monitoring system here to use in your samples.
        return PrometheusRegistry.prometheus();
    }
}

代码片段，我正在创建自定义规程。截至目前，这是一个简单的REST API，可以测试 - （请阅读两者之间的注释）

@SuppressWarnings({ "unchecked", "rawtypes" })
@RequestMapping(value = "/sampleApi", method= RequestMethod.GET)
@ResponseBody
//This Timed annotation is working fine and this metrics comes in /actuator/prometheus by default
@Timed(value = "car.healthcheck", description = "Time taken to return healthcheck")
public ResponseEntity healthCheck(){
    MeterRegistry registry = MicrometerConfig.carMonitoringSystem();
    AtomicLong n = new AtomicLong();
    //Starting from here none of the Gauge metrics shows up in /actuator/prometheus path instead it goes to /sample-data/prometheus on port 8081 as configured.
    registry.gauge("car.gauge.one", Tags.of("k", "v"), n);
    registry.gauge("car.gauge.two", Tags.of("k", "v1"), n, n2 -> n2.get() - 1);
    registry.gauge("car.help.gauge", 89);
    
    //This thing never works! This gauge metrics never shows up in any URI configured
    Gauge.builder("car.gauge.test", cpu)
         .description("car.device.cpu")
         .tags("customer", "demo")
         .register(registry);
    return new ResponseEntity("Car is working fine.", HttpStatus.OK);
}

我需要所有的指标才能在内部显示 - /cartuator/cartuator/prometheus而不是创建新的HTTP服务器。我知道我正在明确创建一个新的HTTP服务器，以便在那里弹出指标。请让我知道如何避免创建新的HTTP服务器，并将所有Prometheus指标重定向到默认路径 - /coartuator/Prometheus。另外，如果我使用gauge.builder来定义自定义量规指标，则永远无法使用。请解释一下我如何也可以使这项工作。让我知道我在哪里做错了。 谢谢。

Answer 1

每当您调用MicrometerConfig.carmonitoringsystem（）;都在创建new Prometheus注册表（并尝试启动新服务器），

您都需要注入meterregistry meterregistry < /代码>在创建量规的类中，并使用注射MeterRegistry这样。