Java 应用与 Linux 控制台程序交互：实现输入与输出

// 启动一个进程
Process process = Runtime.getRuntime().exec(commandArray);
// 或
// Process process = Runtime.getRuntime().exec(commandString);

package com.example.process;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class ConsoleAppTrigger {

    public static void main(final String[] args) {
        // 假设要执行的命令是一个简单的 bash 脚本，它会提示用户输入
        // 并根据输入内容给出不同的响应。
        // 实际使用时，请替换为您的 Linux 控制台应用程序的路径和名称。
        // 例如：String[] command = {"/path/to/your/console_app"};
        // 这里使用 bash -c 来模拟一个简单的交互式程序。
        // 注意：确保您的系统上安装了 bash。
        String[] command = {"bash", "-c", "read -p \"请输入: \" input; if [ \"$input\" = \"a\" ]; then echo \"收到输入: a\"; else echo \"收到输入: $input\"; fi"};

        Process process = null;
        // 创建一个线程池用于异步读取输出流，避免阻塞
        ExecutorService executor = Executors.newFixedThreadPool(2); 

        try {
            // 1. 启动进程
            process = Runtime.getRuntime().exec(command);
            System.out.println("进程已启动。");

            // 2. 异步读取标准输出流
            Future<String> outputFuture = executor.submit(() -> readStream(process.getInputStream(), "OUTPUT"));
            // 3. 异步读取标准错误流
            Future<String> errorFuture = executor.submit(() -> readStream(process.getErrorStream(), "ERROR"));

            // 4. 向进程的输入流写入数据
            final OutputStream os = process.getOutputStream();
            String inputData = "a"; // 模拟用户输入 'a'
            System.out.println("向进程写入数据: " + inputData);
            os.write(inputData.getBytes());

            // 模拟回车键
            final String lineSeparator = System.lineSeparator();
            os.write(lineSeparator.getBytes());
            os.flush(); // 刷新输出流，确保数据被发送

            // 等待进程执行完成
            int exitCode = process.waitFor();
            System.out.println("进程执行完毕，退出码: " + exitCode);

            // 获取异步读取的结果
            System.out.println("--- 进程标准输出 ---");
            System.out.println(outputFuture.get());
            System.out.println("--- 进程标准错误 ---");
            System.out.println(errorFuture.get());

        } catch (IOException e) {
            System.err.println("执行命令时发生IO错误: " + e.getMessage());
            e.printStackTrace();
        } catch (InterruptedException e) {
            System.err.println("进程等待被中断: " + e.getMessage());
            Thread.currentThread().interrupt(); // 重新设置中断状态
        } catch (Exception e) {
            System.err.println("发生未知错误: " + e.getMessage());
            e.printStackTrace();
        } finally {
            if (process != null) {
                process.destroy(); // 确保进程被终止
            }
            executor.shutdownNow(); // 关闭线程池
        }
    }

    /**
     * 辅助方法：从输入流读取所有数据并返回字符串
     */
    private static String readStream(InputStream is, String streamName) throws IOException {
        StringBuilder sb = new StringBuilder();
        int b;
        while ((b = is.read()) != -1) {
            sb.append((char) b);
        }
        // System.out.println("[" + streamName + "] 读取完毕。"); // 调试信息
        return sb.toString();
    }
}