我如何以编程方式创建一个类似 Shipper 的 Filebeat，它将我的日志从客户端服务器发送到远程 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();
有人可以指导我正确的方向吗？