graylog+kafka+zookeeper（单机测试及源码），graylog设置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报警模式触发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-parent
        2.6.2
         
    
    com.example
    demo
    0.0.1-SNAPSHOT
    demo
    demo
    
        1.8
        cloud-graylog
        2021.0.0
    
    
        
            org.springframework.cloud
            spring-cloud-starter-gateway
        
        
            org.springframework.cloud
            spring-cloud-starter-zipkin
            2.2.0.RELEASE
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        
    
    
        
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring-cloud.version}
                pom
                import
            
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
                2.6.2
            

            
            
                com.spotify
                docker-maven-plugin
                1.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 …