|
|
|
@@ -22,7 +22,6 @@ namespace JT1078.Hls |
|
|
|
public readonly M3U8Option m3U8Option; |
|
|
|
ConcurrentDictionary<string, TsFileInfo> curTsFileInfoDic = new ConcurrentDictionary<string, TsFileInfo>();//当前文件信息 |
|
|
|
ConcurrentDictionary<string, Queue<TsFileInfo>> tsFileInfoQueueDic = new ConcurrentDictionary<string, Queue<TsFileInfo>>(); |
|
|
|
ConcurrentDictionary<string, ulong> TsFirst1078PackageDic = new ConcurrentDictionary<string, ulong>(); |
|
|
|
|
|
|
|
public M3U8FileManage(M3U8Option m3U8Option, TSEncoder tSEncoder) |
|
|
|
{ |
|
|
|
@@ -33,46 +32,51 @@ namespace JT1078.Hls |
|
|
|
/// 生成ts和m3u8文件 |
|
|
|
/// </summary> |
|
|
|
/// <param name="jt1078Package"></param> |
|
|
|
public void CreateTsData(JT1078Package jt1078Package) { |
|
|
|
string key = $"{jt1078Package.SIM}_{jt1078Package.LogicChannelNumber}"; |
|
|
|
public void CreateTsData(JT1078Package jt1078Package) |
|
|
|
{ |
|
|
|
string key = jt1078Package.GetKey(); |
|
|
|
string hlsFileDirectory = m3U8Option.HlsFileDirectory; |
|
|
|
string m3u8FileName = Path.Combine(hlsFileDirectory, m3U8Option.M3U8FileName); |
|
|
|
if (!File.Exists(m3u8FileName)) File.Create(m3u8FileName);//创建m3u8文件 |
|
|
|
|
|
|
|
var buff = TSArrayPool.Rent(jt1078Package.Bodies.Length + 1024); |
|
|
|
TSMessagePackWriter tSMessagePackWriter = new TSMessagePackWriter(buff); |
|
|
|
|
|
|
|
var curTsFileInfo = CreateTsFileInfo(key, jt1078Package); |
|
|
|
if (!curTsFileInfo.IsCreateTsFile) |
|
|
|
try |
|
|
|
{ |
|
|
|
var pes = tSEncoder.CreatePES(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pes); |
|
|
|
CreateTsFile(curTsFileInfo.FileName, tSMessagePackWriter.FlushAndGetArray()); |
|
|
|
|
|
|
|
curTsFileInfo.Duration = (jt1078Package.Timestamp - curTsFileInfo.TsFirst1078PackageTimeStamp) / 1000.0; |
|
|
|
//按设定的时间（默认为10秒）切分ts文件 |
|
|
|
if (curTsFileInfo.Duration > m3U8Option.TsFileMaxSecond) |
|
|
|
var curTsFileInfo = CreateTsFileInfo(key); |
|
|
|
if (!curTsFileInfo.IsCreateTsFile) |
|
|
|
{ |
|
|
|
var pes = tSEncoder.CreatePES(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pes); |
|
|
|
CreateTsFile(curTsFileInfo.FileName, tSMessagePackWriter.FlushAndGetArray()); |
|
|
|
curTsFileInfo.Duration = (jt1078Package.Timestamp - curTsFileInfo.TsFirst1078PackageTimeStamp) / 1000.0; |
|
|
|
//按设定的时间（默认为10秒）切分ts文件 |
|
|
|
if (curTsFileInfo.Duration > m3U8Option.TsFileMaxSecond) |
|
|
|
{ |
|
|
|
var tsFileInfoQueue = ManageTsFileInfo(key, curTsFileInfo); |
|
|
|
CreateM3U8File(curTsFileInfo, tsFileInfoQueue); |
|
|
|
var newTsFileInfo = new TsFileInfo { IsCreateTsFile = true, Duration = 0, TsFileSerialNo = ++curTsFileInfo.TsFileSerialNo }; |
|
|
|
curTsFileInfoDic.TryUpdate(key, newTsFileInfo, curTsFileInfo); |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
var tsFileInfoQueue = ManageTsFileInfo(key, curTsFileInfo); |
|
|
|
CreateM3U8File(key, curTsFileInfo, tsFileInfoQueue); |
|
|
|
var newTsFileInfo = new TsFileInfo { IsCreateTsFile = true, Duration = 0, TsFileSerialNo = ++curTsFileInfo.TsFileSerialNo }; |
|
|
|
curTsFileInfoDic.TryUpdate(key, newTsFileInfo, curTsFileInfo); |
|
|
|
curTsFileInfo.IsCreateTsFile = false; |
|
|
|
curTsFileInfo.TsFirst1078PackageTimeStamp = jt1078Package.Timestamp; |
|
|
|
curTsFileInfo.FileName = $"{curTsFileInfo.TsFileSerialNo}.ts"; |
|
|
|
var sdt = tSEncoder.CreateSDT(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(sdt); |
|
|
|
var pat = tSEncoder.CreatePAT(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pat); |
|
|
|
var pmt = tSEncoder.CreatePMT(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pmt); |
|
|
|
var pes = tSEncoder.CreatePES(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pes); |
|
|
|
CreateTsFile(curTsFileInfo.FileName, tSMessagePackWriter.FlushAndGetArray()); |
|
|
|
} |
|
|
|
} |
|
|
|
else { |
|
|
|
curTsFileInfo.IsCreateTsFile = false; |
|
|
|
curTsFileInfo.TsFirst1078PackageTimeStamp = jt1078Package.Timestamp; |
|
|
|
curTsFileInfo.FileName = $"{curTsFileInfo.TsFileSerialNo}.ts"; |
|
|
|
|
|
|
|
var sdt = tSEncoder.CreateSDT(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(sdt); |
|
|
|
var pat = tSEncoder.CreatePAT(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pat); |
|
|
|
var pmt = tSEncoder.CreatePMT(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pmt); |
|
|
|
var pes = tSEncoder.CreatePES(jt1078Package); |
|
|
|
tSMessagePackWriter.WriteArray(pes); |
|
|
|
CreateTsFile(curTsFileInfo.FileName, tSMessagePackWriter.FlushAndGetArray()); |
|
|
|
finally |
|
|
|
{ |
|
|
|
TSArrayPool.Return(buff); |
|
|
|
} |
|
|
|
} |
|
|
|
/// <summary> |
|
|
|
@@ -81,7 +85,8 @@ namespace JT1078.Hls |
|
|
|
/// <param name="key"></param> |
|
|
|
/// <param name="curTsFileInfo"></param> |
|
|
|
/// <returns></returns> |
|
|
|
private Queue<TsFileInfo> ManageTsFileInfo(string key, TsFileInfo curTsFileInfo) { |
|
|
|
private Queue<TsFileInfo> ManageTsFileInfo(string key, TsFileInfo curTsFileInfo) |
|
|
|
{ |
|
|
|
if (tsFileInfoQueueDic.TryGetValue(key, out var tsFileInfoQueue)) |
|
|
|
{ |
|
|
|
if (tsFileInfoQueue.Count >= m3U8Option.TsFileCapacity) |
|
|
|
@@ -103,12 +108,10 @@ namespace JT1078.Hls |
|
|
|
/// <summary> |
|
|
|
/// 创建M3U8文件 |
|
|
|
/// </summary> |
|
|
|
/// <param name="key"></param> |
|
|
|
/// <param name="curTsFileInfo"></param> |
|
|
|
private void CreateM3U8File(string key,TsFileInfo curTsFileInfo, Queue<TsFileInfo> tsFileInfoQueue) |
|
|
|
private void CreateM3U8File(TsFileInfo curTsFileInfo, Queue<TsFileInfo> tsFileInfoQueue) |
|
|
|
{ |
|
|
|
//ecode_slice_header error 以非关键帧开始生成的ts，通过ffplay播放会出现报错信息 |
|
|
|
string tsFileSerialNo = string.Empty; |
|
|
|
StringBuilder sb = new StringBuilder(); |
|
|
|
sb.AppendLine("#EXTM3U");//开始 |
|
|
|
sb.AppendLine("#EXT-X-VERSION:3");//版本号 |
|
|
|
@@ -123,9 +126,9 @@ namespace JT1078.Hls |
|
|
|
sb.AppendLine(tsFileInfo.FileName); |
|
|
|
} |
|
|
|
using (FileStream fs = new FileStream(m3U8Option.M3U8FileName, FileMode.Create, FileAccess.Write, FileShare.ReadWrite)) |
|
|
|
using (StreamWriter sw = new StreamWriter(fs)) |
|
|
|
{ |
|
|
|
sw.Write(sb.ToString()); |
|
|
|
var buffer = Encoding.UTF8.GetBytes(sb.ToString()); |
|
|
|
fs.Write(buffer,0, buffer.Length); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@@ -133,9 +136,9 @@ namespace JT1078.Hls |
|
|
|
/// 创建TS文件信息 |
|
|
|
/// </summary> |
|
|
|
/// <param name="key"></param> |
|
|
|
/// <param name="jt1078Package"></param> |
|
|
|
/// <returns></returns> |
|
|
|
private TsFileInfo CreateTsFileInfo(string key,JT1078Package jt1078Package) { |
|
|
|
private TsFileInfo CreateTsFileInfo(string key) |
|
|
|
{ |
|
|
|
if (!curTsFileInfoDic.TryGetValue(key, out var curTsFileInfo)) |
|
|
|
{ |
|
|
|
curTsFileInfo = new TsFileInfo(); |
|
|
|
@@ -157,41 +160,58 @@ namespace JT1078.Hls |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
///// <summary> |
|
|
|
///// 添加结束标识 |
|
|
|
///// 直播流用不到 |
|
|
|
///// </summary> |
|
|
|
///// <param name="filepath"></param> |
|
|
|
////public void AppendM3U8End() |
|
|
|
////{ |
|
|
|
//// StringBuilder sb = new StringBuilder(); |
|
|
|
//// sb.AppendLine("#EXT-X-ENDLIST"); //m3u8文件结束符 表示视频已经结束 有这个标志同时也说明当前流是一个非直播流 |
|
|
|
//// //#EXT-X-PLAYLIST-TYPE:VOD/Live //VOD表示当前视频流不是一个直播流，而是点播流(也就是视频的全部ts文件已经生成) |
|
|
|
////} |
|
|
|
|
|
|
|
/// <summary> |
|
|
|
/// 添加结束标识 |
|
|
|
/// 直播流用不到 |
|
|
|
/// </summary> |
|
|
|
/// <param name="filepath"></param> |
|
|
|
//public void AppendM3U8End() |
|
|
|
//{ |
|
|
|
// StringBuilder sb = new StringBuilder(); |
|
|
|
// sb.AppendLine("#EXT-X-ENDLIST"); //m3u8文件结束符 表示视频已经结束 有这个标志同时也说明当前流是一个非直播流 |
|
|
|
// //#EXT-X-PLAYLIST-TYPE:VOD/Live //VOD表示当前视频流不是一个直播流，而是点播流(也就是视频的全部ts文件已经生成) |
|
|
|
//} |
|
|
|
} |
|
|
|
/// <summary> |
|
|
|
/// TS文件信息 |
|
|
|
/// </summary> |
|
|
|
public class TsFileInfo { |
|
|
|
/// <summary> |
|
|
|
/// ts文件名 |
|
|
|
/// </summary> |
|
|
|
public string FileName { get; set; } = "0.ts"; |
|
|
|
/// <summary> |
|
|
|
/// 持续时间 |
|
|
|
/// </summary> |
|
|
|
public double Duration { get; set; } = 0; |
|
|
|
/// <summary> |
|
|
|
/// 当前ts文件序号 |
|
|
|
/// </summary> |
|
|
|
public int TsFileSerialNo { get; set; } = 0; |
|
|
|
/// <summary> |
|
|
|
/// 是否创建ts文件 |
|
|
|
/// 停止观看直播时清零数据 |
|
|
|
/// </summary> |
|
|
|
public bool IsCreateTsFile { get; set; } = true; |
|
|
|
/// <param name="sim"></param> |
|
|
|
/// <param name="channelNo"></param> |
|
|
|
public void Clear(string sim,int channelNo) |
|
|
|
{ |
|
|
|
var key = $"{sim}_{channelNo}"; |
|
|
|
curTsFileInfoDic.TryRemove(key, out _); |
|
|
|
tsFileInfoQueueDic.TryRemove(key, out _); |
|
|
|
var directory = Path.Combine(m3U8Option.HlsFileDirectory, key); |
|
|
|
if (Directory.Exists(directory)) Directory.Delete(directory); |
|
|
|
} |
|
|
|
|
|
|
|
/// <summary> |
|
|
|
/// ts文件第一个jt1078包的时间戳 |
|
|
|
/// TS文件信息 |
|
|
|
/// </summary> |
|
|
|
public ulong TsFirst1078PackageTimeStamp { get; set; } = 0; |
|
|
|
internal class TsFileInfo |
|
|
|
{ |
|
|
|
/// <summary> |
|
|
|
/// ts文件名 |
|
|
|
/// </summary> |
|
|
|
public string FileName { get; set; } = "0.ts"; |
|
|
|
/// <summary> |
|
|
|
/// 持续时间 |
|
|
|
/// </summary> |
|
|
|
public double Duration { get; set; } = 0; |
|
|
|
/// <summary> |
|
|
|
/// 当前ts文件序号 |
|
|
|
/// </summary> |
|
|
|
public int TsFileSerialNo { get; set; } = 0; |
|
|
|
/// <summary> |
|
|
|
/// 是否创建ts文件 |
|
|
|
/// </summary> |
|
|
|
public bool IsCreateTsFile { get; set; } = true; |
|
|
|
/// <summary> |
|
|
|
/// ts文件第一个jt1078包的时间戳 |
|
|
|
/// </summary> |
|
|
|
public ulong TsFirst1078PackageTimeStamp { get; set; } = 0; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
SmallChi(Koike)
4 lat temu