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

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

本文主要介绍了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，引入如下依赖

de.codecentric

spring-boot-admin-starter-server

2.2.1

de.codecentric

spring-boot-admin-server-ui

2.2.1

1.2 启动类

@SpringBootApplication

@EnableAdminServer

public 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 config

alibaba.cloud.access-key=****

alibaba.cloud.secret-key=****

1.4 启动项目

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

二、配置邮件通知

2.1 pom

org.springframework.boot

spring-boot-starter-mail

2.2 邮件配置

spring.mail.host=smtp.qq.com

spring.mail.username=单纯QQ号

spring.mail.password=授权码

spring.mail.properties.mail.smpt.auth=true

spring.mail.properties.mail.smpt.starttls.enable=true

spring.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

@EnableAdminServer

public 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 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);YAvLZ

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;

}

}

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

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

YAvLZ

四 总结

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。