【SpringBoot】SpringBoot-Admin 服务监控 + 告警通知

news2024/12/26 23:56:07

简单介绍

Spring Boot Actuator 是 Spring Boot 自带的一个功能模块，
提供了一组已经开箱即用的生产环境下常用的特性和服务，比如应用程序的健康检查、信息暴露、度量收集、日志记录等。
在实际项目中，Actuator 可以帮助我们快速了解应用程序的运行状态和性能瓶颈。

整合SpringBoot-Admin监控，Spring Boot Admin 就是将 Spring Boot Actuator中提供的endpoint信息可视化展示。

环境

Springboot: 2.1.1.RELEASE

注意：不同的SpringBoot版本，所用到的依赖会不一致。本版本亲测可用哦。

服务端简单搭建

核心依赖


<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-starter-server</artifactId>
    <version>2.1.6</version>
</dependency>

<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-server-ui-login</artifactId>
    <version>1.5.7</version>
</dependency>

启动类


@EnableAdminServer //开启admin服务端
@SpringBootApplication
public class BootAdminServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(BootAdminServerApplication.class, args);
    }

}

配置文件

server:
  port: 8001
  servlet:
    context-path: /admin-server
spring:
  application:
    name: admin-server

启动服务后，访问：http://localhost:8001/admin-server

在这里插入图片描述

安全认证

核心依赖


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

SecuritySecureConfig 拦截器Code


@EnableWebSecurity
@Configuration
public class SecuritySecureConfig extends WebSecurityConfigurerAdapter {

    private final String adminContextPath;

    public SecuritySecureConfig(AdminServerProperties adminServer) {
        this.adminContextPath = adminServer.getContextPath();
    }

    @Override
    protected void configure(HttpSecurity http) throws Exception {
        SavedRequestAwareAuthenticationSuccessHandler successHandler = new SavedRequestAwareAuthenticationSuccessHandler();
        successHandler.setTargetUrlParameter("redirectTo");
        successHandler.setDefaultTargetUrl(adminContextPath + "/");

        http.authorizeRequests()
                .antMatchers(adminContextPath + "/login",
                        adminContextPath + "/assets/**",
                        adminContextPath + "/manage/**",
                        adminContextPath + "/actuator/**",
                        adminContextPath + "/login.html"
                ).permitAll()
                .anyRequest().authenticated()
                .and()
                .formLogin().loginPage(adminContextPath + "/login").successHandler(successHandler)
                .and()
                .logout().logoutUrl(adminContextPath + "/logout")
                .and()
                .httpBasic()
                .and()
                .csrf().disable();
    }

}

修改配置

新增以下配置

spring:
  security:
    user:
      name: admin
      password: admin

启动服务后，访问：http://localhost:8001/admin-server

在这里插入图片描述

输入用户名，密码即可。

客户端

核心依赖

  <!--加入spring-boot-admin连接端-->
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-starter-client</artifactId>
    <version>2.1.6</version>
</dependency>

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

配置文件

如果你不想开启安全认证请参考以下的配置。

admin-server 未开启安全认证


server:
  port: 7001

spring:
  application:
    name: admin-client
  # 配置spring-boot-admin服务端的地址
  boot:
    admin:
      client:
        url: 'http://localhost:8001/admin-server'

#展示全部细节信息
management:
  endpoints:
    web:
      exposure:
        include: '*'
  #允许admin工程远程停止本应用
  endpoint:
    health:
      enabled: true
      show-details: always
    shutdown:
      enabled: true

admin-server 开启安全认证

server:
  port: 7001

spring:
  application:
    name: admin-client
  # 配置spring-boot-admin服务端的地址
  boot:
    admin:
      client:
        url: 'http://localhost:8001/admin-server'
        username: admin
        password: admin

#展示全部细节信息
management:
  endpoints:
    web:
      exposure:
        include: '*'
  #允许admin工程远程停止本应用
  endpoint:
    health:
      enabled: true
      show-details: always
    shutdown:
      enabled: true

查看Admin-Server端页面
在这里插入图片描述

在这里插入图片描述

如何实现服务 告警通知

当我们的服务发生异常时， 可以通过邮件、微信、钉钉等发送告警信息。

Server 端新增以下配置类。

@Component
public class AdminNotifier extends AbstractStatusChangeNotifier {

    private static final Logger log = LoggerFactory.getLogger(AdminNotifier.class);

