golang中使用ffmpeg pipe将ts文件转推至rtmp简单示例

1. package main
   
2. 
   
3. import (
   
4.         "fmt"
   
5.         "io"
   
6.         "io/ioutil"
   
7.         "log"
   
8.         "os/exec"
   
9. )
   
10. 
    
11. 
    
12. func tsProducer(writer *io.PipeWriter) {
13.         //将本地的ts文件 写入 writer
    
14.         for i:=0; i<21;i++ {
    
15.                 tsName := fmt.Sprintf("sofia.pts.mp4-%05d.ts", i)
    
16.                 content, err := ioutil.ReadFile(tsName)
    
17.                 log.Print("ts produce loop:", tsName)
    
18. 
    
19.                 if err != nil {
    
20.                         log.Fatal(err)
    
21.                 }
    
22.                 
    
23.                 n , err:= writer.Write(content)
    
24.                 if err != nil {
    
25.                         log.Print("write to pipe failed:", err.Error())
    
26.                 }
    
27. 
    
28.                 log.Printf("write to pipe content len:%d, success\n", n)
    
29.         }
    
30. }
    
31. 
    
32. 
    
33. func main() {
    
34.         rp, wp := io.Pipe()
    
35.         go tsProducer(wp)
    
36. 
    
37.         for {
    
38.                 log.Print("main loop")
    
39.                 cmd := exec.Command("ffmpeg", "-re", "-i", "pipe:0", "-vcodec", "copy", "-acodec", "copy", "-f", "flv", "rtmp://127.0.0.1/live/pipe")
    
40.                 cmd.Stdin = rp
    
41. 
    
42.         
    
43. 
    
44.                 log.Print("cmd run")
    
45.                 err := cmd.Run()
    
46.                 log.Printf("Command finished with error: %v", err)
47.         }
48. }