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

 更新时间:2020年08月27日 08:27:38   作者:牧小农的夏天  
这篇文章主要介绍了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,引入如下依赖

<!-- Admin 服务 -->
 <dependency>
   <groupId>de.codecentric</groupId>
   <artifactId>spring-boot-admin-starter-server</artifactId>
   <version>2.2.1</version>
 </dependency>
 <!-- Admin 界面 -->
 <dependency>
   <groupId>de.codecentric</groupId>
   <artifactId>spring-boot-admin-server-ui</artifactId>
   <version>2.2.1</version>
 </dependency>

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

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-mail</artifactId>
</dependency>

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<Void> 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 健康检查的实际应用,在企业中一般会有短信通知+钉钉群通知和邮件,感兴趣的小伙伴可以去试试看,还是挺好玩的,还有一个就是微信通知,在服务号 模板消息感兴趣的小伙伴可以自行去研究看看,大家加油~

到此这篇关于Spring Cloud Admin健康检查 邮件、钉钉群通知的实现的文章就介绍到这了,更多相关Spring Cloud Admin 通知内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • springboot实现执行sql语句打印到控制台

    springboot实现执行sql语句打印到控制台

    这篇文章主要介绍了springboot实现执行sql语句打印到控制台的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • Seata AT获取数据表元数据源码详解

    Seata AT获取数据表元数据源码详解

    这篇文章主要为大家介绍了Seata AT获取数据表元数据源码详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11
  • java 数组越界判断和获取数组长度的实现方式

    java 数组越界判断和获取数组长度的实现方式

    这篇文章主要介绍了java 数组越界判断和获取数组长度的实现方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • 基于线程池的工作原理与源码解读

    基于线程池的工作原理与源码解读

    下面小编就为大家分享一篇基于线程池的工作原理与源码解读,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2017-12-12
  • SpringBoot学习之全局异常处理设置(返回JSON)

    SpringBoot学习之全局异常处理设置(返回JSON)

    本篇文章主要介绍了SpringBoot学习之全局异常处理设置(返回JSON),小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-02-02
  • Java中关于char类型变量能够输出中文的问题

    Java中关于char类型变量能够输出中文的问题

    这篇文章主要介绍了Java中关于char类型变量能够输出中文的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-12-12
  • SpringBoot从2.7.x 升级到3.3注意事项

    SpringBoot从2.7.x 升级到3.3注意事项

    从SpringBoot 2.7.x升级到3.3涉及多个重要变更,特别是因为 Spring Boot 3.x 系列基于 Jakarta EE 9,而不再使用 Java EE,本文就来详细的介绍一下,感兴趣的可以了解一下
    2024-09-09
  • SpringSecurity添加图形验证码认证实现

    SpringSecurity添加图形验证码认证实现

    本文主要介绍了SpringSecurity添加图形验证码认证实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • Java Map集合使用方法全面梳理

    Java Map集合使用方法全面梳理

    Map是一种依照键(key)存储元素的容器,键(key)很像下标,在List中下标是整数。在Map中键(key)可以使任意类型的对象。Map中不能有重复的键(Key),每个键(key)都有一个对应的值(value)。一个键(key)和它对应的值构成map集合中的一个元素
    2022-04-04
  • AsyncHttpClient exception异常源码流程解析

    AsyncHttpClient exception异常源码流程解析

    这篇文章主要为大家介绍了AsyncHttpClient的exception源码流程解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12

最新评论