fix: rtmp play write timeout

langhuihui · langhuihui · commit 438a8ddee1f7 · 2025-09-08T13:28:52.000+08:00
diff --git a/example/custom/main.go b/example/custom/main.go
@@ -13,7 +13,6 @@ import (
 	_ "m7s.live/v5/plugin/flv"
 	_ "m7s.live/v5/plugin/gb28181"
 	_ "m7s.live/v5/plugin/logrotate"
-	_ "m7s.live/v5/plugin/monitor"
 	_ "m7s.live/v5/plugin/mp4"
 	mp4 "m7s.live/v5/plugin/mp4/pkg"
 	_ "m7s.live/v5/plugin/preview"
diff --git a/example/multiple/main.go b/example/multiple/main.go
@@ -9,7 +9,6 @@ import (
 	_ "m7s.live/v5/plugin/debug"
 	_ "m7s.live/v5/plugin/flv"
 	_ "m7s.live/v5/plugin/logrotate"
-	_ "m7s.live/v5/plugin/monitor"
 	_ "m7s.live/v5/plugin/rtmp"
 	_ "m7s.live/v5/plugin/rtsp"
 	_ "m7s.live/v5/plugin/test"
diff --git a/plugin/rtmp/pkg/net-connection.go b/plugin/rtmp/pkg/net-connection.go
@@ -449,11 +449,11 @@ func (nc *NetConnection) SendMessage(t byte, msg RtmpMessage) (err error) {
 	if sid, ok := msg.(HaveStreamID); ok {
 		head.MessageStreamID = sid.GetStreamID()
 	}
-	nc.SetWriteDeadline(time.Now().Add(time.Second * 5)) // 设置写入超时时间为5秒
 	return nc.sendChunk(util.NewMemory(nc.tmpBuf), head, RTMP_CHUNK_HEAD_12)
 }
 
 func (nc *NetConnection) sendChunk(mem util.Memory, head *ChunkHeader, headType byte) (err error) {
+	nc.SetWriteDeadline(time.Now().Add(time.Second * 5)) // 设置写入超时时间为5秒
 	head.WriteTo(headType, &nc.chunkHeaderBuf)
 	defer func(reuse net.Buffers) {
 		nc.sendBuffers = reuse

Original file line number	Diff line number	Diff line change
`@@ -449,11 +449,11 @@ func (nc *NetConnection) SendMessage(t byte, msg RtmpMessage) (err error) {`
`449`	`449`	`if sid, ok := msg.(HaveStreamID); ok {`
`450`	`450`	`head.MessageStreamID = sid.GetStreamID()`
`451`	`451`	`}`
`452`		`- nc.SetWriteDeadline(time.Now().Add(time.Second * 5)) // 设置写入超时时间为5秒`
`453`	`452`	`return nc.sendChunk(util.NewMemory(nc.tmpBuf), head, RTMP_CHUNK_HEAD_12)`
`454`	`453`	`}`
`455`	`454`
`456`	`455`	`func (nc NetConnection) sendChunk(mem util.Memory, head ChunkHeader, headType byte) (err error) {`
	`456`	`+ nc.SetWriteDeadline(time.Now().Add(time.Second * 5)) // 设置写入超时时间为5秒`
`457`	`457`	`head.WriteTo(headType, &nc.chunkHeaderBuf)`
`458`	`458`	`defer func(reuse net.Buffers) {`
`459`	`459`	`nc.sendBuffers = reuse`