Java服务端服务监控:Prometheus与Spring Boot Actuator的集成方式

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>io.prometheus</groupId>
        <artifactId>prometheus-client-spring-boot</artifactId>
        <version>0.10.0</version>
    </dependency>
</dependencies>

import cn.juwatech.config.PrometheusConfig;
import org.springframework.context.annotation.Configuration;
import io.prometheus.client.exporter.common.TextFormat;
import io.prometheus.client.hotspot.DefaultExports;
import io.prometheus.client.spring.boot.PrometheusMetricsExportAutoConfiguration;

@Configuration
public class PrometheusConfiguration extends PrometheusMetricsExportAutoConfiguration.MetricsExportConfiguration {

    @Override
    public void configureMetricsExport(io.prometheus.client.exporter.MetricsServlet metricsServlet) {
        super.configureMetricsExport(metricsServlet);
        metricsServlet.setServletPath("/metrics");
    }

    @Override
    public void configureDefaultExports() {
        super.configureDefaultExports();
        DefaultExports.initialize();
    }
}

import org.springframework.boot.actuate.autoconfigure.metrics.export.prometheus.PrometheusMetricsExportAutoConfiguration;
import org.springframework.context.annotation.Configuration;
import org.springframework.boot.actuate.autoconfigure.web.server.WebManagementContextResolver;
import org.springframework.boot.actuate.endpoint.web.WebEndpointFilter;

@Configuration
@WebManagementContextResolver
public class ActuatorConfiguration extends PrometheusMetricsExportAutoConfiguration {

    @Override
    public void configureWebEndpointFilters(WebEndpointFilter[] filters) {
        super.configureWebEndpointFilters(filters);
    }
}

import io.prometheus.client.Counter;
import io.prometheus.client.Gauge;
import org.springframework.stereotype.Component;

@Component
public class CustomMetrics {

    private static final Counter requestsCounter = Counter.build()
            .name("my_requests_total")
            .help("Total requests.")
            .register();

    private static final Gauge responseSizeGauge = Gauge.build()
            .name("my_response_size_bytes")
            .help("Response size in bytes.")
            .register();

    public void recordRequest(int responseSize) {
        requestsCounter.inc();
        responseSizeGauge.set(responseSize);
    }
}

import cn.juwatech.service.MyService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    private final CustomMetrics customMetrics;
    private final MyService myService;

    public MyController(CustomMetrics customMetrics, MyService myService) {
        this.customMetrics = customMetrics;
        this.myService = myService;
    }

    @GetMapping("/my-service")
    public String myServiceEndpoint() {
        String response = myService.performAction();
        int responseSize = response.getBytes().length;
        customMetrics.recordRequest(responseSize);
        return response;
    }
}

global:
  scrape_interval: 15s

scrape_configs:
  - job_name: 'spring-boot-application'
    scrape_interval: 5s
    static_configs:
      - targets: ['localhost:8080']

import cn.juwatech.monitor.PrometheusAlertManager;

public class MonitoringAndAlerting {
    public static void main(String[] args) {
        PrometheusAlertManager alertManager = new PrometheusAlertManager();
        alertManager.setAlertRule("my_requests_total > 100");
        alertManager.startMonitoring();
    }
}