Bắt đầu quá trình với stdin/stdout/stderr kế thừa trong Java 6

Question

Nếu tôi bắt đầu quá trình qua lớp ProcessBuilder của Java, tôi có toàn quyền truy cập vào các tiêu chuẩn của quy trình đó, tiêu chuẩn và các luồng lỗi chuẩn như Java InputStreams và OutputStreams. Tuy nhiên, tôi không thể tìm cách kết nối liền mạch các luồng đó với số System.in, System.out và System.err.

Có thể sử dụng redirectErrorStream() để nhận đơn InputStream có lỗi tiêu chuẩn và lỗi chuẩn của quy trình con và chỉ lặp lại và gửi thông qua tiêu chuẩn của tôi — nhưng tôi không thể tìm cách để làm điều đó và để người dùng nhập vào quy trình, vì họ có thể nếu tôi sử dụng cuộc gọi C system().

Điều này dường như có thể xảy ra trong Java SE 7 khi xuất hiện — tôi chỉ tự hỏi liệu có giải pháp nào không. Điểm thưởng nếu kết quả của isatty() trong quá trình con thực hiện thông qua chuyển hướng.

Answer 1

Bạn sẽ cần phải sao chép các luồng Process ra, lỗi và luồng nhập vào phiên bản Hệ thống. Cách dễ nhất để thực hiện điều đó là sử dụng lớp IOUtils từ gói IO của Commons. copy method có vẻ là những gì bạn cần. Các lời gọi phương thức sao chép sẽ cần phải nằm trong các luồng riêng biệt.

Đây là mã cơ bản:

// Assume you already have a processBuilder all configured and ready to go 
final Process process = processBuilder.start(); 
new Thread(new Runnable() {public void run() { 
    IOUtils.copy(process.getOutputStream(), System.out); 
} }).start(); 
new Thread(new Runnable() {public void run() { 
    IOUtils.copy(process.getErrorStream(), System.err); 
} }).start(); 
new Thread(new Runnable() {public void run() { 
    IOUtils.copy(System.in, process.getInputStream()); 
} }).start(); 

Answer 2

Một biến thể của câu trả lời của John đó biên dịch và không yêu cầu bạn phải sử dụng Commons IO:

private static void pipeOutput(Process process) { 
    pipe(process.getErrorStream(), System.err); 
    pipe(process.getInputStream(), System.out); 
} 

private static void pipe(final InputStream src, final PrintStream dest) { 
    new Thread(new Runnable() { 
     public void run() { 
      try { 
       byte[] buffer = new byte[1024]; 
       for (int n = 0; n != -1; n = src.read(buffer)) { 
        dest.write(buffer, 0, n); 
       } 
      } catch (IOException e) { // just exit 
      } 
     } 
    }).start(); 
} 

Answer 3

Đối System.in sử dụng sau đây pipein() thay vì pipe()

pipein(System.in, p.getOutputStream()); 

Triển khai:

private static void pipein(final InputStream src, final OutputStream dest) { 

    new Thread(new Runnable() { 
     public void run() { 
      try { 
       int ret = -1; 
       while ((ret = System.in.read()) != -1) { 
        dest.write(ret); 
        dest.flush(); 
       } 
      } catch (IOException e) { // just exit 
      } 
     } 
    }).start(); 

}