Logstash之TCP插件

蔚落 2023-06-16 02:29 7阅读 0赞

TCP是一种网络传输控制协议，很多公司的数据不一定是在本地的，而是在传承网络的；  
这个时候使用TCP简历连接后，通信双王就可以进行数据传输了；

TCP插件可以监控某个端口，当数据打入logstash监听的端口队列的时候，logstash就可以进行数据的采集

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70]

vim monitor\_tcp.conf

input{
        tcp {
           port => 9876
           mode => "server"
           ssl_enable => false
       }
    }
    output{
        stdout{}
    }

启动并且监听到9876端口;  
检测logstash 配置文件  
bin/logstash -f /usr/local/elk/logstash-5.5.2/conf/template/monitor\_tcp.conf -t

bin/logstash -f /usr/local/elk/logstash-5.5.2/conf/template/monitor\_tcp.conf

写一段java的socket代码向9876发送数据：

public static void main(String[] args) throws Exception{
        // 向服务器端发送请求，服务器IP地址和服务器监听的端口号
        Socket client = new Socket("hadoop01", 9876);
    
        // 通过printWriter 来向服务器发送消息
        PrintWriter printWriter = new PrintWriter(client.getOutputStream());
        System.out.println("连接已建立...");
        for(int i=0;i<10;i++){
            // 发送消息
            printWriter.println("hello logstash , 这是第"+i+" 条消息");
    
            printWriter.flush();
        }
    
    }

观察结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191124072210414.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191124072324492.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDA2MjMzOQ==,size_16,color_FFFFFF,t_70