go - 将大量数据写入 exec.Command().StdinPipe() 错误

Question

考虑以下 Go 代码片段:

cmd := exec.Command(program, arg0)
stdin, err := cmd.StdinPipe()
// produces error when b is too large
n, err := stdin.Write(b.Bytes())

只要 b 太大，Write() 就会返回一个错误。尝试过不同大小的 b 后，似乎只要 b 的长度长于 Linux 管道缓冲区大小时就会发生这种情况。有没有解决的办法？本质上，我需要通过标准输入将大型日志文件提供给外部脚本。

Answer 1

我写这个程序是为了测试你的代码:

package main

import "os/exec"
import "fmt"


func main() {
        cmd := exec.Command("/bin/cat")

        in, _ := cmd.StdinPipe()

        cmd.Start()

        for i := 1024*1024; ; i += 1024*1024 {
                b := make([]byte,i)
                n, err := in.Write(b)
                fmt.Printf("%d: %v\n", n, err)
                if err != nil {
                        cmd.Process.Kill()
                        return
                }
        }
}

这个程序给出错误的唯一方法是被调用的进程关闭标准输入。您调用的程序是否关闭标准输入？这可能是 Go 运行时中的错误。