java - 如何创建另一个 "version"的 process()

Question

我正在使用MessageConsole.java将标准输出流重定向到文本 Pane 。完成后，我认为重定向错误流也很好。为此，我在 this 的修改版本中添加了另一个缓冲读取器。回答。接下来是我的问题所在 - 我需要 process() 方法的另一个“版本”，该方法打印到 System.err 而不是 System.out >。我尝试用谷歌搜索它，但结果为零。如何添加需要特定参数的重写方法的另一个版本？该代码可能类似于第二个示例。

我当前的代码

class ConsoleThread extends SwingWorker<Void, String> {

    String command;

    ConsoleThread(String cmd) {
        command = cmd;
    }

    @Override
    protected Void doInBackground() throws Exception {


            Process ps = Runtime.getRuntime().exec(command);

            BufferedReader is = new BufferedReader(new InputStreamReader(ps.getInputStream()));
            BufferedReader es = new BufferedReader(new InputStreamReader(ps.getErrorStream()));

            String outputLine;
            String errorLine;

            while ((outputLine = is.readLine()) != null) {
                publish(outputLine);
            }

            while ((errorLine = es.readLine()) != null) {
                publish(errorLine);
            }

            is.close();

            return null;

    }



    @Override
    protected void process(List<String> chunk) {
        for (String string : chunk) {
            System.out.println(string);
        }
    }


}

答案可能是什么样的(一​​段代码胜过一千个字)

class ConsoleThread extends SwingWorker<Void, String> {

    String command;

    ConsoleThread(String cmd) {
        command = cmd;
    }

    @Override
    protected Void doInBackground() throws Exception {


            Process ps = Runtime.getRuntime().exec(command);

            BufferedReader is = new BufferedReader(new InputStreamReader(ps.getInputStream()));
            BufferedReader es = new BufferedReader(new InputStreamReader(ps.getErrorStream()));

            String outputLine;
            String errorLine;

            while ((outputLine = is.readLine()) != null) {
                publish(outputLine);
            }

            while ((errorLine = es.readLine()) != null) {
                publish2(errorLine);
            }

            is.close();

            return null;

    }



    @Override
    protected void process(List<String> chunk) {
        for (String string : chunk) {
            System.out.println(string);
        }
    }

    @Override
    protected void process2(List<String> chunk) {
        for (String string : chunk) {
            System.err.println(string);
        }
    }


}

其中 process2() 将被视为原始 process()。

需要明确的是，当前代码可以工作，但会将任何错误消息发送到输出流而不是错误流。 (参见this)

Answer 1

您根本不需要“另一个版本的 Process”。您所需要的只是两个新线程，每个流一个，即输入流和错误流。创建两个 Runnable，将 while 循环放入这些 Runnable 中，将您的 Stream 传递到它们中，然后在它们自己的线程中运行 Runnable。

您可以将要发布的消息包装在标识方法的流来源的包装器对象中，从而允许您使用相同的发布/处理对，或者您可以使用其他通知方法，例如 PropertyChangeListeners 和 PropertyChangeSupport。

<小时/>

就其值(value)而言，我在之前的尝试中使用过此代码来读取错误和输出流:

枚举 GobblerType.java

public enum GobblerType {
   ERROR, OUTPUT
}

类 StreamGobbler.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;

public class StreamGobbler implements Runnable {

   private InputStream is;
   private GobblerType type;
   private OutputStream os;

   public StreamGobbler(InputStream is, GobblerType type) {
      this(is, type, null);
   }

   public GobblerType getType() {
      return type;
   }

   public StreamGobbler(InputStream is, GobblerType type, OutputStream redirect) {
      this.is = is;
      this.type = type;
      this.os = redirect;
   }

   public void run() {
      try {
         PrintWriter pw = null;
         if (os != null) {
            pw = new PrintWriter(os, true);
         }
         InputStreamReader isr = new InputStreamReader(is);
         BufferedReader br = new BufferedReader(isr);
         String line = null;
         while ((line = br.readLine()) != null) {
            if (pw != null) {
               pw.println(line);
            }
            // System.out.println(type + "> " + line);
         }
      } catch (IOException ioe) {
         ioe.printStackTrace();
      }
   }
}

class TextAreaOutputStream.java——我对此最怀疑

import java.io.IOException;
import java.io.OutputStream;

import javax.swing.JTextArea;
import javax.swing.SwingUtilities;

public class TextAreaOutputStream extends OutputStream {

   private final JTextArea textArea;
   private final StringBuilder sb = new StringBuilder();
   private String title;

   public TextAreaOutputStream(final JTextArea textArea, String title) {
      this.textArea = textArea;
      this.title = title;
      sb.append(title + "> ");
   }

   @Override
   public void flush() {
   }

   @Override
   public void close() {
   }

   @Override
   public void write(int b) throws IOException {

      if (b == '\r')
         return;

      if (b == '\n') {
         final String text = sb.toString() + "\n";
         SwingUtilities.invokeLater(new Runnable() {
            public void run() {
               textArea.append(text);
            }
         });
         sb.setLength(0);
         sb.append(title + "> ");

         return;
      }

      sb.append((char) b);
   }
}

这些都不是专业代码，只是我玩过的垃圾。