ljydlv
/
videoplayer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

添加视频流接口

This commit is contained in:
junleea 2024-12-26 13:58:50 +08:00
parent 8214806a2f
commit bc1e89280e
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
handler/device.go
View File

@ -361,6 +361,7 @@ func VideoFeed(c *gin.Context) {
// 创建一个通道用于接收客户端连接关闭的信号 // 创建一个通道用于接收客户端连接关闭的信号
clientClosed := make(chan struct{}) clientClosed := make(chan struct{})
defer close(clientClosed)
c.Stream(func(w io.Writer) bool { c.Stream(func(w io.Writer) bool {
// 将读取 Redis 消息通道的逻辑放在这里，方便根据返回值控制循环 // 将读取 Redis 消息通道的逻辑放在这里，方便根据返回值控制循环
ch := pubSub.Channel() ch := pubSub.Channel()
@ -384,22 +385,22 @@ func VideoFeed(c *gin.Context) {
_, err = w.Write([]byte("--frame\r\n")) _, err = w.Write([]byte("--frame\r\n"))
if err != nil { if err != nil {
fmt.Println("write video frame error:", err) fmt.Println("write video frame error:", err)
continue return false
} }
_, err = w.Write([]byte("Content-Type: image/jpeg\r\n\r\n")) _, err = w.Write([]byte("Content-Type: image/jpeg\r\n\r\n"))
if err != nil { if err != nil {
fmt.Println("write video frame error:", err) fmt.Println("write video frame error:", err)
continue return false
} }
_, err = w.Write(buf) _, err = w.Write(buf)
if err != nil { if err != nil {
fmt.Println("write video frame error:", err) fmt.Println("write video frame error:", err)
continue return false
} }
_, err = w.Write([]byte("\r\n")) _, err = w.Write([]byte("\r\n"))
if err != nil { if err != nil {
fmt.Println("write video frame error:", err) fmt.Println("write video frame error:", err)
continue return false
} }
case <-clientClosed: case <-clientClosed:
// 当接收到客户端关闭连接的信号，返回 false 停止发送视频流 // 当接收到客户端关闭连接的信号，返回 false 停止发送视频流