BililiveRecorder/BililiveRecorder.FlvProcessor/FlvClipProcessor.cs

using NLog;
using System;
using System.Collections.Generic;
using System.IO;
using System.Text;

namespace BililiveRecorder.FlvProcessor
{
    public class FlvClipProcessor
    {
        private static readonly Logger logger = LogManager.GetCurrentClassLogger();

        public readonly FlvMetadata Header;
        public readonly List<FlvTag> HTags;
        public readonly List<FlvTag> Tags;
        private int target = -1;

        public Func<string> GetFileName;

        public FlvClipProcessor(FlvMetadata header, List<FlvTag> head, List<FlvTag> past, uint future)
        {
            Header = header;
            HTags = head;
            Tags = past;
            target = Tags[Tags.Count - 1].TimeStamp + (int)(future * FlvStreamProcessor.SEC_TO_MS);
            logger.Debug("Clip 创建 Tags.Count={0} Tags[0].TimeStamp={1} Tags[Tags.Count-1].TimeStamp={2} Tags里秒数={3}",
                Tags.Count, Tags[0].TimeStamp, Tags[Tags.Count - 1].TimeStamp, (Tags[Tags.Count - 1].TimeStamp - Tags[0].TimeStamp) / 1000d);
        }

        public void AddTag(FlvTag tag)
        {
            Tags.Add(tag);
            if (tag.TimeStamp >= target)
            {
                FinallizeFile();
            }
        }

        public void FinallizeFile()
        {
            try
            {
                string filepath = GetFileName();
                using (var fs = new FileStream(filepath, FileMode.CreateNew, FileAccess.ReadWrite))
                {
                    fs.Write(FlvStreamProcessor.FLV_HEADER_BYTES, 0, FlvStreamProcessor.FLV_HEADER_BYTES.Length);
                    fs.Write(new byte[] { 0, 0, 0, 0, }, 0, 4);

                    var offset = Tags[0].TimeStamp;
                    Tags.ForEach(tag => tag.TimeStamp -= offset);

                    Header.Meta["duration"] = Tags[Tags.Count - 1].TimeStamp / 1000.0;
                    Header.Meta["lasttimestamp"] = (double)Tags[Tags.Count - 1].TimeStamp;

                    var t = new FlvTag
                    {
                        TagType = TagType.DATA,
                        Data = Header.ToBytes()
                    };
                    t.WriteTo(fs);

                    HTags.ForEach(tag => tag.WriteTo(fs));
                    Tags.ForEach(tag => tag.WriteTo(fs));

                    logger.Info("剪辑已保存：{0}", Path.GetFileName(filepath));

                    fs.Close();
                }
                Tags.Clear();

                ClipFinalized?.Invoke(this, new ClipFinalizedArgs() { ClipProcessor = this });

            }
            catch (Exception ex)
            {
                logger.Error(ex, "保存剪辑文件时出错");
            }
        }

        public event ClipFinalizedEvent ClipFinalized;
    }
}