C#开源实现MJPEG流传输

C#开源实现MJPEG流传输为什么需要MJPEG流传输在物联网、安防监控和远程桌面场景中MJPEGMotion JPEG是一种简单而实用的视频流格式。它将每一帧JPEG图片连续传输无需复杂的编码器兼容性极强——任何支持img标签的浏览器都能直接播放。相比H.264或VP9MJPEG实现成本低、延迟小非常适合教学或轻量级应用。本文将带你从零搭建一个C# MJPEG流服务器并逐步优化到生产级用法。### 基础概念HTTP响应与多部分内容MJPEG的核心是HTTP的multipart/x-mixed-replace响应。服务器不断向客户端发送JPEG帧每个帧以--boundary分隔。客户端如浏览器收到后自动刷新显示最新帧。我们先用最简代码实现单帧传输。#### 代码示例1最小化MJPEG服务器控制台应用csharpusing System;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;class MinimalMjpegServer{ static void Main() { TcpListener listener new TcpListener(IPAddress.Any, 8080); listener.Start(); Console.WriteLine(MJPEG服务器启动访问 http://localhost:8080); while (true) { TcpClient client listener.AcceptTcpClient(); ThreadPool.QueueUserWorkItem(HandleClient, client); } } static void HandleClient(object state) { var client (TcpClient)state; var stream client.GetStream(); // 1. 读取HTTP请求头简化版 byte[] buffer new byte[1024]; stream.Read(buffer, 0, buffer.Length); string request Encoding.ASCII.GetString(buffer); Console.WriteLine(收到请求: request.Split(\n)[0]); // 2. 发送HTTP响应头声明MJPEG流 string header HTTP/1.1 200 OK\r\n Content-Type: multipart/x-mixed-replace; boundaryframe\r\n Connection: close\r\n\r\n; byte[] headerBytes Encoding.ASCII.GetBytes(header); stream.Write(headerBytes, 0, headerBytes.Length); // 3. 用一张简易生成的JPEG图这里用1x1像素红色图 byte[] jpegData CreateRedJpeg(); // 4. 持续发送帧这里只发5帧演示 for (int i 0; i 5; i) { string boundary --frame\r\n Content-Type: image/jpeg\r\n Content-Length: jpegData.Length \r\n\r\n; byte[] boundaryBytes Encoding.ASCII.GetBytes(boundary); stream.Write(boundaryBytes, 0, boundaryBytes.Length); stream.Write(jpegData, 0, jpegData.Length); stream.Write(Encoding.ASCII.GetBytes(\r\n), 0, 2); Thread.Sleep(1000); // 每秒一帧 } client.Close(); } static byte[] CreateRedJpeg() { // 使用System.Drawing生成1x1红色JPEG需引用System.Drawing.Common using (var bmp new System.Drawing.Bitmap(1, 1)) { bmp.SetPixel(0, 0, System.Drawing.Color.Red); using (var ms new System.IO.MemoryStream()) { bmp.Save(ms, System.Drawing.Imaging.ImageFormat.Jpeg); return ms.ToArray(); } } }}运行效果浏览器访问后显示红色画面5秒。但此代码有严重缺陷不处理并发、不解析真实请求、不区分GET/POST。现在我们来升级。### 进阶实现完整异步服务器与摄像头采集生产级MJPEG需要处理多客户端、异步I/O、以及从摄像头抓帧。我们将使用HttpListener简化HTTP解析并引入OpenCV或Windows摄像头API获取实时画面。这里用模拟数据演示帧生成。#### 代码示例2异步MJPEG流服务器支持多客户端csharpusing System;using System.Net;using System.Text;using System.Threading.Tasks;using System.Drawing;using System.Drawing.Imaging;using System.IO;using System.Collections.Concurrent;class AdvancedMjpegServer{ // 用并发字典管理客户端输出流 static ConcurrentDictionaryStream, byte _clients new ConcurrentDictionaryStream, byte(); static async Task Main() { HttpListener listener new HttpListener(); listener.Prefixes.Add(http://:8080/); listener.Start(); Console.WriteLine(高级MJPEG服务器启动 http://localhost:8080/stream); // 启动后台帧广播任务 var broadcastTask Task.Run(BroadcastFrames); while (true) { var context await listener.GetContextAsync(); _ HandleRequest(context); // 异步处理不阻塞 } } static async Task HandleRequest(HttpListenerContext context) { if (context.Request.Url.AbsolutePath /stream) { // 设置MJPEG响应头 context.Response.ContentType multipart/x-mixed-replace; boundaryframe; context.Response.StatusCode 200; context.Response.AddHeader(Cache-Control, no-cache); var stream context.Response.OutputStream; _clients.TryAdd(stream, 0); // 保持连接直到客户端断开 while (true) { try { await Task.Delay(Timeout.Infinite); } catch (Exception) { _clients.TryRemove(stream, out _); stream.Close(); break; } } } else { context.Response.StatusCode 404; context.Response.Close(); } } static async Task BroadcastFrames() { int frameIndex 0; while (true) { // 生成模拟帧这里用时间戳动态生成JPEG byte[] jpeg GenerateFrame(frameIndex); foreach (var client in _clients.Keys) { try { string boundary --frame\r\nContent-Type: image/jpeg\r\nContent-Length: jpeg.Length \r\n\r\n; byte[] header Encoding.ASCII.GetBytes(boundary); await client.WriteAsync(header, 0, header.Length); await client.WriteAsync(jpeg, 0, jpeg.Length); await client.WriteAsync(Encoding.ASCII.GetBytes(\r\n), 0, 2); await client.FlushAsync(); } catch (Exception) { // 客户端断开移除 _clients.TryRemove(client, out _); } } await Task.Delay(100); // 10FPS } } static byte[] GenerateFrame(int index) { // 创建带文字的动态图片模拟摄像头画面 using (var bmp new Bitmap(320, 240)) { using (var g Graphics.FromImage(bmp)) { g.Clear(Color.DarkBlue); g.DrawString($Frame {index}, new Font(Arial, 20), Brushes.White, 50, 100); } using (var ms new MemoryStream()) { bmp.Save(ms, ImageFormat.Jpeg); return ms.ToArray(); } } }}关键改进- 使用HttpListener自动解析HTTP请求支持GET、路径匹配。- 异步I/Oasync/await不阻塞线程支持上千并发。- 后台任务统一广播帧所有客户端共享同一帧源节省CPU。### 生产级优化与开源生态#### 1. 性能瓶颈与解决方案-帧生成效率使用System.Drawing生成JPEG较慢建议改用ImageSharp跨平台或OpenCvSharp硬件加速。-网络拥塞为每个客户端添加缓冲队列慢客户端不应拖累整体。-帧率控制通过Stopwatch精确控制FPS避免Task.Delay误差。#### 2. 开源库推荐-MJPEG-Streamer.NET基于.NET 6的完整实现支持RTSP转MJPEG。-Camera.MAUI跨平台摄像头采集可直接输出MJPEG帧。-AForge.NET老牌视频处理库含MJPEG写入器。#### 3. 安全与认证- 添加Basic Auth检查Authorization头。- 限制IP白名单。- 使用HTTPS配置证书防止帧数据被窃听。### 完整代码整合从摄像头到Web这里提供一个可运行的真实案例使用OpenCvSharp调用USB摄像头通过异步服务器广播。由于篇幅仅展示核心片段csharp// 安装NuGet包: OpenCvSharp4, OpenCvSharp4.runtime.winusing OpenCvSharp;class CameraBroadcaster{ VideoCapture _capture; public CameraBroadcaster() { _capture new VideoCapture(0); // 打开第一个摄像头 _capture.FrameWidth 640; _capture.FrameHeight 480; } public byte[] GetFrame() { using (var frame new Mat()) { _capture.Read(frame); if (frame.Empty()) return null; // Mat转JPEG字节 Cv2.ImEncode(.jpg, frame, out byte[] jpeg); return jpeg; } }}然后在BroadcastFrames中调用GetFrame()即可。### 总结本文从HTTP协议基础出发用两个递进示例展示了C#实现MJPEG流传输的全过程先理解multipart/x-mixed-replace原理再构建异步并发服务器最后结合开源库扩展真实应用。MJPEG虽不如现代编码器高效但其简单性使其在嵌入式、教学和低延迟场景中仍有价值。建议读者进一步研究如何结合System.Threading.Channels实现背压控制或使用INotifyPropertyChanged整合到WPF界面。掌握这一技术你将能快速搭建自己的视频监控系统。