[fix] rtsp，只有输入流中的音频和视频格式都支持时才使用queue，避免只有音频或视频时造成延迟增加

CHANGELOG.md

@@ -11,7 +11,7 @@
 - [feat] rtsp，修改rtsp.AVPacketQueue的行为：当音频或者视频数量队列满了后，直接出队而不是丢弃
 - [feat] logic，rtsp pub转发给rtsp sub
 - [feat] logic，rtsp pub转发给relay rtmp push
-- [feat] remux，用于处理协议转封装
+- [feat] remux，新增package，用于处理协议转封装
 - [refactor] 重构所有client session解析url的地方
 - [refactor] 所有session实现ISessionStat接口，用于计算、获取bitrate等流相关的信息
 - [refactor] 所有session实现ISessionURLContext接口，用于获取流url相关的信息

pkg/hls/muxer.go

@@ -91,9 +91,9 @@ func NewMuxer(streamName string, config *MuxerConfig, observer MuxerObserver) *M
 		playlistFilenameBak:       playlistFilenameBak,
 		recordPlayListFilename:    recordPlaylistFilename,
 		recordPlayListFilenameBak: recordPlaylistFilenameBak,
-		config:                    config,
-		observer:                  observer,
-		frags:                     frags,
+		config:   config,
+		observer: observer,
+		frags:    frags,
 	}
 	streamer := NewStreamer(m)
 	m.streamer = streamer

pkg/rtsp/base_in_session.go

@@ -96,7 +96,7 @@ func (s *BaseInSession) InitWithSDP(rawSDP []byte, sdpLogicCtx sdp.LogicContext)
 	s.audioRRProducer = rtprtcp.NewRRProducer(s.sdpLogicCtx.AudioClockRate)
 	s.videoRRProducer = rtprtcp.NewRRProducer(s.sdpLogicCtx.VideoClockRate)
 
-	if s.sdpLogicCtx.HasAudio && s.sdpLogicCtx.HasVideo {
+	if isSupportType(s.sdpLogicCtx.AudioPayloadType) && isSupportType(s.sdpLogicCtx.VideoPayloadType) {
 		s.avPacketQueue = NewAVPacketQueue(s.onAVPacket)
 	}