管道

std::Child 结构体代表了一个正在运行的子进程,它暴露了 stdin(标准 输入),stdout(标准输出)和 stderr(标准错误)句柄,从而可以通过管道与 所代表的进程交互。

  1. use std::io::prelude::*;
  2. use std::process::{Command, Stdio};
  3. static PANGRAM: &'static str =
  4. "the quick brown fox jumped over the lazy dog\n";
  5. fn main() {
  6. // 启动 `wc` 命令
  7. let process = match Command::new("wc")
  8. .stdin(Stdio::piped())
  9. .stdout(Stdio::piped())
  10. .spawn() {
  11. Err(why) => panic!("couldn't spawn wc: {:?}", why),
  12. Ok(process) => process,
  13. };
  14. // 将字符串写入 `wc` 的 `stdin`。
  15. //
  16. // `stdin` 拥有 `Option<ChildStdin>` 类型,不过我们已经知道这个实例不为空值,
  17. // 因而可以直接 `unwrap 它。
  18. match process.stdin.unwrap().write_all(PANGRAM.as_bytes()) {
  19. Err(why) => panic!("couldn't write to wc stdin: {:?}", why),
  20. Ok(_) => println!("sent pangram to wc"),
  21. }
  22. // 因为 `stdin` 在上面调用后就不再存活,所以它被 `drop` 了,管道也被关闭。
  23. //
  24. // 这点非常重要,因为否则 `wc` 就不会开始处理我们刚刚发送的输入。
  25. // `stdout` 字段也拥有 `Option<ChildStdout>` 类型,所以必需解包。
  26. let mut s = String::new();
  27. match process.stdout.unwrap().read_to_string(&mut s) {
  28. Err(why) => panic!("couldn't read wc stdout: {:?}", why),
  29. Ok(_) => print!("wc responded with:\n{}", s),
  30. }
  31. }