    /**
     * 消息模板
     */
    private static final String template = "<<<%s>>> \n 【服务名】: %s(%s) \n 【状态】: %s(%s) \n 【服务ip】: %s \n 【详情】: %s";

    private String titleAlarm = "系统告警";

    private String titleNotice = "系统通知";

    private String[] ignoreChanges = new String[]{"UNKNOWN:UP", "DOWN:UP", "OFFLINE:UP"};

    public AdminNotifier(InstanceRepository repository) {
        super(repository);
    }

    @Override
    protected boolean shouldNotify(InstanceEvent event, Instance instance) {
        if (!(event instanceof InstanceStatusChangedEvent)) {
            return false;
        } else {
            InstanceStatusChangedEvent statusChange = (InstanceStatusChangedEvent) event;
            String from = this.getLastStatus(event.getInstance());
            String to = statusChange.getStatusInfo().getStatus();
            return Arrays.binarySearch(this.ignoreChanges, from + ":" + to) < 0 && Arrays.binarySearch(this.ignoreChanges, "*:" + to) < 0 && Arrays.binarySearch(this.ignoreChanges, from + ":*") < 0;
        }
    }

    @Override
    protected Mono<Void> doNotify(InstanceEvent event, Instance instance) {

        return Mono.fromRunnable(() -> {

            if (event instanceof InstanceStatusChangedEvent) {
                log.info("Instance {} ({}) is {}", instance.getRegistration().getName(),
                        event.getInstance(),
                        ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus());
                String status = ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus();
                String messageText = null;
                switch (status) {
                    // 健康检查没通过
                    case "DOWN":
                        log.info("发送 健康检查没通过 的通知！");
                        messageText = String
                                .format(template, titleAlarm, instance.getRegistration().getName(), event.getInstance(),
                                        ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus(), "健康检查没通过通知",
                                        instance.getRegistration().getServiceUrl(), JSONObject.toJSONString(instance.getStatusInfo().getDetails()));
                        log.info(messageText);
                        break;
                    // 服务离线
                    case "OFFLINE":
                        log.info("发送 服务离线 的通知！");
                        messageText = String
                                .format(template, titleAlarm, instance.getRegistration().getName(), event.getInstance(),
                                        ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus(), "服务离线通知",
                                        instance.getRegistration().getServiceUrl(), JSONObject.toJSONString(instance.getStatusInfo().getDetails()));
                        log.info(messageText);
                        break;
                    //服务上线
                    case "UP":
                        log.info("发送 服务上线 的通知！");
                        messageText = String
                                .format(template, titleNotice, instance.getRegistration().getName(), event.getInstance(),
                                        ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus(), "服务上线通知",
                                        instance.getRegistration().getServiceUrl(), JSONObject.toJSONString(instance.getStatusInfo().getDetails()));
                        log.info(messageText);
                        break;
                    // 服务未知异常
                    case "UNKNOWN":
                        log.info("发送 服务未知异常 的通知！");
                        messageText = String
                                .format(template, titleAlarm, instance.getRegistration().getName(), event.getInstance(),
                                        ((InstanceStatusChangedEvent) event).getStatusInfo().getStatus(), "服务未知异常通知",
                                        instance.getRegistration().getServiceUrl(), JSONObject.toJSONString(instance.getStatusInfo().getDetails()));
                        log.info(messageText);
                        break;
                    default:
                        break;
                }
            } else {
                log.info("Instance {} ({}) {}", instance.getRegistration().getName(), event.getInstance(),
                        event.getType());
            }
        });
    }
}

如下图所示：

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/745124.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

三维重建以及神经渲染中的学习（一）

三维重建以及神经渲染中的学习（一）

三维重建以及神经渲染中的学习 公众号AI知识物语 本文内容为参加过去一次暑期课程学习时的笔记&#xff0c;浅浅记录下。 显示表征&#xff1a; 点云points&#xff1a;由一组离散三维点表征物体表面 推理速度快&#xff0c;容易获取 -离散表征&#xff0c;无拓扑关系 [Fa…
阅读更多...
mysql的聚簇索引和非聚簇索引的区别

mysql的聚簇索引和非聚簇索引的区别

