Logstash之TCP插件

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

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

vim monitor_tcp.conf

input{tcp {port &＃61;> 9876mode &＃61;> "server"ssl_enable &＃61;> 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发送数据&＃xff1a;

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


观察结果&＃xff1a;