java - 以编程方式配置 Filebeat Shippers

Question

如何以编程方式创建类似 Filebeat 的 Shipper，它将我的日志从客户端服务器发送到远程 Logstash 服务器。

我是 ELK 和 log4j 的新手，我正在尝试创建 Daemonize java 程序或 shell 脚本，它将继续逐行读取我的日志文件，并将所有行(以及任何新行)发送到定义的 Logstash 服务器。

我能够逐行读取文件，但到达 EOF 后它就会关闭。

此外，我想让它成为守护进程，它将继续监视日志文件，并通过 TCP 将每一行发送到 Logstash。

FileInputStream fstream = new FileInputStream("textfile.txt");
BufferedReader br = new BufferedReader(new InputStreamReader(fstream));

String strLine;
while ((strLine = br.readLine()) != null)   {

  System.out.println (strLine);
}
br.close();

有人可以指导我正确的方向吗？

Answer 1

现在，

Filebeat确实存在，无需编程，只需使用beat包即可

https://www.elastic.co