管道

Process 结构体代表了一个正在运行的子进程,并公开了stdin(标准输入),stdout(标准输出) 和 stderr(标准错误) 句柄,通过管道和底层的进程交互。(原文:The Process struct represents a running child process, and exposes the stdin, stdout and stderr handles for interaction with the underlying process via pipes.)

  1. use std::error::Error;
  2. use std::io::prelude::*;
  3. use std::process::{Command, Stdio};
  4. static PANGRAM: &'static str =
  5. "the quick brown fox jumped over the lazy dog\n";
  6. fn main() {
  7. // 触发 `wc` 命令(原文:Spawn the `wc` command)
  8. let process = match Command::new("wc")
  9. .stdin(Stdio::piped())
  10. .stdout(Stdio::piped())
  11. .spawn() {
  12. Err(why) => panic!("couldn't spawn wc: {}", why.description()),
  13. Ok(process) => process,
  14. };
  15. // 将字符串写入 `wc` 的 `stdin`。
  16. //
  17. // `stdin` 拥有 `Option<ChildStdin>` 类型,不过既然我们已经知道这个实例
  18. // 只能拥有一个,那么我们可以直接解包(`unwrap`)它。
  19. // (原文:`stdin` has type `Option<ChildStdin>`, but since we know this instance
  20. // must have one, we can directly `unwrap` it.)
  21. match process.stdin.unwrap().write_all(PANGRAM.as_bytes()) {
  22. Err(why) => panic!("couldn't write to wc stdin: {}",
  23. why.description()),
  24. Ok(_) => println!("sent pangram to wc"),
  25. }
  26. // 因为 `stdin` 在上面调用后就不再存活,所以它被销毁了,且管道被关闭。
  27. //
  28. // 这点非常重要,否则 `wc` 不会开始处理我们刚刚发送的输入。
  29. // `stdout` 域也拥有 `Option<ChildStdout>` 类型,所以必需解包。
  30. let mut s = String::new();
  31. match process.stdout.unwrap().read_to_string(&mut s) {
  32. Err(why) => panic!("couldn't read wc stdout: {}",
  33. why.description()),
  34. Ok(_) => print!("wc responded with:\n{}", s),
  35. }
  36. }