MemoryTS 输出的ts 文件 没有音频编码信息 #78

Activity

1. langhuihui commented on Mar 8, 2023

   

   langhuihui

   on Mar 8, 2023

   Member

   More actions

   func (ts *MemoryTs) WriteTo(w io.Writer) (int64, error) {
   	w.Write(mpegts.DefaultPATPacket)
   	w.Write(ts.PMT)
   	return ts.BLL.WriteTo(w)
   }

   注意写入的数据，PAT+PMT+PES
2. mars79668 commented on Mar 8, 2023

   

   mars79668

   on Mar 8, 2023

   Last edited by mars79668

   Author

   More actions

   最新版本 hls 插件不做任何改动测试 hls拉流发布，flv 订阅 可以预览播放， hls 订阅 无法播放，没有编码信息
   最新版本的engin 好像不稳定， flv 播放大约 2-3 分钟后就无法播放了，订阅收不到内容

   我看之前版本的代码，音频在 AudioDeConf AudioPacketToPES 有处理写入编码信息，视频 VideoPacketToPES 也有使用 Track.DecoderConfiguration 处理写入视频编码信息， memoryts 代码好像没有找到写入 音视频编码的信息
3. langhuihui commented on Mar 8, 2023

   

   langhuihui

   on Mar 8, 2023

   Member

   More actions

   hls拉流发布我抽空测一下，估计之前的改动影响到了这个
4. mars79668 commented on Mar 8, 2023

   

   mars79668

   on Mar 8, 2023

   Author

   More actions

   我提供的测试直播流，有我之前反馈的 ts 包乱序的问题，需要修正

   package mpegts
   
   import (
   	"bytes"
   	"errors"
   	"io"
   )
   
   type mpegTsStreamStatus struct {
   	pesPkt *MpegTsPESPacket
   	frames int
   }
   
   func (s *MpegTsStream) Feed(ts io.Reader) (err error) {
   	var reader bytes.Reader
   	var lr io.LimitedReader
   	lr.R = &reader
   	var tsHeader MpegTsHeader
   	tsData := make([]byte, TS_PACKET_SIZE)
   
   	streamsStatus := make(map[uint16]*mpegTsStreamStatus)
   
   	for {
   		_, err = io.ReadFull(ts, tsData)
   		if err == io.EOF {
   			// 文件结尾 把最后面的数据发出去
   			for _, ss := range streamsStatus {
   				if ss.pesPkt != nil {
   					s.PESChan <- ss.pesPkt
   					ss.pesPkt = nil
   				}
   			}
   			return nil
   		} else if err != nil {
   			return
   		}
   		reader.Reset(tsData)
   		lr.N = TS_PACKET_SIZE
   		if tsHeader, err = ReadTsHeader(&lr); err != nil {
   			return
   		}
   		if tsHeader.SyncByte != 0x47 {
   			return errors.New("sync byte error")
   		}
   		if tsHeader.Pid == PID_PAT {
   			if s.PAT, err = ReadPAT(&lr); err != nil {
   				return
   			}
   			continue
   		}
   		if len(s.PMT.Stream) == 0 {
   			for _, v := range s.PAT.Program {
   				if v.ProgramMapPID == tsHeader.Pid {
   					if s.PMT, err = ReadPMT(&lr); err != nil {
   						return
   					}
   				}
   				continue
   			}
   		}
   		for _, v := range s.PMT.Stream {
   			if v.ElementaryPID == tsHeader.Pid {
   				ss := streamsStatus[v.ElementaryPID]
   				if ss == nil {
   					ss = &mpegTsStreamStatus{}
   					streamsStatus[v.ElementaryPID] = ss
   				}
   				if tsHeader.PayloadUnitStartIndicator == 1 {
   					if ss.pesPkt != nil {
   						s.PESChan <- ss.pesPkt
   					}
   					ss.pesPkt = &MpegTsPESPacket{}
   					if ss.pesPkt.Header, err = ReadPESHeader(&lr); err != nil {
   						return
   					}
   				}
   				io.Copy(&ss.pesPkt.Payload, &lr)
   			}
   		}
   	}
   }