Go cmd.StdinPipe
管道允许我们将一个命令的输出发送到另一个命令。 StdinPipe 返回一个管道,该管道将在命令启动时连接到命令的标准输入。
package main import ( "fmt" "io" "log" "os/exec" ) func main() { cmd := exec.Command("cat") stdin, err := cmd.StdinPipe() if err != nil { log.Fatal(err) } go func() { defer stdin.Close() io.WriteString(stdin, "an old falcon") }() out, err := cmd.CombinedOutput() if err != nil { log.Fatal(err) } fmt.Printf("%s\n", out) }
在代码示例中,我们将字符串写入 goroutine 内的标准输入。
cmd := exec.Command("cat")
cat
命令将给定的文件连接到标准输出。当没有给定文件或带有 - 时,该命令读取标准输入并将其打印到标准输出。
stdin, err := cmd.StdinPipe()
我们得到 cat
命令的标准输入管道。
go func() { defer stdin.Close() io.WriteString(stdin, "an old falcon") }()
在 goroutine 内部,我们将一个字符串写入标准输入管道。
$ go run stdinpipe.go an old falcon
Go cmd.StdoutPipe
StdoutPipe 返回一个管道,该管道将在命令启动时连接到命令的标准输出。
package main import ( "fmt" "io/ioutil" "log" "os/exec" "strings" ) func upper(data string) string { return strings.ToUpper(data) } func main() { cmd := exec.Command("echo", "an old falcon") stdout, err := cmd.StdoutPipe() if err != nil { log.Fatal(err) } if err := cmd.Start(); err != nil { log.Fatal(err) } data, err := ioutil.ReadAll(stdout) if err != nil { log.Fatal(err) } if err := cmd.Wait(); err != nil { log.Fatal(err) } fmt.Printf("%s\n", upper(string(data))) }
该示例通过管道读取 echo 命令的输出并将其转换为大写字母。
cmd := exec.Command("echo", "an old falcon")
要运行的命令是带有单个字符串参数的 echo 命令。
stdout, err := cmd.StdoutPipe()
我们得到标准输出管道。
if err := cmd.Start(); err != nil { log.Fatal(err) }
该命令使用 Start 函数执行;它不会等待它完成。
data, err := ioutil.ReadAll(stdout)
我们从管道中读取数据。
if err := cmd.Wait(); err != nil { log.Fatal(err) }
Wait 等待命令退出并等待任何复制到 stdin 或从 stdout 或 stderr 复制完成。它在看到命令退出后关闭管道。
运行该程序:
$ go run stdoutpipe.go AN OLD FALCON
总结
os/exec
包运行外部命令。它包装了 os.StartProcess
以便更轻松地重新映射标准输入和标准输出、将 I/O 与管道连接以及进行其他调整。