SpringBoot指标监控的实现

<!--指示监控-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

management:
  endpoints:
    jmx:
      exposure:
        include: "health,info"

management:
  endpoints:
    web:
      exposure:
        include: "*"
        exclude: "env,beans"

management:
  endpoints:
    web:
      exposure:
        include: '*'

management:
  endpoint:
    health:
      show-details: always

management:
  endpoints:
    enabled-by-default: false

management:
  endpoint:
    health:
      show-details: always
      enabled: true
    info:
      enabled: true

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//

package org.springframework.boot.actuate.system;

import java.io.File;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.boot.actuate.health.AbstractHealthIndicator;
import org.springframework.boot.actuate.health.Health.Builder;
import org.springframework.core.log.LogMessage;
import org.springframework.util.unit.DataSize;

public class DiskSpaceHealthIndicator extends AbstractHealthIndicator {
    private static final Log logger = LogFactory.getLog(DiskSpaceHealthIndicator.class);
    private final File path;
    private final DataSize threshold;

    public DiskSpaceHealthIndicator(File path, DataSize threshold) {
        super("DiskSpace health check failed");
        this.path = path;
        this.threshold = threshold;
    }

    protected void doHealthCheck(Builder builder) throws Exception {
        long diskFreeInBytes = this.path.getUsableSpace();
        if (diskFreeInBytes >= this.threshold.toBytes()) {
            builder.up();
        } else {
            logger.warn(LogMessage.format("Free disk space below threshold. Available: %d bytes (threshold: %s)", diskFreeInBytes, this.threshold));
            builder.down();
        }

        builder.withDetail("total", this.path.getTotalSpace()).withDetail("free", diskFreeInBytes).withDetail("threshold", this.threshold.toBytes()).withDetail("exists", this.path.exists());
    }
}

package com.example.boot.health;

import org.springframework.boot.actuate.health.AbstractHealthIndicator;
import org.springframework.boot.actuate.health.Health;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@Component
public class MyIndicator extends AbstractHealthIndicator {

    @Override
    protected void doHealthCheck(Health.Builder builder) throws Exception {
        //判断的变量
        boolean flag = true;
        //存储详细信息
        Map<String, Object> msg = new HashMap<>();
        //判断是否健康
        if(flag){
            //健康
            builder.up();
            msg.put("code",200);
            msg.put("detail","我各个地方都没有问题");
        }else {
            //不健康
            builder.down();
            msg.put("code",500);
            msg.put("detail","服务器好像出了什么毛病");
        }
        //将数据写入检查器
        builder.withDetail("codes",100)
                .withDetails(msg);
    }
}

info:
  word: hello,world
  appName: 我是Info的appName

info:
  word: hello,world
  appName: 我是Info的appName
  mavenProjectName: @project.name@
  mavenAGV: [@project.artifactId@, @project.groupId@, @project.version@]

package com.example.boot.info;

import org.springframework.boot.actuate.info.Info;
import org.springframework.boot.actuate.info.InfoContributor;
import org.springframework.stereotype.Component;

@Component
public class MyInfo implements InfoContributor {
    @Override
    public void contribute(Info.Builder builder) {
        builder.withDetail("AppName","Hello,World")
                .withDetail("msg","我是实现了InfoContributor的类的消息");
    }
}

management:
  endpoint:
    health:
      show-details: always
      enabled: true
    info:
      enabled: true
    metrics:
      enabled: true

package com.example.boot.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.boot.bean.User;
import com.example.boot.mapper.UserMapper;
import com.example.boot.service.UserService;
import io.micrometer.core.instrument.Counter;
import io.micrometer.core.instrument.MeterRegistry;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {

    Counter counter;

    //在构造器传入参数MeterRegistry registry
    UserServiceImpl(MeterRegistry registry){
        //设置在metrics端点下的名称
        counter = registry.counter("userServiceImpl.list.count");
    }

    @Override
    public List<User> list() {
        //次数加1
        counter.increment();
        return super.list();
    }
}

package com.example.boot.endpoint;

import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
import org.springframework.boot.actuate.endpoint.annotation.WriteOperation;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

/**
 * 使用@Endpoint标注我们的端点类，并使用id赋值取名
 */
@Endpoint(id = "myEndPoint")
@Component
public class MyEndPoint {

    /**
     * 端点的读操作
     * 返回值无所谓，这里以Map为例返回，比较好看
     */
    @ReadOperation
    public Map<String,Object> getDockerInfo(){
        Map<String, Object> map = new HashMap<>();
        map.put("dockerInfo","docker started......");
        return map;
    }

    /**
     * 端点的写操作
     */
    @WriteOperation
    public void stopDocker(){
        System.out.println("docker stopped.......");
    }
}