apps/monibuca
1
0
Fork 0
mirror of https://github.com/langhuihui/monibuca.git synced 2025-12-24 13:48:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: read rtmp streamID

Browse Source
This commit is contained in:
langhuihui
2024-10-17 16:48:07 +08:00
parent 6573fbf442
commit 8a80b06639
2 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
plugin/rtmp/pkg/net-connection.go
View File

@@ -245,7 +245,7 @@ func (nc *NetConnection) readChunkType(h *ChunkHeader, chunkType byte) (err erro
nc.readSeqNum++
if chunkType == 0 {
// Message Stream ID 4bytes
if h.MessageStreamID, err = nc.ReadBE32(4); err != nil { // 读取Message Stream ID
if h.MessageStreamID, err = nc.ReadLE32(4); err != nil { // 读取Message Stream ID
return err
}
}
@@ -305,18 +305,18 @@ func (nc *NetConnection) RecvMessage() (msg *Chunk, err error) {
err = r.WriteAudio(msg.AVData.WrapAudio())
} else {
msg.AVData.Recycle()
if r.PubAudio {
nc.Warn("ReceiveAudio", "MessageStreamID", msg.MessageStreamID)
}
//if r.PubAudio {
// nc.Warn("ReceiveAudio", "MessageStreamID", msg.MessageStreamID)
//}
}
case RTMP_MSG_VIDEO:
if r, ok := nc.Receivers[msg.MessageStreamID]; ok && r.PubVideo {
err = r.WriteVideo(msg.AVData.WrapVideo())
} else {
msg.AVData.Recycle()
if r.PubVideo {
nc.Warn("ReceiveVideo", "MessageStreamID", msg.MessageStreamID)
}
//if r.PubVideo {
// nc.Warn("ReceiveVideo", "MessageStreamID", msg.MessageStreamID)
//}
}
}
}