diff --git a/pkg/rtmp/message_packer.go b/pkg/rtmp/message_packer.go index edcf962..bb95ae2 100644 --- a/pkg/rtmp/message_packer.go +++ b/pkg/rtmp/message_packer.go @@ -85,7 +85,7 @@ func (packer *MessagePacker) writeConnect(writer io.Writer, appName, tcURL strin var objs []ObjectPair objs = append(objs, ObjectPair{Key: "app", Value: appName}) - //objs = append(objs, ObjectPair{Key: "type", Value: "nonprivate"}) + objs = append(objs, ObjectPair{Key: "type", Value: "nonprivate"}) var flashVer string if isPush { flashVer = fmt.Sprintf("FMLE/3.0 (compatible; %s)", base.LALRTMPPushSessionConnectVersion) diff --git a/pkg/rtmp/tag.go b/pkg/rtmp/tag.go new file mode 100644 index 0000000..0e0b130 --- /dev/null +++ b/pkg/rtmp/tag.go @@ -0,0 +1,8 @@ +package rtmp + +type TagHeader struct { + Type uint8 // type + DataSize uint32 // body大小,不包含 header 和 prev tag size 字段 3byte + Timestamp uint32 // 绝对时间戳,单位毫秒 4byte + StreamID uint32 // always 0 3byte +}