rocketmq-console-alarm
所属分类：中间件编程
开发工具：Java
文件大小：0KB
下载次数：0
上传日期：2021-06-04 02:17:39
上 传 者：
sh-1993
说明： 在[https: github.com apache incubator-rocketmq-externals tree master rocketmq- console此基础上添加钉钉报警](https: github.com apache incubator-rocketmq- externals tree master rocketmq- console%E6%AD%A4%E5%9F%BA%E7%A1%80%E4%B8%8A%E6%B7%BB%E5%8A%A0%E9%92%89%E9%92%89%E6%8A%A5%E8%AD%A6)
(Add nail alarm based on [https: github.com apache inhibitor locketmq externals tree master rocketmq - console] (https: github.com apache inhibitor locketmq externals tree master rocketmq - console% E6% AD% A4% E5% 9F% BA% E7% A1% 80% E4% B8% 8A% E6% B7% BB% E5% 8A% A0% E9% 92% 89% E9% 92% 89% E6% 8A% A5% E8% AD% A6))
文件列表:
.travis.yml (322, 2019-11-04)
LICENSE (29843, 2019-11-04)
NOTICE (176, 2019-11-04)
doc/ (0, 2019-11-04)
doc/1_0_0/ (0, 2019-11-04)
doc/1_0_0/Milestone.md (3824, 2019-11-04)
doc/1_0_0/UserGuide_CN.md (2961, 2019-11-04)
doc/1_0_0/UserGuide_EN.md (2846, 2019-11-04)
pom.xml (15100, 2019-11-04)
src/ (0, 2019-11-04)
src/main/ (0, 2019-11-04)
src/main/docker/ (0, 2019-11-04)
src/main/docker/Dockerfile (169, 2019-11-04)
src/main/java/ (0, 2019-11-04)
src/main/java/cn/ (0, 2019-11-04)
src/main/java/cn/chendahai/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/App.java (1113, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/aspect/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/aspect/admin/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/aspect/admin/MQAdminAspect.java (2916, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/aspect/admin/annotation/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/aspect/admin/annotation/MultiMQAdminCmdMethod.java (1232, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/aspect/admin/annotation/OriginalControllerReturnValue.java (1204, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/config/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/config/RMQConfigure.java (3163, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/ (0, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/ClusterController.java (1775, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/ConsumerController.java (5107, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/DashboardController.java (2168, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/MessageController.java (3756, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/MonitorController.java (2782, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/NamesvrController.java (1604, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/OpsController.java (2251, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/ProducerController.java (2003, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/TestController.java (4939, 2019-11-04)
src/main/java/cn/chendahai/rocketmq/console/controller/TopicController.java (5083, 2019-11-04)
... ...
## 将jar包发布到中央仓库
`mvn clean deploy '-Dmaven.test.skip=true'`
## 源地址
> https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console
## 钉钉报警
参考：https://blog.csdn.net/luanlouis/article/details/88078657
## 扩展实现的代码
```$xslt
@Scheduled(cron = "0 */1 * * * ?")
public void scanProblemConsumeGroup() {
System.out.println("每1分钟监控一次");
for (Map.Entry configEntry : monitorService.queryConsumerMonitorConfig().entrySet()) {
GroupConsumeInfo consumeInfo = consumerService.queryGroup(configEntry.getKey());
if (consumeInfo.getCount() < configEntry.getValue().getMinCount() || consumeInfo.getDiffTotal() > configEntry.getValue().getMaxDiffTotal()) {
String msg = "消息堆积详情"+
"\ngroup→"+consumeInfo.getGroup()+
"\ncount→"+consumeInfo.getCount()+
"\nmessageModel→"+consumeInfo.getMessageModel()+
"\nconsumeTps→"+consumeInfo.getConsumeTps()+
"\ndiffTotal→"+consumeInfo.getDiffTotal();
dingDingSendMsg.send(msg);
}
}
}
```
## 使用方式
#### 下载打包
`cd project`
`mvn clean package`
#### 运行jar包
```$xslt
cd target
java -jar rocketmq-console-alarm-1.0.3.jar --server.port=6789 --rocketmq.config.namesrvAddr=192.168.1.10:9876 --dingding.token=***12a51a37466df312f420d4157a
0648effe59bcd725522300edae853401f4f --dingding.phones=13121939122
```
1. server.port:指定端口号
1. rocketmq.config.namesrvAddr:指定rocketmq地址，多个使用分号`;`分隔
1. dingding.token:钉钉报警机器人token值
1. dingding.phones:@人的手机号，所有的话使用all，多个人的话使用逗号`,`分隔
minCount 最少需要几个提供者
maxDiffTotal 消息堆积量
#### 效果
近期下载者：
相关文件：
收藏者：