C#使用FFMPEG推流，而且獲取流保存在本地，隨時取媒體進行播放！

時間 2020-06-19

標籤 c# 使用 ffmpeg 而且獲取保存本地隨時媒體進行播放欄目 C# 简体版

原文原文鏈接

最近開發了基於C#的推流器一直不大理想，終於在不懈努力以後研究了一點成果，這邊作個筆記；本文着重在於講解下如何使用ffmpeg進行簡單的推流，看似簡單幾行代碼沒有官方的文檔很吃力。並獲取流的源代碼：以下→服務器

            #region RTMP推流(**已成功推流至服務器**)
            Network.Create()
                .WithSource(inputPath)//inputPath能夠改爲獲取設備的視頻流
                .WithDest("rtmp://192.168.61.128/live/livestream")//能夠根據本身的需求更新RTMP服務器地址
                .WithFilter(new X264Filter { ConstantQuantizer = 20 })
                .WithFilter(new ResizeFilter(Resolution.X720P))
                .Push();

            #endregion

            Network.Create()
                .WithSource("rtmp://192.168.61.128/live/livestream")//inputPath能夠改爲獲取設備的視頻流
                .WithDest(inputPath)//這個路徑能夠自由更改，若是是直播就不須要使用這個路徑，直接讀取流至播放器播放實時接收便可。
                .WithFilter(new X264Filter { ConstantQuantizer = 20 })
                .WithFilter(new ResizeFilter(Resolution.X720P))
                .Pull();

以上分別是推流和獲取流保存在本地的核心代碼。spa

1：首先創建服務器與客戶端的鏈接；3d

2：初始化服務器地址；code

3：初始化路徑；orm

4：視頻屬性設定；視頻

5：推/拉流操做；server

  /// <summary>
        /// 推流到RTMP服務器
        /// </summary>
        public void Push()
        {
            Validate();

            if (_destType != TargetType.Live)
            {
                throw new ApplicationException("當推流到RTMP服務器的時候，源類型必須是'RtmpType.Live'類型.");
            }

            //參數爲false的時候則爲推流
            var @params = GetParams(false);

            Processor.FFmpeg(@params);
        }

  /// <summary>
        /// 把流從RTMP服務器拉取--讀取視頻數據 ==pull a stream from rtmp server
        /// </summary>
        public void Pull()
        {
            Validate();

            if (!TestRtmpServer(_source, true))
                throw new ApplicationException("RTMP服務器發送錯誤.");

            if (_sourceType != TargetType.Live)
            {
                throw new ApplicationException("必須是RTMP服務器.");
            }
            //參數爲true的時候則爲讀取視頻流
            var @params = GetParams(false);

            Processor.FFmpeg(@params);
        }

 /// <summary>
        /// 檢測輸出輸入源以及過濾器
        /// </summary>
        private void Validate()
        {
            if (_sourceType == TargetType.Default)
                throw new ApplicationException("源錯誤.請輸入源！");

            if (_destType == TargetType.Default)
                throw new ApplicationException("dest錯誤.請輸入一個dest");

            var supportFilters = new[] { "Resize", "Segment", "X264", "AudioRate", "AudioBitrate" };

            if (_filters.Any(x => !supportFilters.Contains(x.Name)))
            {
                throw new ApplicationException(string.Format("過濾器不支持，過濾器只支持:{0} 類型",
                    supportFilters.Aggregate(string.Empty, (current, filter) => current + (filter + ",")).TrimEnd(new[] { ',' })));
            }
        }