- Process process = new ProcessBuilder(command).redirectErrorStream(true).start();
- 或者
- Process process = Runtime.getRuntime().exec(cmd);
redirectErrorStream(true)
错误输出与标准输出合并,以便通过使用Process类的getInputStream()方法可以读取错误并输出
通过子进程所产生的任何错误输出随后由该对象的start()方法启动将与标准输出合并, 这样既可以用Process.getInputStream()方法来读取。此使得更容易与对应的输出相关的错误消息。初始值是false。
- int exitcode = process .waitFor();
- new PrintStream(process .getErrorStream(), "error").start();
- new PrintStream(process .getInputStream(), "input").start();
process创建的子进程没有自己的控制台或终端,其所有的io操作都是通过(输入流、输出流、错误流)重定向到父进程中,如果该可执行程序的输入、输出或者错误输出比较多的话,而由于运行窗口的标准输入、输出等缓冲区有大小的限制,则可能导致子进程阻塞,甚至产生死锁,其解决方法就是在waitfor()方法之前读出窗口的标准输出、输出、错误缓冲区中的内容 所以,建议process .waitFor(); 放在处理流后面等待
- new PrintStream(process .getErrorStream(), "error").start();
- new PrintStream(process .getInputStream(), "input").start();
- int exitcode = process .waitFor();
(1)使用expect4j
- Process process = Runtime.getRuntime().exec("...");
- Expect expect = new ExpectBuilder()
- .withInputs(process.getInputStream())
- .withOutput(process.getOutputStream())
- .withErrorOnTimeout(true)
- .build();
- expect.expect(contains("Password:"));
- expect.sendLine("secret");
- expect.close();
(2)使用Threa.sleep
本来输出流,以为使用(win)\r\n或(linux)\n 模拟回车就可以输入参数。但是不起作用。
Thread.sleep(1000);在输入之间等待一段时间.将脚本在下一个输入之前消耗上个输入
- OutputStream outputStream = process.getOutputStream();
- outputStream.write(new String("1var").getBytes());
- Thread.sleep(1000); //https://www.it1352.com/2342759.html
- outputStream.write(new String("1tyh").getBytes());
- outputStream.flush();
- outputStream.close(); //写入完成后必须得执行 flush() 和 close() 方法,否则进程无法判断写入是否完成,导致写入失败;
(3)使用1024字节数组
一个 SET/P 语句的输入限制为 1024 个字符.我们可以使用它来解决这种情况,通过管道传输一个比 1024 小一个字符的缓冲区.因此,下一个输入的第一个字符将使缓冲区满,这将导致消耗输入并继续执行下一个语句.所以如果你使用这种转换方法,您的代码将按预期工作.事实上,你甚至可以省去刷新缓存
- OutputStream outputStream = process.getOutputStream();
- outputStream.write(convert("tester"));
- outputStream.write(convert("25"));
- outputStream.flush();
- outputStream.close(); //写入完成后必须得执行 flush() 和 close() 方法,否则进程无法判断写入是否完成,导致写入失败;
-
- public static byte[] convert(String str){
- byte[] asBytes = str.getBytes();
- byte[] result = new byte[1023];
- for(int i = 0; i < asBytes.length; i++)
- result[i] = asBytes[i];
- return result;
- }
- }
-
- /**
- * 用于处理Runtime.getRuntime().exec产生的错误流及输出流
- */
- public class PrintStreamextends Thread {
- InputStream is;
- String type;
- OutputStream os;
-
- PrintStream(InputStream is, String type) {
- this(is, type, null);
- }
-
- PrintStream(InputStream is, String type, OutputStream redirect) {
- this.is = is;
- this.type = type;
- this.os = redirect;
- }
-
- public void run() {
- InputStreamReader isr = null;
- BufferedReader br = null;
- PrintWriter pw = null;
- try {
- if (os != null)
- pw = new PrintWriter(os);
-
- isr = new InputStreamReader(is);
- br = new BufferedReader(isr);
- String line=null;
- while ( (line = br.readLine()) != null) {
- if (pw != null)
- pw.println(line);
- System.out.println(type + ">" + line);
- }
-
- if (pw != null)
- pw.flush();
- } catch (IOException ioe) {
- ioe.printStackTrace();
- } finally{
- try {
- pw.close();
- br.close();
- isr.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- }
参考:
如何使用 Java Process Builder 执行接受多个输入的批处理脚本? - IT屋-程序员软件开发技术分享社区
java - 如何将参数传递给Java Process? - Thinbug