安装SkyWalking作为监控工具

<dependency <groupId>org.apache.skywalking</groupId>
<artifactId>server-core</artifactId>
<version>8.2.0</version>
</dependency>

 package com.wt.monitor.skywalking.alarm.domain; import lombok.Data; import java.io.Serializable; /** * @author ChengJianSheng
* @date 2020/12/1 */ @Data public class AlarmMessageDTO implements Serializable { private int scopeId; private String scope; /** * Target scope entity name */
private String name; private String id0; private String id1; private String ruleName; /** * Alarm text message */
private String alarmMessage; /** * Alarm time measured in milliseconds */
private long startTime;

} 

package com.wt.monitor.skywalking.alarm.service; import com.dingtalk.api.DefaultDingTalkClient; import com.dingtalk.api.DingTalkClient; import com.dingtalk.api.request.OapiRobotSendRequest; import com.taobao.api.ApiException; import lombok.extern.slf4j.Slf4j; import org.apache.commons.codec.binary.Base64; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.crypto.Mac; import javax.crypto.spec.SecretKeySpec; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.security.InvalidKeyException; import java.security.NoSuchAlgorithmException; /** * https://ding-doc.dingtalk.com/doc#/serverapi2/qf2nxq
* @author ChengJianSheng
* @data 2020/12/1 */ @Slf4j
  @Service public class DingTalkAlarmService {

  @Value("${dingtalk.webhook}") private String webhook;
  @Value("${dingtalk.secret}") private String secret; public void sendMessage(String content) { try {
  Long timestamp = System.currentTimeMillis();
  String stringToSign = timestamp + "\n" + secret;
  Mac mac = Mac.getInstance("HmacSHA256");
  mac.init(new SecretKeySpec(secret.getBytes("UTF-8"), "HmacSHA256")); byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8"));
  String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)),"UTF-8");

           String serverUrl = webhook + "&timestamp=" + timestamp + "&sign=" + sign;
           DingTalkClient client = new DefaultDingTalkClient(serverUrl);
           OapiRobotSendRequest request = new OapiRobotSendRequest();
           request.setMsgtype("text");
           OapiRobotSendRequest.Text text = new OapiRobotSendRequest.Text();
           text.setContent(content);
           request.setText(text);

           client.execute(request);
       } catch (ApiException e) {
           e.printStackTrace();
           log.error(e.getMessage(), e);
       } catch (NoSuchAlgorithmException e) {
           e.printStackTrace();
           log.error(e.getMessage(), e);
       } catch (UnsupportedEncodingException e) {
           e.printStackTrace();
           log.error(e.getMessage(), e);
       } catch (InvalidKeyException e) {
           e.printStackTrace();
           log.error(e.getMessage(), e);
       }
  }
  }

package com.wt.monitor.skywalking.alarm.controller; import com.alibaba.fastjson.JSON; import com.wt.monitor.skywalking.alarm.domain.AlarmMessageDTO; import com.wt.monitor.skywalking.alarm.service.DingTalkAlarmService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.text.MessageFormat; import java.util.List; /** * @author ChengJianSheng
* @date 2020/12/1 */ @Slf4j
  @RestController
  @RequestMapping("/skywalking") public class AlarmController {

  @Autowired private DingTalkAlarmService dingTalkAlarmService;

  @PostMapping("/alarm") public void alarm(@RequestBody List<AlarmMessageDTO> alarmMessageDTOList) {
  log.info("收到告警信息: {}", JSON.toJSONString(alarmMessageDTOList)); if (null != alarmMessageDTOList) {
  alarmMessageDTOList.forEach(e->dingTalkAlarmService.sendMessage(MessageFormat.format("-----来自SkyWalking的告警-----\n【名称】: {0}\n【消息】: {1}\n", e.getName(), e.getAlarmMessage())));
  }
  }
  }