SpringBoot集成Prometheus

// 也可以不带配置文件，默认是这个，除非你的名字变了prometheus.exe --config.file=prometheus.yml

scrape_configs:  # The job name is added as a label `job=<job_name>` to any timeseries scraped from this config.  - job_name: "prometheus"    #metrics_path: 'actuator/prometheus'
    # metrics_path defaults to '/metrics'    # scheme defaults to 'http'.
    static_configs:      - targets: ["localhost:9090"]  // 以下是我增加的 2个服务  - job_name: "your_server_name_one"    metrics_path: 'actuator/prometheus'    static_configs:      - targets: ["localhost:8083"]
  - job_name: "your_server_name_two"    metrics_path: 'actuator/prometheus'    static_configs:      - targets: ["localhost:8198"]

// 如果其中某个指标不想受监控 可以通过以下配置关闭 ，// ${jar}文件中meat_info下的文件的spring-configuration-metadata.json 查看management.health.mail.enabled=falsemanagement.health.diskspace.enabled=false

<!-- spring-boot-actuator依赖 --><dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-actuator</artifactId></dependency><!-- prometheus依赖 --><dependency>    <groupId>io.micrometer</groupId>    <artifactId>micrometer-registry-prometheus</artifactId></dependency><!-- 上面2个就够了，加下面这个是为了把nacos注册也加到监控中，否则不行 --><dependency>    <groupId>com.alibaba.cloud</groupId>    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>    <version>2.2.2.RELEASE</version></dependency>

spring.application.name = ${application_name}
server.servlet.context-path = ${app_context_path}// 指定promethues采集数据的接口spring.cloud.nacos.discovery.metadata.metricpath=${server.servlet.context-path}/actuator/prometheus
spring.cloud.nacos.discovery.metadata.management.context-path=${server.servlet.context-path}/actuator
management.metrics.export.prometheus.enabled=truemanagement.metrics.export.jmx.enabled=truemanagement.metrics.tags.application=${spring.application.name}

@Configuration@Datapublic class MicroMeterConfig {
    @Value("${spring.application.name}")    private String springApplicationName;
    @Bean    MeterRegistryCustomizer<MeterRegistry> meterRegistryCustomizer(MeterRegistry meterRegistry) {        //全局标明所有指标归属        return registry -> meterRegistry.config().commonTags("application", springApplicationName);    }}

@Slf4j@Componentpublic class MicroMeterTool {    @Autowired    private MeterRegistry meterRegistry;
    //存储某个URI对应的耗时    private final ConcurrentHashMap<String, AtomicLong> appAccessTimeGaugeMap = new ConcurrentHashMap<>();
    /**     * 统计某个URI的业务耗时     * @param uri 做一个AOP拦截请求 获取 URI     * @param time output:System.currentTimeMillis()-input:System.currentTimeMillis()     */    public void appAccessTimeGauge(String uri,Long time) {        log.debug("appAccessTimeGauge uri:{} time:{}",uri,time);
        //自定义指标名称        String uk ="http_req_cost_time";        AtomicLong val = appAccessTimeGaugeMap.get(uri);        if (null != val) {            val.set(time);            return;        }        try {            val = new AtomicLong(time);            meterRegistry.gauge(uk, Arrays.asList(Tag.of("uri",uri)),val,AtomicLong::get);            appAccessTimeGaugeMap.put(uri, val);        } catch (Exception e) {            log.error("metrics appAccessTimeGauge error,key:{},method:{},time:{}", uk, val, e);        }    }}

 private final ConcurrentHashMap<String, AtomicLong> jvmByteGaugeMap = new ConcurrentHashMap<>();    public void jvmUsageByteGauge(String key,Long bytes) {        log.debug("jvmUsageByteGauge key:{} bytes:{}",key,bytes);        String uk ="app_jvm_bytes";        AtomicLong val = jvmByteGaugeMap.get(key);        if (null != val) {            val.set(bytes);            return;        }      //以下代码每个类之跑一次，后续自动与Map关联        try {            val = new AtomicLong(bytes);            meterRegistry.gauge(uk, Arrays.asList(Tag.of("name", "jvm_usage"), Tag.of("type", "bytes"),Tag.of("class_name",key)),val,AtomicLong::get);            jvmByteGaugeMap.put(key, val);        } catch (Exception e) {            log.error("metrics jvmByteGaugeMap error,key:{},method:{},time:{}", uk, val, e);        }    }    private final ConcurrentHashMap<String, AtomicLong> jvmInstanceGaugeMap = new ConcurrentHashMap<>();    public void jvmUsageInstanceGauge(String key,Long instances) {        log.debug("jvmUsageInstanceGauge key:{} instances:{}",key,instances);
        String uk ="app_jvm_instances";        AtomicLong val = jvmInstanceGaugeMap.get(key);        if (null != val) {            val.set(instances);            return;        }        try {            val = new AtomicLong(instances);            meterRegistry.gauge(uk, Arrays.asList(Tag.of("name", "jvm_usage"), Tag.of("type", "instances"),Tag.of("class_name",key)),val,AtomicLong::get);            jvmInstanceGaugeMap.put(key, val);        } catch (Exception e) {            log.error("metrics jvmInstanceGaugeMap error,key:{},method:{},time:{}", uk, val, e);        }    }

public void clearHistoryKey(Collection<String> keys,String key){    Collection<Meter> meters = meterRegistry.get(key).meters();    for (Meter meter : meters) {        Meter.Id id = meter.getId();        String className = id.getTag("class_name");        if (!StringUtils.isBlank(className) &&  !keys.contains(className)){            meterRegistry.remove(meter);            jvmInstanceGaugeMap.remove(className);            jvmByteGaugeMap.remove(className);            log.debug("clearHistoryKey key：{} clzName:{}",key,className);        }    }}

step1.启动Prometheus的时候带上启动参数：--web.enable-lifecycleprometheus.exe --config.file=/xxx/prometheus.yml --web.enable-lifecyclestep2.更新Prometheus配置 step3.更新完配置后，通过Post请求的方式，动态更新配置：curl -v --request POST 'http://localhost:9090/-/reload'