在Rust中如何将子进程stdout实时转发到当前进程stdout？

问题描述 #

我正尝试解决如何将命令的标准输出（stdout）转发到当前进程的标准输出的问题。目前我的实现代码会一次性读取子进程的所有stdout内容，无法处理子进程在终止前分块输出的情况：

let output = Command::new(cmd)
 .args(args)
 .output()
 .expect("Error reading process stdout");

print!(
  "{}",
  String::from_utf8(output.stdout).expect("Invalid output")
);

请问是否有办法增量读取这些输出并在输出块到达时实时打印？

解决方案 #

你需要用Command::spawn()替代output()——output()会阻塞到子进程完全终止才返回所有输出，而spawn()启动进程后会立即返回Child实例，允许你实时读写子进程的标准流。

核心实现思路 #

• 配置子进程时，将stdout设为Stdio::piped()，获取可读取的输出管道
• 用BufReader（或直接调用read()）增量读取管道内容
• 读取到内容后立即打印，并手动刷新当前进程的stdout缓冲区，确保内容实时显示

示例代码 #

use std::io::{self, BufRead, Write};
use std::process::{Command, Stdio};

fn main() -> io::Result<()> {
    // 替换成你的命令和参数
    let mut child = Command::new("ping")
        .args(&["-c", "5", "example.com"])
        .stdout(Stdio::piped())
        .spawn()?;

    // 提取子进程的stdout管道
    let stdout = child.stdout.take().expect("无法获取子进程标准输出");
    let reader = io::BufReader::new(stdout);

    // 逐行读取并实时打印
    for line_result in reader.lines() {
        let line = line_result?;
        println!("{}", line);
        // 强制刷新输出缓冲区，避免内容积压
        io::stdout().flush()?;
    }

    // 等待子进程执行完毕并获取退出状态
    let exit_status = child.wait()?;
    println!("\n子进程退出状态: {}", exit_status);

    Ok(())
}

注意事项 #

• 如果需要同时处理子进程的stderr，同样可以将stderr设为Stdio::piped()，并启动单独的线程来读取，避免阻塞stdout的处理
• 若不需要按行读取，也可以用read()方法读取固定大小的字节块，适配不同的输出场景

内容的提问来源于stack exchange，提问作者Finley Baker