Java调用socat命令无法实时输出日志问题排查

核心问题点 #

1. socat调试输出流向stderr：socat的-d -d verbose日志默认输出到标准错误流（stderr），而你的代码只读取了标准输出流（stdout），因此终端看不到任何输出。
2. 命令解析错误：当命令包含环境变量、sudo及复杂参数时，直接用字符串传给Runtime.exec()会导致参数拆分混乱——比如SOCAT_SOCKADDR=...和socat的参数会被错误解析，无法正确执行命令。
3. 缓冲区阻塞：即使进程有stderr输出，若不读取，当stderr缓冲区填满时，进程会被挂起，无法继续运行或输出内容。

修复后的代码实现 #

改用ProcessBuilder替代Runtime.exec()，它更适合处理复杂命令，同时异步读取stdout和stderr，避免阻塞：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;

public class CommandRunner {

    public static ArrayList<String> runCommand(String[] commandArray) {
        ArrayList<String> outputLines = new ArrayList<>();

        ProcessBuilder pb = new ProcessBuilder(commandArray);
        // 单独设置环境变量，避免命令字符串解析错误
        pb.environment().put("SOCAT_SOCKADDR", "192.168.11.131");
        // 将stderr合并到stdout，统一读取所有输出
        pb.redirectErrorStream(true);

        try {
            Process process = pb.start();

            // 异步读取输出，防止缓冲区阻塞
            Thread outputReader = new Thread(() -> {
                try (BufferedReader reader = new BufferedReader(
                        new InputStreamReader(process.getInputStream()))) {
                    String line;
                    while ((line = reader.readLine()) != null) {
                        outputLines.add(line);
                        System.out.println(line); // 实时输出日志
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });
            outputReader.start();

            // 等待进程结束，同时确保输出读取完成
            int exitCode = process.waitFor();
            outputReader.join();

            System.out.println("\nExited with error code : " + exitCode);

        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }

        return outputLines;
    }

    public static void main(String[] args) {
        // 将命令拆分为数组，确保每个参数被正确解析
        String[] socatCommand = {
                "sudo",
                "socat",
                "-d", "-d",
                "-T", "10",
                "UDP4-LISTEN:132,reuseaddr,fork",
                "UDP4:192.168.11.130:130,bind=192.168.11.131:133"
        };
        runCommand(socatCommand);
    }
}

额外注意事项 #

• sudo免密配置：如果Java进程运行用户需要sudo权限，需在/etc/sudoers中添加免密规则，避免进程因等待密码输入而卡住：

  your_username ALL=(ALL) NOPASSWD: /usr/bin/socat
  

• 单独处理stderr：如果需要区分stdout和stderr，可移除pb.redirectErrorStream(true)，单独创建线程读取process.getErrorStream()。

内容的提问来源于stack exchange，提问作者Nafiul Alam Fuji