XXL-JOB学习笔记-新增企业微信告警通知

xxl-job默认的告警通知方式是发送邮件，工作中不易及时的收到通知并作出响应，所以想要调整下告警的通知方式，查阅文档资料，发现可以扩展xxl-job的源码实现支持。
主要思路就是根据xxl-job现有的告警机制，扩展实现企业微信机器人的告警功能，接下来就记录下xxl-job新增企业微信告警通知功能。
  • 从官方网站上下载xxl-job源码，导入IDEA。
    官方地址：https://github.com/xuxueli/xxl-job 或 https://gitee.com/xuxueli0323/xxl-job。
  • xxl-job现有的告警功能。可以发现只要实现JobAlarm这个接口就可以了。
@Component
public class JobAlarmer implements ApplicationContextAware, InitializingBean {private static Logger logger = LoggerFactory.getLogger(JobAlarmer.class);private ApplicationContext applicationContext;private List<JobAlarm> jobAlarmList;@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}@Overridepublic void afterPropertiesSet() throws Exception {Map<String, JobAlarm> serviceBeanMap = applicationContext.getBeansOfType(JobAlarm.class);if (serviceBeanMap != null && serviceBeanMap.size() > 0) {jobAlarmList = new ArrayList<JobAlarm>(serviceBeanMap.values());}}/*** job alarm** @param info* @param jobLog* @return*/public boolean alarm(XxlJobInfo info, XxlJobLog jobLog) {boolean result = false;if (jobAlarmList!=null && jobAlarmList.size()>0) {result = true;  // success means all-successfor (JobAlarm alarm: jobAlarmList) {boolean resultItem = false;try {resultItem = alarm.doAlarm(info, jobLog);} catch (Exception e) {logger.error(e.getMessage(), e);}if (!resultItem) {result = false;}}}return result;}}
  • 扩展实现企业微信机器人的告警功能。
    在企业微信终端某个群组添加机器人之后，创建者可以在机器人详情页看到该机器人特有的webhookurl。开发者可以向这个地址发起HTTP POST请求，即可实现给该群组发送消息。相关资料可以参考：https://developer.work.weixin.qq.com/document/path/91770
    后续可能还会有其他告警通知的需求（比如钉钉告警通知等），就先抽取一个类出来，方便后续扩展。
public abstract class AbstractJobAlarm implements JobAlarm {protected static final Logger logger = LoggerFactory.getLogger(AbstractJobAlarm.class);protected static final SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");protected RestTemplate restTemplate = new RestTemplate();public abstract String containsKeyword();public abstract String genJobAlarmRequestUrl(String keyword);public abstract Object genJobAlarmRequestBody(XxlJobInfo xxlJobInfo, XxlJobLog xxlJobLog);@Overridepublic boolean doAlarm(XxlJobInfo xxlJobInfo, XxlJobLog xxlJobLog) {if (null == xxlJobInfo) {return true;}String alarmEmail = xxlJobInfo.getAlarmEmail();if (null == alarmEmail || "".equals(alarmEmail) || !alarmEmail.contains(containsKeyword())) {return true;}boolean alarmResult = true;Object jobAlarmRequestBody = genJobAlarmRequestBody(xxlJobInfo, xxlJobLog);String[] keywordArray = alarmEmail.split(",");for (int i = 0, len = keywordArray.length; i < len; i++) {try {String jobAlarmRequestUrl = genJobAlarmRequestUrl(keywordArray[i]);logger.info("job alarm request url {} body {}", jobAlarmRequestUrl, jobAlarmRequestBody);restTemplate.postForEntity(jobAlarmRequestUrl, jobAlarmRequestBody, Object.class);} catch (Exception e) {logger.error(">>>>>>>>>>> xxl-job, job fail alarm send error, job log id:{}", xxlJobLog.getId(), e);alarmResult = false;}}return alarmResult;}protected String buildJobAlarmContentV1(XxlJobInfo xxlJobInfo, XxlJobLog xxlJobLog) {StringBuilder content = new StringBuilder();content.append("【告警信息】\n");content.append("负责人: ").append(buildAuthor(xxlJobInfo.getAuthor())).append("\n");content.append("描述: ").append(xxlJobInfo.getJobDesc()).append("\n");content.append("JOB_ID: ").append(xxlJobLog.getJobId()).append("\n");content.append("JOB_GROUP: ").append(xxlJobLog.getJobGroup()).append("\n");content.append("执行器名称: ").append(xxlJobInfo.getExecutorHandler()).append("\n");content.append("执行器IP: ").append(xxlJobLog.getExecutorAddress()).append("\n");content.append("任务参数: ").append(xxlJobLog.getExecutorParam()).append("\n");content.append("告警时间: ").append(SDF.format(new Date())).append("\n");content.append("LOG_ID: ").append(xxlJobLog.getId()).append("\n");Date triggerTime = xxlJobLog.getTriggerTime();if (null != triggerTime) {content.append("TRIGGER_TIME: ").append(SDF.format(triggerTime)).append("\n");}String triggerMsg = xxlJobLog.getTriggerMsg();if (null != triggerMsg && !"".equals(triggerMsg.trim())) {content.append("TRIGGER_MSG: ").append(triggerMsg.replace("<br>", "\n")).append("\n");}Date handleTime = xxlJobLog.getHandleTime();if (null != handleTime) {content.append("HANDLE_TIME: ").append(SDF.format(handleTime)).append("\n");}String handleMsg = xxlJobLog.getHandleMsg();if (null != handleMsg && !"".equals(handleMsg.trim())) {content.append("HANDLE_MSG: ").append(handleMsg).append("\n");}return content.toString();}private String buildAuthor(String author) {return null == author || "".equals(author) ? author : String.join(",",Arrays.stream(author.split(",")).map(v -> "@" + v).collect(Collectors.toList()));}}

public class QyWeiXinJobAlarm extends AbstractJobAlarm {@Value("${qyweixin.robot.webhook.url.prefix:https://qyapi.weixin.qq.com/cgi-bin/webhook/send?}")private String webhookUrlPrefix;@Overridepublic String containsKeyword() {return "key";}@Overridepublic String genJobAlarmRequestUrl(String keyword) {return webhookUrlPrefix + keyword;}/*** * @param xxlJobInfo* @param xxlJobLog* @return*/@Overridepublic Object genJobAlarmRequestBody(XxlJobInfo xxlJobInfo, XxlJobLog xxlJobLog) {HashMap<String, Object> requestBodyMap = new HashMap<>();try {// 获取执行日志信息ExecutorBiz executorBiz = XxlJobScheduler.getExecutorBiz(xxlJobLog.getExecutorAddress());if (null != executorBiz) {ReturnT<LogResult> resultReturnT = executorBiz.log(new LogParam(xxlJobLog.getTriggerTime().getTime(), xxlJobLog.getId(), 1));if (null != resultReturnT) {LogResult logResult = resultReturnT.getContent();if (null != logResult && null != logResult.getLogContent()) {logger.info("return result log {}", logResult.getLogContent());}}}} catch (Exception e) {logger.error(e.getMessage(), e);}// 消息类型requestBodyMap.put("msgtype", "text");HashMap<String, Object> textMap = new HashMap<>();textMap.put("content", buildJobAlarmContentV1(xxlJobInfo, xxlJobLog));// 设置是否@指定人String author = xxlJobInfo.getAuthor();if (null != author && !"".equals(author)) {List<String> authors = Arrays.stream(author.split(",")).collect(Collectors.toList());//authors.add("@all");textMap.put("mentioned_list", authors);textMap.put("mentioned_mobile_list", authors);}requestBodyMap.put("text", textMap);return requestBodyMap;}}
  • 自此，企业微信告警通知扩展实现完成，重新打包部署即可。没有调整修改前端的界面，所以只需要在原先的邮件文本框输入key=xxxxxx,key=xxxxxx即可。

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

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

相关文章

浅谈Java 微服务技术:理论与实践

浅谈Java 微服务技术:理论与实践

目录 1. 引言 2. 什么是微服务架构&#xff1f; 2.2 微服务的优势 3. 微服务架构的设计原则 3.1 单一职责原则 3.2 服务自治原则 3.3 去中心化原则 4. 微服务通信方式 4.1 RESTful API 4.2 消息队列 5. 服务注册与发现 6. 微服务容器化与Docker 7. 微服务监控与日志…
阅读更多...
SQL注入总结

SQL注入总结

又到了期末时间段&#xff0c;此文章是自己总结所学&#xff0c;仅供参考。 目录&#xff1a; 一、原理 一般流程 二、分类 按照请求分类 盲注分类 按照头部字段 其他类型 三、防御 代码层面 网络层面 一、原理&#xff1a; 后端web服务器对用户输入的恶意字符过滤不严&am…
阅读更多...
数据结构和算法-交换排序中的快速排序（演示过程 算法实现 算法效率 稳定性）

数据结构和算法-交换排序中的快速排序（演示过程 算法实现 算法效率 稳定性）

文章目录 总览快速排序&#xff08;超级重要&#xff09;啥是快速排序演示过程算法实现第一次quicksort函数第一次partion函数到第一次quicksort的第一个quicksort到第二次quicksort的第一个quicksort到第二次quicksort的第二个quicksort到第一次quicksort的第二个quicksort到第…
阅读更多...
Java反射和动态代理

Java反射和动态代理

文章目录 1、反射1.1 反射的概述1.2 反射作用1.3 获取字节码文件对象的方式1.4 字节码文件和字节码文件对象1.5 获取构造方法1.6 获取构造方法并创建对象1.7 获取成员变量并获取值和修改值1.8 获取成员方法1.9 获取成员方法并运行1.10 反射练习1.10.1 泛型擦除1.10.2 修改字符串…
阅读更多...
uniapp 创建组件组件

uniapp 创建组件组件

组件&#xff1a;用于将某个功能的 HTML、CSS、JS 封装到一个文件中&#xff0c;提高代码的复用性和可维护性。 创建组件 一、在根目录中创建 components 文件夹&#xff0c;右键点击新建组件。 二、输入组件名称、选择默认模板、点击创建组件。 三、在组件中正常编写内容即可…
阅读更多...
动态编译 - Dynamically Compile and Load External Java Classes

动态编译 - Dynamically Compile and Load External Java Classes

文章目录 概述Code 概述 动态编译和加载外部Java类的核心流程可以概括为以下几个步骤&#xff1a; 读取源代码: 首先&#xff0c;需要获取到外部的Java源代码。这通常是通过读取文件、网络资源或者数据库中的源代码字符串来实现的。编译源代码: 接下来&#xff0c;需要使用Ja…
阅读更多...
计算机网络（8）：因特网上的音频/视频服务

计算机网络（8）：因特网上的音频/视频服务

概述 计算机网络最初是为传送数据设计的。因特网 IP 层提供的 “尽最大努力交付” 服务以及每一个分组独立交付的策略&#xff0c;对传送数据信息十分合适。因特网使用的 TCP 协议可以很好地解决P层不能提供可靠交付这一问题。 音频/视频常称为多媒体信息 多媒体信息&#xff…
阅读更多...
unity 安卓 TCP可以连接别人，但是作为服务器无法被连接

unity 安卓 TCP可以连接别人，但是作为服务器无法被连接

现象非常的奇特&#xff0c;电脑ping手机没问题&#xff0c;用手机的socket调试助手也没问题&#xff0c;手机还能向外连接tcp服务器&#xff0c;但是电脑连手机tcp服务器连不上。更有趣的是&#xff0c;有些手机做tcp服务器可以被连接&#xff0c;有些手机做tcp服务器不能被连…
阅读更多...
容器相关笔记

容器相关笔记

1.容器 1.什么是容器 容器就是存放对象的集合 2.java中的容器 容器就是一系列的类或接口&#xff0c;用来存储一系列对象的地址 3.容器里存放的是引用数据类型&#xff08;存对象的地址&#xff0c;不是对象本身&#xff09;&#xff0c;不能存基本数据类型 4.容器存放的两种格…
阅读更多...
【BIAI】lecture 3 - GD BP CNN Hands-on

【BIAI】lecture 3 - GD BP CNN Hands-on

GD & BP & CNN & Hands-on 专业术语 gradient descent (GD) 梯度下降 back propagation (BP) 向传播 Convolutional Neural Network (CNN) 卷积神经网络 forward propagation 前向传播 biologically symmetry 生物对称性 synaptic 突触 axon 轴突 课程大纲 The go…
阅读更多...
BUUCTF crypto做题记录（6）新手向

BUUCTF crypto做题记录（6）新手向

一、Unencode 得到的密文&#xff1a;89FQA9WMD<V1A<V1S83DY.#<W3$Q,2TM] 看题目名字&#xff0c;我们可以知道这是一个解码的题目&#xff0c;但是unencode 好像是不可解码的意思&#xff0c;我们可以对照着解码方式看一下哪个更适合&#xff0c;可以进行尝试一下C…
阅读更多...
Linux系统操作——重启oracle服务：监听器和实例

Linux系统操作——重启oracle服务：监听器和实例

目录 一、重启Oracle数据库及监听器 【方法一】 【方法二】 【方法三】 二、查看oracle监听状态 三、重启实例 一、重启Oracle数据库及监听器 【方法一】 获取root权限 su root 进入oracle的安装目录 cd $ORACLE_HOME 重启数据库 dbstart 重启监听器 lsnrctl st…
阅读更多...
RocketMQ 投递消息方式以及消息体结构分析：Message、MessageQueueSelector

RocketMQ 投递消息方式以及消息体结构分析：Message、MessageQueueSelector

&#x1f52d; 嗨&#xff0c;您好 &#x1f44b; 我是 vnjohn&#xff0c;在互联网企业担任 Java 开发&#xff0c;CSDN 优质创作者 &#x1f4d6; 推荐专栏&#xff1a;Spring、MySQL、Nacos、Java&#xff0c;后续其他专栏会持续优化更新迭代 &#x1f332;文章所在专栏&…
阅读更多...
H5的3D游戏开源框架

H5的3D游戏开源框架

在H5的3D游戏框架中&#xff0c;Three.js、Babylon.js和Turbulenz是比较受欢迎的选择。 Three.js是一个广泛应用并且功能强大的JavaScript 3D库&#xff0c;可以创建简单的3D动画到创建交互的3D游戏。 Babylon.js是David Catuhe对3D游戏引擎热爱的结果&#xff0c;是最好的Jav…
阅读更多...
腾讯云取消免费10G CDN流量包：免费CDN时代结束

腾讯云取消免费10G CDN流量包：免费CDN时代结束

关注卢松松&#xff0c;会经常给你分享一些我的经验和观点。 免费送了7-8年的腾讯云10G免费流量包&#xff0c;从2024年开始&#xff0c;停止赠送了!自此&#xff0c;国内绝大多数互联网大厂的CDN都开收费了! 大概从2016年开始&#xff0c;腾讯云为了抢夺CDN客户&#xff0…
阅读更多...
基于Spring-boot-websocket的聊天应用开发总结

基于Spring-boot-websocket的聊天应用开发总结

目录 1.概述 1.1 Websocket 1.2 STOMP 1.3 源码 2.Springboot集成WS 2.1 添加依赖 2.2 ws配置 2.2.1 WebSocketMessageBrokerConfigurer 2.2.2 ChatController 2.2.3 ChatInRoomController 2.2.4 ChatToUserController 2.3 前端聊天配置 2.3.1 index.html和main.j…
阅读更多...
从0开始python学习-43.通过yaml实现不同文件之间参数的关联

从0开始python学习-43.通过yaml实现不同文件之间参数的关联

目的&#xff1a; 1. 统一管理接口关联的中间变量 2. 解决多个py文件中间的中间变量关联的问题 新建一个yaml_util.py进行封装读写清空yaml方法 # 读取 def read_yaml(key): with open("extract.yaml",encoding"utf-8") as f: #这里的文件如果没有会自…
阅读更多...
mnn-llm: 大语言模型端侧CPU推理优化

mnn-llm: 大语言模型端侧CPU推理优化

在大语言模型(LLM)端侧部署上&#xff0c;基于 MNN 实现的 mnn-llm 项目已经展现出业界领先的性能&#xff0c;特别是在 ARM 架构的 CPU 上。目前利用 mnn-llm 的推理能力&#xff0c;qwen-1.8b在mnn-llm的驱动下能够在移动端达到端侧实时会话的能力&#xff0c;能够在较低内存…
阅读更多...
MySQL之视图外连接、内连接和子查询的使用

MySQL之视图外连接、内连接和子查询的使用

一、视图 1.1 含义 虚拟表&#xff0c;和普通表一样使用 1.2 操作 创建视图 create view 视图名 as 修改视图 方式一&#xff1a; create or replace view 视图名 as 【查看视图相关字段】 方式二&#xff1a; alter view 视图名 as 【查看的SQL语句】 查看视图 方式一&…
阅读更多...
Baumer工业相机堡盟工业相机如何联合NEOAPI SDK和OpenCV实现相机图像转换为AVI视频格式（C#）

Baumer工业相机堡盟工业相机如何联合NEOAPI SDK和OpenCV实现相机图像转换为AVI视频格式（C#）

Baumer工业相机堡盟工业相机如何联合NEOAPI SDK和OpenCV实现相机图像转换为视频格式&#xff08;C#&#xff09; Baumer工业相机Baumer工业相机的图像转换为OpenCV的图像的技术背景在NEOAPI SDK里实现相机图像转换为视频格式 工业相机通过OpenCV实现相机图像转换为视频格式的优…
阅读更多...
最新文章

Copyright @ 2022~2023