Spring Cloud Admin健康检查邮件、钉钉群通知-技术圈

源码地址：https://github.com/muxiaonong/Spring-Cloud/tree/master/cloudadmin

Admin 简介

官方文档：What is Spring Boot Admin?

SpringBootAdmin是一个用于管理和监控SpringBoot微服务的社区项目，可以使用客户端注册或者Eureka服务发现向服务端提供监控信息。注意，服务端相当于提供UI界面，实际的监控信息由客户端Actuator提供通过SpringBootAdmin，你可以通过华丽大气的界面访问到整个微服务需要的监控信息，例如服务健康检查信息、CPU、内存、操作系统信息等等

本篇文章使用SpringBoot 2.3.3.RELEASE、SpringCloud Hoxton.SR6、SpringBoot Admin 2.2.3版本，此外，服务注册中心采用eureka

一、SpringCloud使用SpringBoot Admin

1.1 创建一个SpringBoot项目，命名为admin-test，引入如下依赖

   <dependency>      <groupId>de.codecentricgroupId>      <artifactId>spring-boot-admin-starter-serverartifactId>      <version>2.2.1version>  dependency>    <dependency>      <groupId>de.codecentricgroupId>      <artifactId>spring-boot-admin-server-uiartifactId>      <version>2.2.1version>  dependency>

1.2 启动类

@SpringBootApplication@EnableAdminServerpublic class AdminTestApplication {
    public static void main(String[] args) {        SpringApplication.run(AdminTestApplication.class, args);    }      }

1.3 配置文件

spring.application.name=admin-test
management.endpoints.jmx.exposure.include=*management.endpoints.web.exposure.include=*management.endpoint.health.show-details=always
# spring cloud access&secret configalibaba.cloud.access-key=****alibaba.cloud.secret-key=****

1.4 启动项目

输入项目地址：http://localhost:8080/applications

二、配置邮件通知

2.1 pom

<dependency>  <groupId>org.springframework.bootgroupId>  <artifactId>spring-boot-starter-mailartifactId>dependency>

2.2 邮件配置

spring.mail.host=smtp.qq.comspring.mail.username=单纯QQ号spring.mail.password=授权码spring.mail.properties.mail.smpt.auth=truespring.mail.properties.mail.smpt.starttls.enable=truespring.mail.properties.mail.smpt.starttls.required=true
#收件邮箱spring.boot.admin.notify.mail.to=xxxx@qq.com# 发件邮箱spring.boot.admin.notify.mail.from= xxxx@qq.com

2.3 QQ邮箱设置

找到自己的QQ邮箱

QQ邮箱》设置》账户》红框处获取授权码

我们将 consumer 服务下线后，

接着我们就收到了邮件通知，告诉我们服务关闭了

三、发送钉钉群通知

找到群里面的群设置》智能群助手》添加机器人 注意：这里的自定义关键词一定要和项目的关键字匹配

获取 Webhook 到项目中，这个是后面要使用到的

启动类：

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.annotation.Bean;
import de.codecentric.boot.admin.server.config.EnableAdminServer;import de.codecentric.boot.admin.server.domain.entities.InstanceRepository;
@SpringBootApplication@EnableAdminServerpublic class AdminApplication {
  public static void main(String[] args) {    SpringApplication.run(AdminApplication.class, args);  }     @Bean      public DingDingNotifier dingDingNotifier(InstanceRepository repository) {          return new DingDingNotifier(repository);      }}

通知类：

import java.util.Map;
import com.alibaba.fastjson.JSONObject;
import de.codecentric.boot.admin.server.domain.entities.Instance;import de.codecentric.boot.admin.server.domain.entities.InstanceRepository;import de.codecentric.boot.admin.server.domain.events.InstanceEvent;import de.codecentric.boot.admin.server.notify.AbstractStatusChangeNotifier;import reactor.core.publisher.Mono;
public class DingDingNotifier extends AbstractStatusChangeNotifier  {  public DingDingNotifier(InstanceRepository repository) {        super(repository);    }    @Override    protected Mono doNotify(InstanceEvent event, Instance instance) {        String serviceName = instance.getRegistration().getName();        String serviceUrl = instance.getRegistration().getServiceUrl();        String status = instance.getStatusInfo().getStatus();        Map<String, Object> details = instance.getStatusInfo().getDetails();        StringBuilder str = new StringBuilder();        str.append("服务预警 : 【" + serviceName + "】");        str.append("【服务地址】" + serviceUrl);        str.append("【状态】" + status);        str.append("【详情】" + JSONObject.toJSONString(details));        return Mono.fromRunnable(() -> {            DingDingMessageUtil.sendTextMessage(str.toString());        });    }}

发送工具类

import java.io.InputStream;import java.io.OutputStream;import java.net.HttpURLConnection;import java.net.URL;
import com.alibaba.fastjson.JSONObject;
public class DingDingMessageUtil {  public static String access_token = "Token";    public static void sendTextMessage(String msg) {        try {            Message message = new Message();            message.setMsgtype("text");            message.setText(new MessageInfo(msg));            URL url = new URL("https://oapi.dingtalk.com/robot/send?access_token=" + access_token);            // 建立 http 连接            HttpURLConnection conn = (HttpURLConnection) url.openConnection();            conn.setDoOutput(true);            conn.setDoInput(true);            conn.setUseCaches(false);            conn.setRequestMethod("POST");            conn.setRequestProperty("Charset", "UTF-8");            conn.setRequestProperty("Content-Type", "application/Json; charset=UTF-8");            conn.connect();            OutputStream out = conn.getOutputStream();            String textMessage = JSONObject.toJSONString(message);            byte[] data = textMessage.getBytes();            out.write(data);            out.flush();            out.close();            InputStream in = conn.getInputStream();            byte[] data1 = new byte[in.available()];            in.read(data1);            System.out.println(new String(data1));        } catch (Exception e) {            e.printStackTrace();        }    }}

消息类：

public class Message {  private String msgtype;    private MessageInfo text;    public String getMsgtype() {        return msgtype;    }    public void setMsgtype(String msgtype) {        this.msgtype = msgtype;    }    public MessageInfo getText() {        return text;    }    public void setText(MessageInfo text) {        this.text = text;    }}

public class MessageInfo {    private String content;    public MessageInfo(String content) {        this.content = content;    }    public String getContent() {        return content;    }    public void setContent(String content) {        this.content = content;    }}

我们下线一个服务后，就可以看到钉钉群就发了消息的通知

同时，当我们启动服务的时候，也会有消息通知我们服务启动了

四总结

上面就是我们对admin 健康检查的实际应用，在企业中一般会有短信通知+钉钉群通知和邮件，感兴趣的小伙伴可以去试试看，还是挺好玩的，还有一个就是微信通知，在服务号模板消息感兴趣的小伙伴可以自行去研究看看，大家加油~

-- End --

———————

1.原创不易，你的「在看」是我创作的动力。

2.欢迎关注公众号牧小农的夏天，「带你一起学Java」！

3.疫情期间，勤洗手，戴口罩，做好个人防护。

“在看转发”是最大的支持

Spring Cloud Admin健康检查 邮件、钉钉群通知