Prometheus监控报警自定义指标

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-registry-prometheus</artifactId>
</dependency>

#监控的端点
management.endpoints.web.exposure.include=*
#应用程序名称，在prometheus 上会显示
management.metrics.tags.application=${spring.application.name}
#tomcat 指标需要开启
server.tomcat.mbeanregistry.enabled=true

package com.adx.service;

import java.math.BigDecimal;

/**
 * @author gao_liang
 * @date 2024-05-31 上午9:16
 */
public interface IAccountService {
    void withdrawOrder(BigDecimal amount);
    void depositOrder(BigDecimal amount);
}

package com.adx.service.impl;

import com.adx.service.IAccountService;
import io.micrometer.core.instrument.Counter;
import io.micrometer.core.instrument.DistributionSummary;
import io.micrometer.core.instrument.Gauge;
import io.micrometer.core.instrument.MeterRegistry;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.math.BigDecimal;

/**
 * @author gao_liang
 * @date 2024-05-31 上午9:18
 */
@Service
@Slf4j
public class IAccountServiceImpl implements IAccountService {
    @Autowired
    private MeterRegistry registry;
    //入金笔数
    private Counter depositCounter;
    // 出金笔数
    private Counter withdrawCounter;
    //入金金额
    private DistributionSummary depositAmountSummary;
    // 出金金额
    private DistributionSummary withdrawAmountSummary;
    //余额
    private BigDecimal balance = new BigDecimal(1000);

    /**
     * 初始化函数，用于在对象构造完成后执行一次性的配置或资源获取。
     * 该方法没有参数，也没有返回值。
     * 主要完成以下功能：
     * 1. 初始化存款计数器；
     * 2. 初始化取款计数器；
     * 3. 初始化存款金额统计；
     * 4. 初始化取款金额统计；
     * 5. 注册余额的实时 gauge 仪表盘。
     */
    @PostConstruct
    private void init() {
        depositCounter = (Counter) registry.counter("deposit_counter", "currency", "btc");
        withdrawCounter = (Counter) registry.counter("withdraw_counter", "currency", "btc");
        depositAmountSummary = registry.summary("deposit_amount", "currency", "btc");
        withdrawAmountSummary = registry.summary("withdraw_amount", "currency", "btc");
        Gauge.builder("balanceGauge", () -> balance)
                .tags("currency", "btc")
                .description("余额")
                .register(registry);
    }

    /**
     * 充值操作
     * 为账户增加指定金额，同时更新相关统计信息。
     *
     * @param amount 充值金额，使用BigDecimal类型以确保精确计算。
     */
    @Override
    // 充值操作
    public void depositOrder(BigDecimal amount) {
        log.info("depositOrder amount:{}", amount);
        try {
            //余额增加
            balance = balance.add(amount);
            //充值笔数埋点
            depositCounter.increment();
            //充值金额埋点
            depositAmountSummary.record(amount.doubleValue());

        } catch (Exception e) {
            log.info("depositOrder error", e);
        } finally {
            log.info("depositOrder result:{}", amount);
        }
    }

    /**
     * 提现操作
     *
     * @param amount 提现金额
     *               该方法实现用户提现功能，会检查余额是否充足，若充足则进行余额扣减，并记录提现相关数据。
     */
    @Override
    //提现操作
    public void withdrawOrder(BigDecimal amount) {
        log.info(" withdrawOrder amount:{}", amount);
        try {
            if (balance.subtract(amount).compareTo(BigDecimal.ZERO) < 0) {
                throw new Exception("提现金额不足，提现失败");
            }
            //余额减少
            balance = balance.subtract(amount);
            // 提现笔数埋点数据
            withdrawCounter.increment();
            // 提现金额埋点
            withdrawAmountSummary.record(amount.doubleValue());
        } catch (Exception e) {
            log.info("withdrawOrder error", e);
        } finally {
            log.info("withdrawOrder result:{}", amount);
        }
    }
}

package com.adx.controller;

import com.adx.constants.ControllerConstants;
import com.adx.service.IAccountService;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.math.BigDecimal;

@RestController
@RequestMapping(ControllerConstants.PATH_PREFIX + "/account")
@AllArgsConstructor
public class AccountController {

    private final IAccountService accountService;

    /**
     * 充值
     */
    @RequestMapping(value = "/deposit", method = RequestMethod.GET)
    public void deposit(@RequestParam("amount") BigDecimal amount) {
        accountService.depositOrder(amount);
    }

    /**
     * 提现
     */
    @RequestMapping(value = "/withdraw", method = RequestMethod.GET)
    public void withdraw(@RequestParam("amount") BigDecimal amount) {
        accountService.withdrawOrder(amount);
    }

}

docker restart prometheus

http://ip:8081/api/account/withdraw?amount=800

sum(balanceGauge{application="backend"})

withdraw_amount_sum{application="backend"}
deposit_amount_sum{application="backend"}

increase(deposit_counter_total{application="backend"}[5m])
increase(withdraw_counter_total{application="backend"}[5m])