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<Mat> matQueue = new ConcurrentQueue<Mat>();
        /// <summary>
        /// 播放
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        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();
        }

        /// <summary>
        /// 停止
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        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;
13. namespace Sdcb.FFmpegDemo
14. {
15.     public partial class Form1 : Form
16.     {
17.         public Form1()
18.         {
19.             InitializeComponent();
20.         }
22.         CancellationTokenSource cts;
24.         ConcurrentQueue<Mat> matQueue = new ConcurrentQueue<Mat>();
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();
35.             //string rtsp_url = "test_car_person_1080P.mp4";
36.             string rtsp_url = "rtsp://192.168.3.62/ch1";
38.             Task.Run(() => DecodeRTSP(rtsp_url, cts.Token));
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.         }
58.         void DecodeRTSP(string url, CancellationToken cancellationToken = default)
59.         {
60.             FormatContext fc = FormatContext.OpenInputUrl(url);
61.             fc.LoadStreamInfo();
62.             MediaStream videoStream = fc.GetVideoStream();
64.             CodecContext videoDecoder = new CodecContext(Codec.FindDecoderByName("h264"));
65.             videoDecoder.FillParameters(videoStream.Codecpar);
66.             videoDecoder.Open();
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;
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.         }
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.         }
103.         private void Form1_Load(object sender, EventArgs e)
104.         {
105.             Sdcb.FFmpeg.Utils.FFmpegLogger.LogWriter = (level, msg) => Console.WriteLine(msg);
106.         }
107.     }
109. }

复制代码

下载

源码下载

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。