快捷導(dǎo)航

詳解如何實(shí)現(xiàn)C#和Python間實(shí)時(shí)視頻數(shù)據(jù)交互

更新時(shí)間：2024年10月12日 09:53:26 作者：音視頻牛哥

我們?cè)谧鯮TSP|RTMP播放的時(shí)候,遇到好多開發(fā)者,他們的視覺算法大多運(yùn)行在python下,需要高效率的實(shí)現(xiàn)C#和Python的視頻數(shù)據(jù)交互,本文給大家總結(jié)了一些常用的方法,感興趣的小伙伴跟著小編一起來(lái)看看吧

方法一：通過(guò)HTTP請(qǐng)求傳輸視頻數(shù)據(jù)

服務(wù)器端（Python）

使用Flask或Django等Web框架創(chuàng)建一個(gè)HTTP服務(wù)器，通過(guò)API接口提供視頻數(shù)據(jù)。

from flask import Flask, send_file, request, jsonify  
import cv2  
import io  
import base64  
  
app = Flask(__name__)  
  
def get_video_frame():  
    # 讀取視頻幀  
    cap = cv2.VideoCapture('your_video.mp4')  
    ret, frame = cap.read()  
    cap.release()  
    if not ret:  
        return None, "No more frames"  
  
    # 轉(zhuǎn)換為RGB格式  
    frame_rgb = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)  
  
    # 轉(zhuǎn)換為字節(jié)流  
    ret, buffer = cv2.imencode('.jpg', frame_rgb)  
    if not ret:  
        return None, "Could not encode frame"  
  
    # 將字節(jié)流轉(zhuǎn)換為base64字符串  
    img_str = base64.b64encode(buffer).decode('utf-8')  
    return img_str, 200  
  
@app.route('/video_frame', methods=['GET'])  
def video_frame():  
    img_str, status_code = get_video_frame()  
    if img_str is None:  
        return jsonify({"error": status_code}), status_code  
    return jsonify({"image": img_str})  
  
if __name__ == '__main__':  
    app.run(debug=True)

客戶端（C#）

使用HttpClient從Python服務(wù)器獲取視頻幀，并將其顯示在PictureBox中。

using System;  
using System.Drawing;  
using System.Drawing.Imaging;  
using System.IO;  
using System.Net.Http;  
using System.Windows.Forms;  
  
public class VideoForm : Form  
{  
    private PictureBox pictureBox;  
    private HttpClient httpClient;  
  
    public VideoForm()  
    {  
        pictureBox = new PictureBox  
        {  
            Dock = DockStyle.Fill,  
            SizeMode = PictureBoxSizeMode.StretchImage  
        };  
        this.Controls.Add(pictureBox);  
  
        httpClient = new HttpClient();  
        Timer timer = new Timer();  
        timer.Interval = 100; // Adjust the interval as needed  
        timer.Tick += Timer_Tick;  
        timer.Start();  
    }  
  
    private async void Timer_Tick(object sender, EventArgs e)  
    {  
        try  
        {  
            HttpResponseMessage response = await httpClient.GetAsync("http://localhost:5000/video_frame");  
            response.EnsureSuccessStatusCode();  
            string jsonResponse = await response.Content.ReadAsStringAsync();  
            dynamic jsonData = Newtonsoft.Json.JsonConvert.DeserializeObject(jsonResponse);  
            string base64String = jsonData.image;  
            byte[] imageBytes = Convert.FromBase64String(base64String);  
            using (MemoryStream ms = new MemoryStream(imageBytes))  
            {  
                Image image = Image.FromStream(ms);  
                pictureBox.Image = image;  
            }  
        }  
        catch (Exception ex)  
        {  
            MessageBox.Show($"Error: {ex.Message}");  
        }  
    }  
  
    [STAThread]  
    public static void Main()  
    {  
        Application.EnableVisualStyles();  
        Application.Run(new VideoForm());  
    }  
}

方法二：通過(guò)ZeroMQ傳輸視頻數(shù)據(jù)

ZeroMQ是一種高性能的異步消息庫(kù)，適用于需要低延遲和高吞吐量的應(yīng)用。

服務(wù)器端（Python）

使用pyzmq庫(kù)發(fā)送視頻幀。

import zmq  
import cv2  
import numpy as np  
  
context = zmq.Context()  
socket = context.socket(zmq.PUB)  
socket.bind("tcp://*:5555")  
  
cap = cv2.VideoCapture('your_video.mp4')  
  
while True:  
    ret, frame = cap.read()  
    if not ret:  
        break  
    frame_rgb = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)  
    frame_bytes = frame_rgb.tobytes()  
    socket.send_string("FRAME", zmq.SNDMORE)  
    socket.send(frame_bytes, flags=0, copy=False)

客戶端（C#）

使用NetMQ庫(kù)接收視頻幀。

using System;  
using System.Drawing;  
using System.Drawing.Imaging;  
using System.Runtime.InteropServices;  
using System.Threading.Tasks;  
using System.Windows.Forms;  
using NetMQ;  
using NetMQ.Sockets;  
  
public class VideoForm : Form  
{  
    private PictureBox pictureBox;  
    private SubscriberSocket subscriber;  
  
    public VideoForm()  
    {  
        pictureBox = new PictureBox  
        {  
            Dock = DockStyle.Fill,  
            SizeMode = PictureBoxSizeMode.StretchImage  
        };  
        this.Controls.Add(pictureBox);  
  
        var address = "tcp://localhost:5555";  
        using (var context = NetMQContext.Create())  
        {  
            subscriber = context.CreateSubscriberSocket();  
            subscriber.Connect(address);  
            subscriber.Subscribe("FRAME");  
  
            Task.Run(() => ReceiveFramesAsync(subscriber));  
        }  
    }  
  
    private async Task ReceiveFramesAsync(SubscriberSocket subscriber)  
    {  
        while (true)  
        {  
            var topic = await subscriber.ReceiveFrameStringAsync();  
            var frameBytes = await subscriber.ReceiveFrameBytesAsync();  
  
            if (topic == "FRAME")  
            {  
                int width = 640; // Adjust based on your video resolution  
                int height = 480; // Adjust based on your video resolution  
                int stride = width * 3;  
                Bitmap bitmap = new Bitmap(width, height, PixelFormat.Format24bppRgb);  
                BitmapData bitmapData = bitmap.LockBits(new Rectangle(0, 0, width, height), ImageLockMode.WriteOnly, bitmap.PixelFormat);  
                Marshal.Copy(frameBytes, 0, bitmapData.Scan0, frameBytes.Length);  
                bitmap.UnlockBits(bitmapData);  
  
                pictureBox.Image = bitmap;  
            }  
        }  
    }  
  
    [STAThread]  
    public static void Main()  
    {  
        Application.EnableVisualStyles();  
        Application.Run(new VideoForm());  
    }  
}