问题背景
graylog+kafka+zookeeper(单机测试及源码),graylog组件部署,查找问题分析(一)graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二)graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三)graylog+kafka+zookeeper(单机测试及源码),graylog收集kafka(脚本创建发布订阅方式)存储的消息(四)graylog+kafka+zookeeper(单机测试及源码),graylog设置URL报警方式(五) graylog开启URL报警模式触发URL测试代码测试总结Lyric: 老仓库的角落
问题背景前四个篇章介绍了graylog+kafka+zookeeper的单机安装部署以及udp和kafka使用,这个篇章介绍 graylog 使用url的报警方式,因为我没有配置邮件的方式继续使用第二篇 kafka 的发布者和订阅者进行发送特殊的消息,并发起url报警可以自己创建工程,也可以url测试代码下载 graylog+kafka+zookeeper(单机测试及源码),graylog组件部署,查找问题分析(一) graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二) graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三) graylog+kafka+zookeeper(单机测试及源码),graylog收集kafka(脚本创建发布订阅方式)存储的消息(四) graylog+kafka+zookeeper(单机测试及源码),graylog设置URL报警方式(五) graylog开启URL报警模式
1 点击alerts页面
2 点击红框
3 创建时间定义
4 创建名字,选择优先级
5 设置filter&aggregation *** 作
6 自定义字段,本次测试暂时没有使用
7 添加URL通知方式,点击Add Notification
8 最后的效果
1 导入pom文件,可以删掉docker插件
4.0.0 org.springframework.boot spring-boot-starter-parent2.6.2 com.example demo0.0.1-SNAPSHOT demo demo 1.8 cloud-graylog 2021.0.0 org.springframework.cloud spring-cloud-starter-gatewayorg.springframework.cloud spring-cloud-starter-zipkin2.2.0.RELEASE org.springframework.boot spring-boot-starter-testtest org.springframework.cloud spring-cloud-dependencies${spring-cloud.version} pom import org.springframework.boot spring-boot-maven-plugin2.6.2 com.spotify docker-maven-plugin1.0.0 build-image package build ${docker.image.prefix}/${project.artifactId} src/main/docker http://192.168.207.128:2375 / ${project.build.directory} ${project.build.finalName}.jar
2 项目启动类
package com.example.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } }
3 application.yml
server: port: 8888
4 测试API
package com.example.demo.controller; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class Controller { @PostMapping("test") public String get(){ System.out.println("Receive success"); return "I am YuanGe"; } }
6 启动项目,kafka发布者发送关键字 yuange
7 查看接收情况,可以看到已经触发了URL方式报警,那么可以通过这种方式设置钉钉通知也是可以的
1 触发报警有一个bug,需要接收到下一条消息的时候,才会触发刚才的报警,还得研究一下有啥方式
作为程序员第 13 篇文章,每次写一句歌词记录一下,看看人生有几首歌的时间,wahahaha …
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)