sprinngboot+micrometer+prometheus项目监控

1.pom需要添加的依赖

2.application.yml的配置内容

#监控配置

management:

security:

# 仅限于开发环境可对security进行关闭。

enabled: false

metrics:

export:

prometheus:

enabled: true

step: 1m

descriptions: true

web:

server:

auto-time-requests: true

endpoints:

prometheus:

id: springmetrics

web:

exposure:

include: health,info,env,prometheus,metrics,httptrace,threaddump,heapdump,springmetrics

3.代码

package com.sitech.vehicle.job;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.sitech.utils.http.HttpRequest;

import com.sitech.utils.http.HttpResponse;

import com.sitech.vehicle.config.Constant;

import com.sitech.vehicle.operator.dto.CommonRequestDTO;

import com.sitech.vehicle.operator.dto.OperatorCmdDTO;

import com.sitech.vehicle.tsp.dto.cmd.CmdDTO;

import com.sitech.vehicle.utils.AESUtils;

import com.sitech.vehicle.utils.SignatureUtils;

import io.micrometer.core.instrument.*;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.http.HttpHeaders;

import org.springframework.http.HttpStatus;

import org.springframework.http.MediaType;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

import java.util.*;

import java.util.concurrent.atomic.AtomicInteger;

@Component

public class ControlCmdJob {

private static Logger logger = LoggerFactory.getLogger(ControlCmdJob.class);

List<Tag> init(){

ArrayList<Tag> list = new ArrayList(){};

list.add(new ImmutableTag("service", "demo"));

return list;

}

AtomicInteger atomicInteger = new AtomicInteger(0);

AtomicInteger passCases = Metrics.gauge("vehicle.cmd.timeout", init(), atomicInteger);

private String CloudApiUrl = "https://v2n-sv.sitechdev.com";

private String CloudApiUrl2 = "https://cloud-api.sitechdev.com";

private String urlCaller4Get(String url) {

HttpResponse response = HttpRequest.get(url)

.execute();

return response.body();

}

private String getCmdParam(String vin) throws Exception {

Long operatorId = 200353L;

String sercret = "7b2566668cce3bffc794816548383d03";

CommonRequestDTO commonRequestDTO = new CommonRequestDTO();

commonRequestDTO.setOperatorID(operatorId);

commonRequestDTO.setTimestamp(new Date().getTime());

OperatorCmdDTO operatorCmdDTO = new OperatorCmdDTO();

operatorCmdDTO.setVin(vin);

CmdDTO cmdDTO = new CmdDTO();

cmdDTO.setCmdName("open_search_lighting");

operatorCmdDTO.setCmdDTO(cmdDTO);

String content = JSONObject.toJSONString(operatorCmdDTO);

String encontent = AESUtils.Encrypt(content, sercret);

commonRequestDTO.setData(encontent);

Map<String, String> map = new HashMap<String, String>();

map.put("operatorID", commonRequestDTO.getOperatorID() + "");

map.put("data", commonRequestDTO.getData());

map.put("timestamp", commonRequestDTO.getTimestamp() + "");

System.out.println("业务参数：" + content);

System.out.println("加密后： " + encontent);

try {

String signature = SignatureUtils.generate(map, sercret);

System.out.println("签名： " + signature);

commonRequestDTO.setSign(signature);

} catch (Exception e) {

e.printStackTrace();

}

System.out.println(JSONObject.toJSONString(commonRequestDTO));

return JSONObject.toJSONString(commonRequestDTO);

}

@Scheduled(cron = "0/40 * * * * ? ") // 间隔40秒执行,查询车控次数，入库

public void health() {

String url = CloudApiUrl + Constant.URL;

String vin = "XTEVE000000D01001";

//TODO 调用车控接口，监控车控服务是否异常

try {

String responseA=urlCaller4Get(CloudApiUrl2+"/sitechid/authcenter/v2/security/operator-token-build/200353?appKey=7b2566668cce3bffc794816548383d03");

String token= JSON.parseObject(responseA).getJSONObject("data").getString("operatorToken");

String operatorId="Operator"+" "+token;

HttpResponse response = null;

System.out.println("----"+getCmdParam(vin));

response = HttpRequest.post(url)

.header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)

.header(HttpHeaders.AUTHORIZATION,operatorId)

.body(getCmdParam(vin))

.execute();

logger.info("response: " + response.body());

if (response.getStatus() != HttpStatus.OK.value()){

passCases.addAndGet(1);

}

int cmdStatus=Integer.valueOf(JSONObject.parseObject(response.body()).getJSONObject("data").getString("cmdStatus")).intValue();

if (response.getStatus() == HttpStatus.OK.value() && cmdStatus==7){

passCases.addAndGet(1);

}else{

passCases.set(0);

}

} catch (Exception e) {

e.printStackTrace();

}

4.prometheus.yml配置

scrape_configs:

- job_name: 'prometheus'

metrics_path: /prometheus

static_configs:

- targets: ['localhost:9000']

5.运行

本地运行访问：http://localhost:9504/actuator/prometheus （说明：9504为项目端口号），访问成功如下图：

访问prometheus：http://localhost:9090 （说明需要本地先启动prometheus的客户端）