1

我目前正在开发一个项目，其中客户端从服务器接收外壳/控制台命令，并且必须执行它们。

如何让 Java 在 shell 或命令提示符下运行这些命令？我希望能够忽略平台类型 - 并且不必指定 shell 或命令提示符 - 但如果我不能，那没关系。

我必须能够发送一系列相关命令，而不仅仅是一个命令。这意味着 shell/prompt 不能在命令之间退出或关闭。

我当前的代码如下所示，允许执行一系列程序，但是这些命令必须以某种方式通过管道传输到 shell/命令提示符中，必须从中读取输出。

ArrayList<String> comDat = new ArrayList<>();

while(true) {
    String input = con.recv();
    System.out.println("> " + input);

    if(!input.equals("EOF")) comDat.add(input); else {
        String[] s = new String[comDat.size()];
        for(int i = 0; i < comDat.size(); i++) s[i] = comDat.get(i);

        System.out.println("---Command sequence executing---");
        Process p = Runtime.getRuntime().exec(s);
        p.waitFor();

        System.out.println("---ErrorStream output---"); String line = "";
        BufferedReader errStream = new BufferedReader(new InputStreamReader(p.getErrorStream()));
        while((line = errStream.readLine()) != null) System.out.println("< " + line);

        System.out.println("\n---OutputStream output---"); line = "";
        BufferedReader outStream = new BufferedReader(new InputStreamReader(p.getInputStream()));
        while((line = errStream.readLine()) != null) System.out.println("< " + line);
    }
    Thread.sleep(200);
}

谢谢您的帮助！

4

1 回答 1

0

基本前提围绕着这个事实，dir它不是外部命令，而是cmd.

我会避免BufferedReaders在读取进程的输出时，因为并非所有进程在发送输出（例如进度指示器）时都使用新行，而是您应该读取 char for char（恕我直言）。

你应该我们ProcessBuilder而不是Runtime#exec。它提供了更好的管理并允许您将错误流重定向到输入流中，从而更容易读取输入。

import java.io.IOException;
import java.io.InputStream;

public class TestProcessBuilder {

    public static void main(String[] args) {

        try {
            ProcessBuilder pb = new ProcessBuilder("cmd", "/c", "dir");
            pb.redirectError();
            Process p = pb.start();
            InputStreamConsumer isc = new InputStreamConsumer(p.getInputStream());
            isc.start();
            int exitCode = p.waitFor();

            isc.join();
            System.out.println("Process terminated with " + exitCode);
        } catch (IOException | InterruptedException exp) {
            exp.printStackTrace();
        }

    }

    public static class InputStreamConsumer extends Thread {

        private InputStream is;

        public InputStreamConsumer(InputStream is) {
            this.is = is;
        }

        @Override
        public void run() {

            try {
                int value = -1;
                while ((value = is.read()) != -1) {
                    System.out.print((char)value);
                }
            } catch (IOException exp) {
                exp.printStackTrace();
            }

        }

    }
}
于 2013-04-18T23:30:49.577 回答