go + ffmpeg pipe 怎么确定当前转码操作已经结束，可以停了

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

已注册用户请登录

这是一个创建于 549 天前的主题，其中的信息可能已经有所发展或是发生改变。

伪代码如下：

func main() { url := "http://a.mp4" args := strings.Split("ffmpeg -y -i pipe:0 -f mpegts pipe:1", " ") ctx, cancel := context.WithCancel(context.Background()) cmd := exec.CommandContext(ctx, args[0], args[1:]...) pipe0, _ := cmd.StdinPipe() pipe1, _ := cmd.StdoutPipe() cmd.Start() go func () { cmd.Wait() } go func () { file := os.Openfile.... io.Copy(file, pipe1) } io.Copy(pipe0, http.resp.body) }

问题是，write 完成了，但是我不确定转码完成了没。去监听 stderr 吗？看 stderr 的已完成转码时长是不是等于预期？

转码

完成

监听

7 条回复 2024-05-27 10:38:34 +08:00

awm47

2024-05-27 09:52:43 +08:00

把 cmd.Wait 放在外面，io.Copy 放在 goroutine 里

dzdh

2024-05-27 09:55:47 +08:00

@jaynos 不行。pipe 不是真正的 wait 。进程不会自己停的。即便 input 写完了，进程也在继续等你的 write 。而且转码进度一直也有速度。

awm47

2024-05-27 10:00:33 +08:00

@dzdh 我测试 `cat file_example_MP4_1920_18MG.mp4 | ffmpeg -y -i pipe:0 -f mpegts pipe:1 > /dev/null` 进程是会结束的，是不是没的 reader 没返回 io.EOF

dzdh
OP
2024-05-27 10:07:44 +08:00

@jaynos #3 io.Copy(pipe0, http.resp.body) 这个都结束了。进程还在跑。

linux 管道自己会结束吧，| 前面的结束后边的也跟着结束这是 linux 自带的吧。我测试也会自己结束。

写代码的不会。。。

dzdh

2024-05-27 10:10:48 +08:00

@jaynos #3

我 sb 了。io.Copy(pipe0, http.resp.body)结束后加个 pipe0.close 就好了。我放到 defer 了。。。

解决。结贴。

awm47

2024-05-27 10:15:03 +08:00

@dzdh #5 刚写了个代码测试了可以，stdin 写完 close 就会触发 io.EOF 结束进程了

Yoruno

2024-05-27 10:38:34 +08:00

应该可以读取信息，判断转完调用 close 关闭