MySQL InnoDB存储引擎时&#xff0c;索引类型可分为聚簇索引和非聚簇索引&#xff0c;有时候也通俗的称为主键索引和普通索引。MyISAM的引擎只有非聚簇索引&#xff0c;所以MYSIAM的引擎在查询的时候非主键索引的时候特别快 接下来讨论一下几个问题&#xff1a; 什么是聚簇索…
阅读更多...
linux搭建vsftpd服务使用filezilla连接服务

linux搭建vsftpd服务使用filezilla连接服务

背景&#xff1a;支持使用filezilla上传文件到公司的服务机器上&#xff0c;所以搭建vsftpd支持filezilla进行上传 一、linux机器搭建vsftpd服务 1、先看看自己的机器属于什么发行版&#xff0c;不同的发行版命令不一样 我的是centos&#xff0c;其他发行版命令不一样&#xf…
阅读更多...
架构训练营笔记：高可用设计

架构训练营笔记：高可用设计

2-3高可用设计 高可用复杂度模型 分为计算高可用&#xff0c;存储高可用&#xff0c;高可用本质上需要冗余&#xff0c;这里是集群&#xff0c;没有单机。 计算高可用&#xff1a;分为任务分配与任务分解。 计算高可用对比之前的高性能&#xff0c;就是多了状态检测。 任务…
阅读更多...
请求响应-实体参数的接受

请求响应-实体参数的接受

实体参数的接受 简单实体对象&#xff1a;请求参数名与形参属性对象名相同&#xff0c;定义pojo接受即可&#xff0c;将数据封装到实体类中实体类代码如下&#xff1a; package com.example.POJO;public class User {private String name;private Integer age;public String g…
阅读更多...
系统测试——postman的400错误

系统测试——postman的400错误

如果Headers中不勾选Host&#xff0c;调用接口就会报400 Bad Request错误。
阅读更多...
Hystrix 断路器

Hystrix 断路器

文章目录 1 问题&#xff1a;服务雪崩2 概念3 服务降级3.1 概念&#xff1a;3.2 触发服务降级的情况&#xff1a;3.3 应用3.3.1 依赖3.3.2 解决的问题3.3.3 生产者&#xff1a;3.3.4 消费者&#xff1a;3.3.5 配置全局fallback方法3.3.6 解耦合 4 服务熔断4.1 概念&#xff1a;…
阅读更多...
Shell的条件运算语句

Shell的条件运算语句

目录 IF语句 单分支语句语法语法 多分支结构语法 CASE语句 语法 IF语句 单分支语句语法语法 #写法1 if 条件语句 then内容 fi#写法2 if 条件语句 ;then内容 fi编写一个内容警报器的例子 #!/bin/bash free_mem$(free -m | grep "Mem:" | tr -s " "…
阅读更多...
kubernetes源码学习之kube-scheduler

kubernetes源码学习之kube-scheduler

kube-scheduler是kubernetes中的调度程序&#xff0c;负责从api server中获得待分发的pod列表&#xff0c;并为他们找到最合适运行的Node。 基于kubernetes 1.27 基本框架 下面是kubernetes官发给出的框架图&#xff0c;先对kubernetes pod调度的大致流程有一个认识 看一下有…
阅读更多...
眼睛：来一场视觉盛宴《手拿把掐》css特效 —— 之听说过CSS【笑】

眼睛：来一场视觉盛宴《手拿把掐》css特效 —— 之听说过CSS【笑】

&#x1f637;&#x1f60a;&#x1f93a;&#x1f93a;&#x1f93a;前期回顾 打造极简风格动效 —— 5 分钟轻松实现惊艳、震撼人心的视觉效果_彩色之外的博客-CSDN博客 &#x1f601; css动画 —— 把你喜欢css动画嵌入到浏览器中_css做的动画效果怎么嵌入网页_彩色之外的…
阅读更多...
window电脑修复网络不能正常

window电脑修复网络不能正常

问题描述 问题的起点是我打开了OpenAPI公司的GPT&#xff0c;在回答的过程中响应很慢&#xff0c;然后自己开始尝试切换连接的服务器&#xff08;这里使用到了网络代理&#xff09;&#xff0c;最后自己做了一个操作是 代理软件的这个菜单里面的增强模式选项&#xff0c;结果…
阅读更多...
Android爬坑指南————工信部又出新规！

Android爬坑指南————工信部又出新规！

