Java Runtime.exec() đầu ra không đồng bộ

Question

Tôi muốn lấy đầu ra từ lệnh shell đang chạy dài vì nó có sẵn thay vì chờ lệnh hoàn thành. Mã của tôi được chạy trong một thread mới

Process proc = Runtime.getRuntime().exec("/opt/bin/longRunning"); 
InputStream in = proc.getInputStream(); 
int c; 
while((c = in.read()) != -1) { 
    MyStaticClass.stringBuilder.append(c); 
} 

Vấn đề ở đây là chương trình của tôi trong/opt/bin/longRunning phải hoàn thành trước khi InputStream được giao và đọc. Có cách nào tốt để làm điều này một cách không đồng bộ? Mục tiêu của tôi là một yêu cầu ajax sẽ trả về giá trị hiện tại MyStaticClass.stringBuilder.toString() mỗi giây hoặc lâu hơn.

Tôi bị kẹt trên Java 5, fyi.

Cảm ơn! W

Answer 1

Hãy thử với Apache Common Exec. Nó có khả năng thực hiện không đồng bộ một quá trình và sau đó "bơm" đầu ra cho một luồng. Kiểm tra Javadoc để biết thêm

Answer 2

Runtime.getRuntime(). Exec thực hiện không chờ lệnh chấm dứt, vì vậy bạn sẽ nhận được kết quả ngay lập tức. Có lẽ đầu ra đang được đệm bởi vì lệnh biết nó đang ghi vào một đường ống chứ không phải là một thiết bị đầu cuối?

Answer 3

Đặt đọc trong một chủ đề mới:

new Thread() { 
    public void run() { 
     InputStream in = proc.getInputStream(); 
     int c; 
     while((c = in.read()) != -1) { 
      MyStaticClass.stringBuilder.append(c); 
     } 
    } 
}.start(); 

Answer 4

Bạn viết chương trình mà bạn đang gọi điện thoại? Nếu vậy hãy thử xả đầu ra của bạn sau khi viết. Các văn bản có thể bị mắc kẹt trong một bộ đệm và không nhận được vào chương trình java của bạn.

tôi sử dụng mã này để làm điều này và nó hoạt động:

Runtime runtime = Runtime.getRuntime(); 
    Process proc = runtime.exec(command); 
    BufferedReader br = new BufferedReader(new InputStreamReader(proc.getInputStream())); 

    while (true) { 

     // enter a loop where we read what the program has to say and wait for it to finish 
     // read all the program has to say 
     while (br.ready()) { 
      String line = br.readLine(); 
      System.out.println("CMD: " + line); 
     } 

     try { 
      int exitCode = proc.exitValue(); 
      System.out.println("exit code: " + exitCode); 
      // if we get here then the process finished executing 
      break; 
     } catch (IllegalThreadStateException ex) { 
      // ignore 
     } 

     // wait 200ms and try again 
     Thread.sleep(200); 

    } 

Answer 5

Hãy thử:

try { 
     Process p = Runtime.getRuntime().exec("/opt/bin/longRunning"); 
     BufferedReader in = new BufferedReader( 
            new InputStreamReader(p.getInputStream())); 
     String line = null; 
     while ((line = in.readLine()) != null) { 
     System.out.println(line); }