C#利用ffmpeg和opencv进行视频的解码播放

目录

说明

效果

项目 

代码

下载

说明

利用周杰大佬的开源项目 Sdcb.FFmpeg

项目地址：https://github.com/sdcb/Sdcb.FFmpeg/

效果

C#利用ffmpeg和opencv进行视频的解码播放

项目 

代码

using OpenCvSharp;
using Sdcb.FFmpeg.Codecs;
using Sdcb.FFmpeg.Formats;
using Sdcb.FFmpeg.Raw;
using Sdcb.FFmpeg.Toolboxs.Extensions;
using System;
using System.Collections.Concurrent;
using System.Runtime.InteropServices;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace Sdcb.FFmpegDemo
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        CancellationTokenSource cts;

        ConcurrentQueue matQueue = new ConcurrentQueue();

        ///


        /// 播放
        ///
        ///
        ///
        private void button1_Click(object sender, EventArgs e)
        {
            cts = new CancellationTokenSource();

            //string rtsp_url = "test_car_person_1080P.mp4";
            string rtsp_url = "rtsp://192.168.3.62/ch1";

            Task.Run(() => DecodeRTSP(rtsp_url, cts.Token));

            Task.Run(() =>
            {
                Mat mat = new Mat();
                while (true)
                {
                    if (cts.IsCancellationRequested) break;
                    //Console.WriteLine("matQueue.Count:" + matQueue.Count);
                    if (matQueue.TryDequeue(out mat))
                    {
                        Cv2.ImShow(rtsp_url, mat);
                        Cv2.WaitKey(1);
                        mat.Dispose();
                    }
                }
                Cv2.DestroyAllWindows();
            });
        }

        void DecodeRTSP(string url, CancellationToken cancellationToken = default)
        {
            FormatContext fc = FormatContext.OpenInputUrl(url);
            fc.LoadStreamInfo();
            MediaStream videoStream = fc.GetVideoStream();

            CodecContext videoDecoder = new CodecContext(Codec.FindDecoderByName("h264"));
            videoDecoder.FillParameters(videoStream.Codecpar);
            videoDecoder.Open();

            foreach (Sdcb.FFmpeg.Utils.Frame frame in fc
                .ReadPackets(videoStream.Index)
                .DecodePackets(videoDecoder)
                .ConvertVideoFrames(() => (videoDecoder.Width, videoDecoder.Height), AVPixelFormat.Bgr24))
            {
                if (cancellationToken.IsCancellationRequested) break;

                try
                {
                    byte[] data = new byte[frame.Linesize[0] * frame.Height];
                    Marshal.Copy(frame.Data._0, data, 0, data.Length);
                    OpenCvSharp.Mat mat = new OpenCvSharp.Mat(frame.Height, frame.Width, MatType.CV_8UC3, data); ;
                    matQueue.Enqueue(mat);
                }
                finally
                {
                    frame.Unref();
                }
            }
            cts.Cancel();
            videoDecoder.Dispose();
            fc.Dispose();
        }


        ///


        /// 停止
        ///
        ///
        ///
        private void button2_Click(object sender, EventArgs e)
        {
            cts.Cancel();
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            Sdcb.FFmpeg.Utils.FFmpegLogger.LogWriter = (level, msg) => Console.WriteLine(msg);
        }
    }

}

  1. using OpenCvSharp;
  2. using Sdcb.FFmpeg.Codecs;
  3. using Sdcb.FFmpeg.Formats;
  4. using Sdcb.FFmpeg.Raw;
  5. using Sdcb.FFmpeg.Toolboxs.Extensions;
  6. using System;
  7. using System.Collections.Concurrent;
  8. using System.Runtime.InteropServices;
  9. using System.Threading;
  10. using System.Threading.Tasks;
  11. using System.Windows.Forms;
  12.  
  13. namespace Sdcb.FFmpegDemo
  14. {
  15.     public partial class Form1 : Form
  16.     {
  17.         public Form1()
  18.         {
  19.             InitializeComponent();
  20.         }
  21.  
  22.         CancellationTokenSource cts;
  23.  
  24.         ConcurrentQueue<Mat> matQueue = new ConcurrentQueue<Mat>();
  25.  
  26.         /// <summary>
  27.         /// 播放
  28.         /// </summary>
  29.         /// <param name="sender"></param>
  30.         /// <param name="e"></param>
  31.         private void button1_Click(object sender, EventArgs e)
  32.         {
  33.             cts = new CancellationTokenSource();
  34.  
  35.             //string rtsp_url = "test_car_person_1080P.mp4";
  36.             string rtsp_url = "rtsp://192.168.3.62/ch1";
  37.  
  38.             Task.Run(() => DecodeRTSP(rtsp_url, cts.Token));
  39.  
  40.             Task.Run(() =>
  41.             {
  42.                 Mat mat = new Mat();
  43.                 while (true)
  44.                 {
  45.                     if (cts.IsCancellationRequested) break;
  46.                     //Console.WriteLine("matQueue.Count:" + matQueue.Count);
  47.                     if (matQueue.TryDequeue(out mat))
  48.                     {
  49.                         Cv2.ImShow(rtsp_url, mat);
  50.                         Cv2.WaitKey(1);
  51.                         mat.Dispose();
  52.                     }
  53.                 }
  54.                 Cv2.DestroyAllWindows();
  55.             });
  56.         }
  57.  
  58.         void DecodeRTSP(string url, CancellationToken cancellationToken = default)
  59.         {
  60.             FormatContext fc = FormatContext.OpenInputUrl(url);
  61.             fc.LoadStreamInfo();
  62.             MediaStream videoStream = fc.GetVideoStream();
  63.  
  64.             CodecContext videoDecoder = new CodecContext(Codec.FindDecoderByName("h264"));
  65.             videoDecoder.FillParameters(videoStream.Codecpar);
  66.             videoDecoder.Open();
  67.  
  68.             foreach (Sdcb.FFmpeg.Utils.Frame frame in fc
  69.                 .ReadPackets(videoStream.Index)
  70.                 .DecodePackets(videoDecoder)
  71.                 .ConvertVideoFrames(() => (videoDecoder.Width, videoDecoder.Height), AVPixelFormat.Bgr24))
  72.             {
  73.                 if (cancellationToken.IsCancellationRequested) break;
  74.  
  75.                 try
  76.                 {
  77.                     byte[] data = new byte[frame.Linesize[0] * frame.Height];
  78.                     Marshal.Copy(frame.Data._0, data, 0, data.Length);
  79.                     OpenCvSharp.Mat mat = new OpenCvSharp.Mat(frame.Height, frame.Width, MatType.CV_8UC3, data); ;
  80.                     matQueue.Enqueue(mat);
  81.                 }
  82.                 finally
  83.                 {
  84.                     frame.Unref();
  85.                 }
  86.             }
  87.             cts.Cancel();
  88.             videoDecoder.Dispose();
  89.             fc.Dispose();
  90.         }
  91.  
  92.  
  93.         /// <summary>
  94.         /// 停止
  95.         /// </summary>
  96.         /// <param name="sender"></param>
  97.         /// <param name="e"></param>
  98.         private void button2_Click(object sender, EventArgs e)
  99.         {
  100.             cts.Cancel();
  101.         }
  102.  
  103.         private void Form1_Load(object sender, EventArgs e)
  104.         {
  105.             Sdcb.FFmpeg.Utils.FFmpegLogger.LogWriter = (level, msg) => Console.WriteLine(msg);
  106.         }
  107.     }
  108.  
  109. }

下载

源码下载

天天代码码天天
微信公众号
.NET 人工智能实践
注：本文转载自blog.csdn.net的天天代码码天天的文章"https://lw112190.blog.csdn.net/article/details/141176560"。版权归原作者所有，此博客不拥有其著作权，亦不承担相应法律责任。如有侵权，请联系我们删除。
复制链接
相关推荐
发表评论

评论记录：

未查询到任何数据！