msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

Optimized Feishu configuration changes and alarm notifications

Browse Source
pull/435/head
chen.ma 2 years ago
parent cb983b15a7
commit 53ce9c4b18
5 changed files with 413 additions and 8 deletions
Show Stats Download Patch File Download Diff File

22
hippo4j-message/src/main/java/cn/hippo4j/message/platform/LarkSendMessageHandler.java
Unescape View File

@ -17,6 +17,7 @@
package cn.hippo4j.message.platform;
import cn.hippo4j.common.toolkit.Singleton;
import cn.hippo4j.message.dto.NotifyConfigDTO;
import cn.hippo4j.message.enums.NotifyPlatformEnum;
import cn.hippo4j.message.enums.NotifyTypeEnum;
@ -25,6 +26,7 @@ import cn.hippo4j.message.request.AlarmNotifyRequest;
import cn.hippo4j.message.request.ChangeParameterNotifyRequest;
import cn.hippo4j.common.toolkit.StringUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest;
import lombok.AllArgsConstructor;
@ -53,20 +55,25 @@ public class LarkSendMessageHandler implements SendMessageHandler<AlarmNotifyReq
@SneakyThrows
public void sendAlarmMessage(NotifyConfigDTO notifyConfig, AlarmNotifyRequest alarmNotifyRequest) {
String afterReceives = getReceives(notifyConfig.getReceives());
String larkAlarmTxt;
String larkAlarmTimoutReplaceTxt;
String larkAlarmTxtKey = "message/robot/dynamic-thread-pool/lark-alarm.json";
String larkAlarmTxt = Singleton.get(larkAlarmTxtKey, () -> FileUtil.readUtf8String(larkAlarmTxtKey));
String larkAlarmTimoutReplaceJsonKey = "message/robot/dynamic-thread-pool/lark-alarm-timeout-replace.json";
String larkAlarmTimoutReplaceJson = Singleton.get(larkAlarmTimoutReplaceJsonKey, () -> FileUtil.readUtf8String(larkAlarmTimoutReplaceJsonKey));
if (Objects.equals(alarmNotifyRequest.getNotifyTypeEnum(), NotifyTypeEnum.TIMEOUT)) {
String executeTimeoutTrace = alarmNotifyRequest.getExecuteTimeoutTrace();
String larkAlarmTimoutTraceReplaceJsonKey = "message/robot/dynamic-thread-pool/lark-alarm-trace-replace.json";
String larkAlarmTimoutTraceReplaceJson = Singleton.get(larkAlarmTimoutTraceReplaceJsonKey, () -> FileUtil.readUtf8String(larkAlarmTimoutTraceReplaceJsonKey));
if (StringUtil.isNotBlank(executeTimeoutTrace)) {
String larkAlarmTimoutTraceReplaceTxt = String.format(LARK_ALARM_TIMOUT_TRACE_REPLACE_TXT, executeTimeoutTrace);
larkAlarmTimoutReplaceTxt = StrUtil.replace(LARK_ALARM_TIMOUT_REPLACE_TXT, LARK_ALARM_TIMOUT_TRACE_REPLACE_TXT, larkAlarmTimoutTraceReplaceTxt);
String larkAlarmTimoutTraceReplaceTxt = String.format(larkAlarmTimoutTraceReplaceJson, executeTimeoutTrace);
larkAlarmTimoutReplaceTxt = StrUtil.replace(larkAlarmTimoutReplaceJson, larkAlarmTimoutTraceReplaceJson, larkAlarmTimoutTraceReplaceTxt);
} else {
larkAlarmTimoutReplaceTxt = StrUtil.replace(LARK_ALARM_TIMOUT_REPLACE_TXT, LARK_ALARM_TIMOUT_TRACE_REPLACE_TXT, "");
larkAlarmTimoutReplaceTxt = StrUtil.replace(larkAlarmTimoutReplaceJson, larkAlarmTimoutTraceReplaceJson, "");
}
larkAlarmTimoutReplaceTxt = String.format(larkAlarmTimoutReplaceTxt, alarmNotifyRequest.getExecuteTime(), alarmNotifyRequest.getExecuteTimeOut());
larkAlarmTxt = StrUtil.replace(LARK_ALARM_JSON_STR, LARK_ALARM_TIMOUT_REPLACE_TXT, larkAlarmTimoutReplaceTxt);
larkAlarmTxt = StrUtil.replace(larkAlarmTxt, larkAlarmTimoutReplaceJson, larkAlarmTimoutReplaceTxt);
} else {
larkAlarmTxt = StrUtil.replace(LARK_ALARM_JSON_STR, LARK_ALARM_TIMOUT_REPLACE_TXT, "");
larkAlarmTxt = StrUtil.replace(larkAlarmTxt, larkAlarmTimoutReplaceJson, "");
}
String text = String.format(larkAlarmTxt,
@ -118,7 +125,8 @@ public class LarkSendMessageHandler implements SendMessageHandler<AlarmNotifyReq
public void sendChangeMessage(NotifyConfigDTO notifyConfig, ChangeParameterNotifyRequest changeParameterNotifyRequest) {
String threadPoolId = changeParameterNotifyRequest.getThreadPoolId();
String afterReceives = getReceives(notifyConfig.getReceives());
String larkNoticeJson = LARK_NOTICE_JSON_STR;
String larkNoticeJsonKey = "message/robot/dynamic-thread-pool/lark-config.json";
String larkNoticeJson = Singleton.get(larkNoticeJsonKey, () -> FileUtil.readUtf8String(larkNoticeJsonKey));
String text = String.format(larkNoticeJson,
// 环境
changeParameterNotifyRequest.getActive(),

30
hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/lark-alarm-timeout-replace.json
Unescape View File

@ -0,0 +1,30 @@
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 任务执行时间：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 超时时间：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 链路信息：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},

8
hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/lark-alarm-trace-replace.json
Unescape View File

@ -0,0 +1,8 @@
{
"is_short": true,
"text": {
"content": "** 链路信息：** %s",
"tag": "lark_md"
}
}

205
hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/lark-alarm.json
Unescape View File

@ -1,3 +1,206 @@
{
"name": "123"
"msg_type": "interactive",
"card": {
"config": {
"wide_screen_mode": true
},
"header": {
"template": "red",
"title": {
"content": "[🔥警报] %s 动态线程池运行告警（%s）",
"tag": "plain_text"
}
},
"elements": [
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 线程池ID：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 应用名称：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 应用实例：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 核心线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 最大线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 当前线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 活跃线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 同存最大线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 线程池任务总量：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 队列类型：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 队列容量：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 队列元素个数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 队列剩余个数：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 任务执行时间：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 超时时间：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 链路信息：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 拒绝策略：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 拒绝策略执行次数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** OWNER：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 播报时间： ** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"tag": "note",
"elements": [
{
"tag": "plain_text",
"content": "提示： %s 分钟内此线程池不会重复告警（可配置）"
}
]
}
]
}
}

156
hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/lark-config.json
Unescape View File

@ -0,0 +1,156 @@
{
"msg_type": "interactive",
"card": {
"config": {
"wide_screen_mode": true
},
"header": {
"template": "greed",
"title": {
"content": "[通知] %s 动态线程池参数变更",
"tag": "plain_text"
}
},
"elements": [
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 线程池ID：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 应用名称：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 应用实例：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 核心线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 最大线程数：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 核心线程超时：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 线程存活时间：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** 队列类型：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 队列容量：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 执行超时时间：** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"fields": [
{
"is_short": true,
"text": {
"content": "** AGO 拒绝策略：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** NOW 拒绝策略：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** OWNER：** %s",
"tag": "lark_md"
}
},
{
"is_short": true,
"text": {
"content": "** 播报时间： ** %s",
"tag": "lark_md"
}
}
],
"tag": "div"
},
{
"tag": "hr"
},
{
"tag": "note",
"elements": [
{
"tag": "plain_text",
"content": "提示：动态线程池配置变更实时通知（无限制）"
}
]
}
]
}
}
Write Preview
Loading…
Cancel
Save