Ví dụ về Apache Commons IO Tailer

Question

Tôi đang làm việc trên một chương trình giám sát đọc tệp /var/log/auth.log. Tôi đang sử dụng Apache Commons IO Tailer lớp để đọc tệp trong thời gian thực. Để bắt đầu, tôi muốn kiểm tra phần đọc thời gian thực trên một tệp đơn giản và nhập thủ công một số mã trong dòng điều khiển. Đây là mã của tôi:

public class Main { 
    public static void main(String[] args) { 
     TailerListener listener = new MyListener(); 
     Tailer tailer = Tailer.create(new File("log.txt"), listener, 500); 
     while(true) { 

     } 
    } 
} 

public class MyListener extends TailerListenerAdapter { 
    @Override 
    public void handle(String line) { 
     System.out.println(line); 
    } 
} 

Và từ nhà ga: sudo echo "Hello" >> log.txt Vấn đề là khi tôi cố gắng viết bằng tay một cái gì đó trong tập tin, nó không in nó trong giao diện điều khiển. Tôi đã cố gắng tìm một ví dụ cụ thể về cách sử dụng lớp Tailer, nhưng không may mắn. Tôi làm gì sai ở đây?

Answer 1

Dựa trên thử nghiệm của tôi, Tailer sẽ chỉ in một dòng khi bạn đã thêm dòng mới vào tệp. Vì vậy, hãy thử sudo echo "Hello\n" >> log.txt

Cũng lưu ý rằng nếu bạn gọi create, bạn bắt đầu một chuỗi nhưng không xử lý được. Do đó tại sao bạn phải có một vòng lặp while/true.

Bạn có thể thử này để thay thế:

public static void main(String[] args) { 
    TailerListener listener = new MyListener(); 
    Tailer tailer = new Tailer(new File("log.txt"), listener, 500);   
    tailer.run(); 
} 

Answer 2

Mã của bạn nên làm việc. Đối với tôi, điều này hoạt động như mong đợi.

package de.lhorn.stackoverflowplayground; 

import java.io.File; 
import org.apache.commons.io.input.Tailer; 
import org.apache.commons.io.input.TailerListenerAdapter; 

public class App { 

    private static final int SLEEP = 500; 

    public static void main(String[] args) throws Exception { 
     App app = new App(); 
     app.run(); 
    } 

    private void run() throws InterruptedException { 
     MyListener listener = new MyListener(); 
     Tailer tailer = Tailer.create(new File("/tmp/log.txt"), listener, SLEEP); 
     while (true) { 
      Thread.sleep(SLEEP); 
     } 
    } 

    public class MyListener extends TailerListenerAdapter { 

     @Override 
     public void handle(String line) { 
      System.out.println(line); 
     } 

    } 
}