微服务监控之三：Prometheus + Grafana Spring Boot 应用可视化监控

在application.xml里设置属性：spring.metrics.servo.enabled=false，  
去掉重复的metrics，不然在prometheus的控制台的targets页签里，会一直显示此endpoint为down状态。  

#应用可视化监控  
management.security.enabled=false
spring.metrics.servo.enabled=false  

import java.lang.annotation.*;
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interfacePrometheusMetrics {
    /**
     * 默认为空,程序使用method signature作为Metric name 如果name有设置值,使用name作为Metric name
     * 
     * @return
     */
    String name() default "";
}

importio.prometheus.client.Counter;
importio.prometheus.client.Histogram;
importorg.apache.commons.lang3.StringUtils;
importorg.aspectj.lang.ProceedingJoinPoint;
importorg.aspectj.lang.annotation.Around;
importorg.aspectj.lang.annotation.Aspect;
importorg.aspectj.lang.annotation.Pointcut;
importorg.aspectj.lang.reflect.MethodSignature;
importorg.springframework.stereotype.Component;
importorg.springframework.web.context.request.RequestContextHolder;
importorg.springframework.web.context.request.ServletRequestAttributes;
importjavax.servlet.http.HttpServletRequest;
@Aspect
@Component
public classPrometheusMetricsAspect {
    private static final Counter requestTotal = Counter.build().name("couter_all").labelNames("api")
            .help("total request couter of api").register();
    private static final Counter requestError = Counter.build().name("couter_error").labelNames("api")
            .help("response Error couter of api").register();
    private static final Histogram histogram = Histogram.build().name("histogram_consuming").labelNames("api")
            .help("response consuming of api").register();
    //自定义Prometheus注解的全路径
    @Pointcut("@annotation(com....annotation.PrometheusMetrics)")
    public voidpcMethod() {
    }
    @Around(value = "pcMethod() && @annotation(annotation)")
    public Object MetricsCollector(ProceedingJoinPoint joinPoint, PrometheusMetrics annotation) throwsThrowable {
        MethodSignature methodSignature =(MethodSignature) joinPoint.getSignature();
        PrometheusMetrics prometheusMetrics = methodSignature.getMethod().getAnnotation(PrometheusMetrics.class);
        if (prometheusMetrics != null) {
            String name;
            if(StringUtils.isNotEmpty(prometheusMetrics.name())) {
                name =prometheusMetrics.name();
            } else{
                HttpServletRequest request =((ServletRequestAttributes) RequestContextHolder.getRequestAttributes())
                        .getRequest();
                name =request.getRequestURI();
            }
            requestTotal.labels(name).inc();
            Histogram.Timer requestTimer =histogram.labels(name).startTimer();
            Object object;
            try{
                object =joinPoint.proceed();
            } catch(Exception e) {
                requestError.labels(name).inc();
                throwe;
            } finally{
                requestTimer.observeDuration();
            }
            returnobject;
        } else{
            returnjoinPoint.proceed();
        }
    }
}

@PrometheusMetrics
    @PostMapping(value = "isBacklist")
    @ApiOperation(value = "黑名单判断", notes = "是否在黑名单中，如果存在并且记录状态为2，则为黑名单，返回true，否则返回：false")
    @Log
    public RespResult<Boolean> isBacklist(@RequestBody BacklistReqDTO reqDTO) {

./prometheus --config.file=prometheus2.yml

结果：

duanxz@ubuntu:~/Downloads/prometheus-2.0.0.linux-amd64$ ./prometheus --config.file=prometheus2.yml
level=info ts=2018-06-19T08:27:47.222527495Z caller=main.go:215 msg="Starting Prometheus" version="(version=2.0.0, branch=HEAD, revision=0a74f98628a0463dddc90528220c94de5032d1a0)"
level=info ts=2018-06-19T08:27:47.222895906Z caller=main.go:216 build_context="(go=go1.9.2, user=root@615b82cb36b6, date=20171108-07:11:59)"
level=info ts=2018-06-19T08:27:47.223110655Z caller=main.go:217 host_details="(Linux 4.4.0-128-generic #154~14.04.1-Ubuntu SMP Fri May 25 14:58:51 UTC 2018 x86_64 ubuntu (none))"
level=info ts=2018-06-19T08:27:47.227443134Z caller=web.go:380 component=web msg="Start listening for connections" address=0.0.0.0:9090
level=info ts=2018-06-19T08:27:47.234616341Z caller=main.go:314 msg="Starting TSDB"
level=info ts=2018-06-19T08:27:47.244932582Z caller=targetmanager.go:71 component="target manager" msg="Starting target manager..."
level=info ts=2018-06-19T08:27:47.24608357Z caller=main.go:326 msg="TSDB started"
level=info ts=2018-06-19T08:27:47.246514727Z caller=main.go:394 msg="Loading configuration file" filename=prometheus2.yml
level=info ts=2018-06-19T08:27:47.247799187Z caller=main.go:371 msg="Server is ready to receive requests."