工信部又出新规了&#xff01; 一、背景二、整改2.1 个人信息保护2.1.1 基本模式&#xff08;无权限、无个人信息获取模式&#xff09;腾讯视频网易云音乐 2.1.2 隐私政策内容 2.2 app权限调用2.2.1 应用内权限调用2.2.1.1 获取定位信息和生物特征识别信息2.2.1.2 其他权限 2.3…
阅读更多...
渲染流程（上）：HTML、CSS和JavaScript，是如何变成页面的？

渲染流程（上）：HTML、CSS和JavaScript，是如何变成页面的？

在上一篇文章中我们介绍了导航相关的流程&#xff0c;那导航被提交后又会怎么样呢&#xff1f; 就进入了渲染阶段。这个阶段很重要&#xff0c;了解其相关流程能让你“看透”页面是如何工作的&#xff0c;有了这些知识&#xff0c;你可以解决一系列相关的问题&#xff0c;比如…
阅读更多...
SVR算法简介及与其它回归算法的关系

SVR算法简介及与其它回归算法的关系

目录 参考链接 有人可以帮助我理解支持向量回归技术和其他简单回归模型之间的主要区别是什么 支持向量回归找到一个线性函数&#xff0c;表示误差范围 (epsilon) 内的数据。也就是说&#xff0c;大多数点都可以在该边距内找到&#xff0c;如下图所示 这意味着 SVR 比大多数其…
阅读更多...
TypeScript 学习笔记(一)：基本类型、交叉类型、联合类型、类型断言

TypeScript 学习笔记(一)：基本类型、交叉类型、联合类型、类型断言

文章目录 一、常见类型1. 数组2. 布尔3. 数值4. 字符串5. object6. null 和 undefined7. symbol7.1 作为属性名7.2 属性名遍历7.3 静态方法&#xff1a;Symbol.for()和 Symbol.keyFor()7.4 内置 symbol 值7.4.1 Symbol.hasInstance7.4.2 Symbol.isConcatSpreadable7.4.3 Symbol…
阅读更多...
Android 报错，闪退（错误）日志保存到手机内存中，以文本文件的形式保存

Android 报错，闪退（错误）日志保存到手机内存中，以文本文件的形式保存

1.直接贴代码 import android.app.AlarmManager; import android.app.PendingIntent; import android.content.Context; import android.content.Intent; import android.os.Environment; import android.util.Log;import com.nuotu.atmBookClient.App;import java.io.File; i…
阅读更多...
python接口自动化（三十二）--Python发送邮件（常见四种邮件内容）番外篇——上（详解）

python接口自动化（三十二）--Python发送邮件（常见四种邮件内容）番外篇——上（详解）

简介 本篇文章与前边没有多大关联&#xff0c;就是对前边有关发邮件的总结和梳理。在写脚本时&#xff0c;放到后台运行&#xff0c;想知道执行情况&#xff0c;会通过邮件、SMS&#xff08;短信&#xff09;、飞信、微信等方式通知管理员&#xff0c;用的最多的是邮件。在linu…
阅读更多...
这份4577页的Java面试PDF，让我成功斩获阿里、字节等大厂offer

这份4577页的Java面试PDF，让我成功斩获阿里、字节等大厂offer

我为大家准备了一份超级全面的Java 学习面试笔记&#xff0c;这份电子版笔记涵盖了诸多后端技术栈的面试题和答案&#xff0c;相信可以帮助大家在最短的时间内复习Java后端的大多数技术点和面试题&#xff0c;从而拿到自己心仪的offer。共4577页。整体还是比较清爽的&#xff0…
阅读更多...
Postman的细节回顾

Postman的细节回顾

之前在学校摸索着玩过postman&#xff0c;工作后要使用postman&#xff0c;发现对于很多细节&#xff0c;这里补充说明一下&#xff0c;当作使用手册。 之所以使用postman&#xff0c;是因为更便捷的查看接口情况&#xff0c;不需要每次在浏览器f12查看。 目录 1 创建请求2 测…
阅读更多...
产品经理怎么管理项目进度？

产品经理怎么管理项目进度？

作为在职七年的项目管理人员&#xff0c;在项目进度管理上确实有一点发言权。产品经理作为企业的核心骨干岗位之一&#xff0c;在进行项目进度管理时也会有很多问题出现&#xff0c;那么应该怎样去管理项目进度呢&#xff1f;以下是答主的一些拙见&#xff0c;有需要的朋友们就…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023