Spring Cloud Admin健康检查 邮件、钉钉群通知的实现
本文主要介绍了SpringCloudAdmin的使用，分享给大家，具体如下：
源码地址：https://github.com/muxiaonong/Spring-Cloud/tree/master/cloudadmin
Admin简介
官方文档：WhatisSpringBootAdmin?
SpringBootAdmin是一个用于管理和监控SpringBoot微服务的社区项目，可以使用客户端注册或者Eureka服务发现向服务端提供监控信息。
注意，服务端相当于提供UI界面，实际的监控信息由客户端Actuator提供
通过SpringBootAdmin，你可以通过华丽大气的界面访问到整个微服务需要的监控信息，例如服务健康检查信息、CPU、内存、操作系统信息等等
本篇文章使用SpringBoot2.3.3.RELEASE、SpringCloudHoxton.SR6、SpringBootAdmin2.2.3版本，此外，服务注册中心采用eureka
一、SpringCloud使用SpringBootAdmin
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
publicclassAdminTestApplication{
publicstaticvoidmain(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 #springcloudaccess&secretconfig alibaba.cloud.access-key=**** alibaba.cloud.secret-key=****
1.4启动项目
输入项目地址：http://localhost:8080/applications
二、配置邮件通知
2.1pom
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.3QQ邮箱设置
找到自己的QQ邮箱
QQ邮箱》设置》账户》红框处获取授权码
接着我们就收到了邮件通知，告诉我们服务关闭了
三、发送钉钉群通知
找到群里面的群设置》智能群助手》添加机器人
注意：这里的自定义关键词一定要和项目的关键字匹配
获取Webhook到项目中，这个是后面要使用到的
importorg.springframework.boot.SpringApplication;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.context.annotation.Bean;
importde.codecentric.boot.admin.server.config.EnableAdminServer;
importde.codecentric.boot.admin.server.domain.entities.InstanceRepository;
@SpringBootApplication
@EnableAdminServer
publicclassAdminApplication{
publicstaticvoidmain(String[]args){
SpringApplication.run(AdminApplication.class,args);
}
@Bean
publicDingDingNotifierdingDingNotifier(InstanceRepositoryrepository){
returnnewDingDingNotifier(repository);
}
}
通知类：
importjava.util.Map;
importcom.alibaba.fastjson.JSONObject;
importde.codecentric.boot.admin.server.domain.entities.Instance;
importde.codecentric.boot.admin.server.domain.entities.InstanceRepository;
importde.codecentric.boot.admin.server.domain.events.InstanceEvent;
importde.codecentric.boot.admin.server.notify.AbstractStatusChangeNotifier;
importreactor.core.publisher.Mono;
publicclassDingDingNotifierextendsAbstractStatusChangeNotifier{
publicDingDingNotifier(InstanceRepositoryrepository){
super(repository);
}
@Override
protectedMonodoNotify(InstanceEventevent,Instanceinstance){
StringserviceName=instance.getRegistration().getName();
StringserviceUrl=instance.getRegistration().getServiceUrl();
Stringstatus=instance.getStatusInfo().getStatus();
Mapdetails=instance.getStatusInfo().getDetails();
StringBuilderstr=newStringBuilder();
str.append("服务预警:【"+serviceName+"】");
str.append("【服务地址】"+serviceUrl);
str.append("【状态】"+status);
str.append("【详情】"+JSONObject.toJSONString(details));
returnMono.fromRunnable(()->{
DingDingMessageUtil.sendTextMessage(str.toString());
});
}
}
发送工具类
importjava.io.InputStream;
importjava.io.OutputStream;
importjava.net.HttpURLConnection;
importjava.net.URL;
importcom.alibaba.fastjson.JSONObject;
publicclassDingDingMessageUtil{
publicstaticStringaccess_token="Token";
publicstaticvoidsendTextMessage(Stringmsg){
try{
Messagemessage=newMessage();
message.setMsgtype("text");
message.setText(newMessageInfo(msg));
URLurl=newURL("https://oapi.dingtalk.com/robot/send?access_token="+access_token);
//建立http连接
HttpURLConnectionconn=(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();
OutputStreamout=conn.getOutputStream();
StringtextMessage=JSONObject.toJSONString(message);
byte[]data=textMessage.getBytes();
out.write(data);
out.flush();
out.close();
InputStreamin=conn.getInputStream();
byte[]data1=newbyte[in.available()];
in.read(data1);
System.out.println(newString(data1));
}catch(Exceptione){
e.printStackTrace();
}
}
}
消息类：
publicclassMessage{
privateStringmsgtype;
privateMessageInfotext;
publicStringgetMsgtype(){
returnmsgtype;
}
publicvoidsetMsgtype(Stringmsgtype){
this.msgtype=msgtype;
}
publicMessageInfogetText(){
returntext;
}
publicvoidsetText(MessageInfotext){
this.text=text;
}
}
publicclassMessageInfo{
privateStringcontent;
publicMessageInfo(Stringcontent){
this.content=content;
}
publicStringgetContent(){
returncontent;
}
publicvoidsetContent(Stringcontent){
this.content=content;
}
}
我们下线一个服务后，就可以看到钉钉群就发了消息的通知
同时，当我们启动服务的时候，也会有消息通知我们服务启动了
四总结
上面就是我们对admin健康检查的实际应用，在企业中一般会有短信通知+钉钉群通知和邮件，感兴趣的小伙伴可以去试试看，还是挺好玩的，还有一个就是微信通知，在服务号模板消息感兴趣的小伙伴可以自行去研究看看，大家加油~
到此这篇关于SpringCloudAdmin健康检查邮件、钉钉群通知的实现的文章就介绍到这了,更多相关SpringCloudAdmin通知内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。