当前位置：首页 > 科技 > 软件

WebRTC.Net库开发进阶，教你实现屏幕共享和多路复用！

来源：责编：时间：2023-08-05 11:46:09 3792观看

导读WebRTC.Net库：让你的应用更亲民友好，实现视频通话无痛接入！除了基本用法外，还有一些进阶用法可以更好地利用该库。自定义 STUN/TURN 服务器配置WebRTC.Net 默认使用 Google 的 STUN 服务器和 Coturn 的 TURN 服务器。如

WebRTC.Net库：让你的应用更亲民友好，实现视频通话无痛接入！除了基本用法外，还有一些进阶用法可以更好地利用该库。

自定义 STUN/TURN 服务器配置

WebRTC.Net 默认使用 Google 的 STUN 服务器和 Coturn 的 TURN 服务器。如果你需要使用其他 STUN/TURN 服务器，则可以在初始化 PeerConnectionFactory 和 PeerConnection 时设置自定义配置。

例如，以下代码设置了使用 coturn 服务器的 PeerConnectionFactory：

var config = new PeerConnectionConfiguration{   IceServers = new List<IceServer>   {      new IceServer{ Urls = new[] { "stun:stun.l.google.com:19302" }},      new IceServer{ Urls = new[] { "turn:my-turn-server.com" }, Username="myusername", Credential="mypassword" }   }};var factory = new PeerConnectionFactory(config);

在不同线程中创建和使用 PeerConnectionFactory 和 PeerConnection 对象：

WebRTC.Net 库本质上是基于线程的，因此它的对象通常在单独的线程中创建和使用。这样可以避免在主线程中对 UI 线程造成大量负担。

以下代码在后台线程中创建并使用 PeerConnection 对象：

Task.Run(() =>{   var config = new PeerConnectionConfiguration { IceServers = new List<IceServer> { new IceServer { Urls = new[] { "stun:stun.l.google.com:19302" } } } };   var factory = new PeerConnectionFactory(config);   var pc = factory.CreatePeerConnection(config);      // 在这里使用 PeerConnection 对象，不会阻塞主线程}).Wait();

选择视频和音频设备

在创建 PeerConnectionFactory 对象时，可以设置 defaultAudioDevice 和 defaultVideoDevice 参数以选择默认的音频和视频设备。

例如，以下如何通过设备名称选择视频和音频设备：

var config = new PeerConnectionConfiguration{   IceServers = new List<IceServer> { new IceServer { Urls = new[] { "stun:stun.l.google.com:19302" } } },   DefaultVideoDevice = VideoCaptureDevice.GetDevices().FirstOrDefault(x => x.Name == "MyCameraName"),   DefaultAudioDevice = AudioCaptureDevice.GetDevices().FirstOrDefault(x => x.Name == "MyMicrophoneName")};var factory = new PeerConnectionFactory(config);

实现数据通道

WebRTC.Net 库不仅支持音视频传输，还支持实现数据通道（DataChannel）。使用数据通道，应用程序可以在客户端之间传输任意类型的数据，例如聊天消息、游戏状态等。

以下代码如何创建数据通道：

// 创建 PeerConnection 对象var config = new PeerConnectionConfiguration { IceServers = new List<IceServer> { new IceServer { Urls = new[] { "stun:stun.l.google.com:19302" } } } };var factory = new PeerConnectionFactory(config);var pc = factory.CreatePeerConnection(config);// 创建数据通道var dcConfig = new DataChannelInit { Ordered = true };var dc = pc.CreateDataChannel("mydatachannel", dcConfig);// 监听数据通道事件dc.MessageReceived += (sender, e) =>{   // 处理接收到的数据};

实现屏幕共享

除了音视频传输和数据通道，WebRTC.Net 还支持屏幕共享。这意味着应用程序可以捕获屏幕上的内容并将其共享给其他客户端。

以下是使用 WinForm 技术栈和 WebRTC.Net 库实现桌面共享的示例代码。

using System;using System.Drawing;using System.Threading.Tasks;using System.Windows.Forms;using Windows.Graphics.Capture;using Windows.Graphics.DirectX.Direct3D11;using Microsoft.Toolkit.Win32.UI.Controls.Interop.WinRT;using Org.WebRtc;namespace DesktopStreaming{    public partial class MainForm : Form    {        private PeerConnection _peerConnection;        private DataChannel _dataChannel;        private Direct3D11CaptureFramePool _framePool;        private GraphicsCaptureSession _session;        private VideoTrack _videoTrack;        public MainForm()        {            InitializeComponent();            // 初始化 WebRTC            WebRTC.Initialize(new WebRTCInitializationOptions { EnableAudioBufferLog = false });            // 创建 PeerConnectionFactory 对象            var config = new PeerConnectionConfiguration { IceServers = new[] { new IceServer { Urls = new[] { "stun:stun.l.google.com:19302" } } } };            var factory = new PeerConnectionFactory(config);            // 创建 PeerConnection 对象            _peerConnection = factory.CreatePeerConnection();            // 创建数据通道            _dataChannel = _peerConnection.CreateDataChannel("mychannel");            // 订阅数据通道的消息事件            _dataChannel.MessageReceived += (sender, args) =>            {                // 处理收到的消息            };            // 创建 Direct3D11CaptureFramePool 对象            var device = Direct3D11Helpers.CreateDevice();            var size = new Size(800, 600);            _framePool = Direct3D11CaptureFramePool.CreateFreeThreaded(                device,                Direct3DPixelFormat.B8G8R8A8UIntNormalized,                1,                size);            // 订阅 FrameArrived 事件            _framePool.FrameArrived += (sender, args) =>            {                // 获取最新的桌面帧                using var frame = sender.TryGetNextFrame();                if (frame == null) return;                // 将桌面帧转换为 RTCVideoFrame 对象                var videoFrame = new RTCVideoFrame(frame.ContentSize.Width, frame.ContentSize.Height, RTCVideoFrameType.RTCVideoFrameTypeI420);                videoFrame.ConvertFromArgb32(frame.Surface.Direct3D11Device, frame.Surface);                // 将 RTCVideoFrame 对象转换为 VideoTrack 对象并发送                if (_videoTrack != null)                    _videoTrack.PushFrame(videoFrame);            };            // 创建 GraphicsCaptureItem 对象            var item = ScreenCapture.GetDefault();            // 创建 GraphicsCaptureSession 对象            _session = _framePool.CreateCaptureSession(item);        }        private async void btnStart_Click(object sender, EventArgs e)        {            // 开始共享桌面            await _session.StartAsync();            // 创建视频轨道            _videoTrack = await PeerConnectionFactory.GetVideoTrackSourceAsync(_framePool);            // 添加视频轨道到 PeerConnection 对象            await _peerConnection.AddTrack(_videoTrack);            // 创建 Offer SDP 并设置本地描述符            var offerSdp = await _peerConnection.CreateOffer();            await _peerConnection.SetLocalDescription(offerSdp);            // 发送 Offer SDP 到远端            SendSdp(offerSdp);        }        private void SendSdp(RTCSessionDescription sdp)        {            // 将 SDP 转换为 JSON 格式并发送到远端            var json = Newtonsoft.Json.JsonConvert.SerializeObject(new { type = sdp.Type, sdp = sdp.Sdp });            _dataChannel.Send(json);        }        private async void MainForm_FormClosing(object sender, FormClosingEventArgs e)        {            // 关闭 PeerConnection 和 GraphicsCaptureSession 对象            await _peerConnection.CloseAsync();            _session.Dispose();        }    }}

上述代码中，我们使用了 ScreenCapture 类来获取默认的桌面捕获项目，然后创建了 GraphicsCaptureSession 对象来捕获桌面帧。我们还使用了
Direct3D11CaptureFramePool 类来创建一个 Direct3D 11 帧池，并订阅了 FrameArrived 事件以获取最新的桌面帧。在每次收到桌面帧时，我们将其转换为 RTCVideoFrame 对象，再将其发送到 WebRTC 连接中。通过这种方式，我们就实现了桌面共享的功能。

需要注意的是，由于 WebRTC 是基于 p2p 的实时通信协议，因此本示例代码中仅演示了如何将桌面共享的数据发送给远端客户端，而没有涉及如何在远端客户端上解析和显示收到的数据。

处理 ICE 连接状态

WebRTC.Net 使用 ICE（Interactive Connectivity Establishment）协议来建立和维护客户端之间的连接。ICE 协议涉及多个状态和事件，例如 gathering、connected、disconnected 等等。应用程序可以订阅 PeerConnection 对象上的各种事件来处理这些状态。

以下代码如何订阅 PeerConnection 对象上的连接状态：

// 创建 PeerConnection 对象var config = new PeerConnectionConfiguration { IceServers = new List<IceServer> { new IceServer { Urls = new[] { "stun:stun.l.google.com:19302" } } } };var factory = new PeerConnectionFactory(config);var pc = factory.CreatePeerConnection(config);// 订阅 PeerConnection 对象上的连接状态pc.IceStateChanged += (sender, iceState) =>{   if (iceState == IceConnectionState.Connected)   {      // 客户端已成功连接   }   else if (iceState == IceConnectionState.Disconnected)   {      // 客户端已断开连接   }};

实现多路复用

WebRTC.Net 支持实现多路复用（Multiplexing），这意味着应用程序可以在同一个数据通道上同时传输多种类型的数据，例如音频、视频、文件等。

下面是使用 WinForm 技术栈和 WebRTC.Net 库实现多路复用的示例代码。

Copy Codeusing System;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;using System.Windows.Forms;using Microsoft.Toolkit.Win32.UI.Controls.Interop.WinRT;using Org.WebRtc;namespace WebRTC_Multiplexing{    public partial class Form1 : Form    {        private PeerConnection _peerConnection;        private List<DataChannel> _dataChannels = new List<DataChannel>();        public Form1()        {            InitializeComponent();            // 初始化 WebRTC            WebRTC.Initialize(new WebRTCInitializationOptions { EnableAudioBufferLog = false });            // 创建 PeerConnectionFactory 对象            var config = new PeerConnectionConfiguration { IceServers = new[] { new IceServer { Urls = new[] { "stun:stun.l.google.com:19302" } } } };            var factory = new PeerConnectionFactory(config);            // 创建 PeerConnection 对象            _peerConnection = factory.CreatePeerConnection();            // 订阅 PeerConnection 的连接状态改变事件            _peerConnection.ConnectionStateChanged += (sender, args) =>            {                // 处理连接状态改变事件                BeginInvoke(new Action(() => txtOutput.AppendText($"连接状态：{args.NewState.ToString()}/r/n")));            };            // 订阅 PeerConnection 的数据通道回调事件            _peerConnection.DataChannelAdded += (sender, args) =>            {                // 处理数据通道回调事件                var dataChannel = args.Channel;                dataChannel.MessageReceived += DataChannel_MessageReceived;                _dataChannels.Add(dataChannel);                BeginInvoke(new Action(() => txtOutput.AppendText($"收到数据通道：{dataChannel.Label}/r/n")));            };        }        private async void btnCreateOffer_Click(object sender, EventArgs e)        {            // 创建 Offer SDP 并设置本地描述符            var offerSdp = await _peerConnection.CreateOffer();            await _peerConnection.SetLocalDescription(offerSdp);            // 发送 Offer SDP 到对端            SendSdp(offerSdp);        }        private void SendSdp(RTCSessionDescription sdp)        {            // 将 SDP 转换为 JSON 格式并发送到对端            var json = Newtonsoft.Json.JsonConvert.SerializeObject(new { type = sdp.Type, sdp = sdp.Sdp });            _dataChannels.ForEach(dc => dc.Send(json));        }        private async void DataChannel_MessageReceived(object sender, DataChannelMessageEventArgs e)        {            // 收到数据通道消息后将其转换为 RTCSessionDescription 对象            if (e.MessageType == DataMessageType.Text)            {                var text = e.Data;                var sdp = Newtonsoft.Json.JsonConvert.DeserializeObject<RTCSessionDescription>(text);                // 设置远端描述符并完成连接                await _peerConnection.SetRemoteDescription(sdp);                if (sdp.Type == RTCSessionDescriptionType.Offer) await _peerConnection.CreateAnswer();            }        }    }}

上述代码中，我们创建了一个 PeerConnectionFactory 对象和一个 PeerConnection 对象，用于建立 WebRTC 连接。我们还创建了一个 _dataChannels 列表来保存所有的数据通道对象，每当 PeerConnection 对象添加一个新的数据通道时，我们就将其添加到 _dataChannels 列表中。

在 btnCreateOffer_Click 事件处理方法中，我们创建了一个 Offer SDP 并设置本地描述符，然后将其发送到所有的数据通道对象中。当收到对端发送过来的 SDP 消息时，我们将其转换为 RTCSessionDescription 对象，并调用 SetRemoteDescription 方法设置远端描述符。如果收到来自对端的 Offer SDP，则执行 CreateAnswer 方法创建 Answer SDP 并将其发送回对端。

通过这种方式，我们就可以使用同一个 PeerConnection 对象来支持多路复用。每当需要发送数据时，只需要将数据发送到指定的数据通道对象即可。需要注意的是，在使用多路复用时，我们需要为不同的数据通道设置不同的标签（Label），以便在接收端识别不同的通道。

本文链接：http://www.28at.com/showinfo-26-147-0.htmlWebRTC.Net库开发进阶，教你实现屏幕共享和多路复用！

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：一个注解实现接口幂等，这样才优雅！

下一篇： Python异步IO编程的进程/线程通信实现

标签：

热门焦点

太卷！Redmi MAX 100英寸电视便宜了：12999元买Redmi史上最大屏

8月5日消息，从小米商城了解到，Redmi MAX 100英寸巨屏电视日前迎来官方优惠，到手价12999元，比发布价便宜了7000元，在大屏电视市场开卷。据了解，Redmi MAX 100
这款新兴工具平台，让你的电脑效率翻倍

随着信息技术的发展,我们获取信息的渠道越来越多,但是处理信息的效率却成为一个瓶颈。于是各种工具应运而生,都在争相解决我们的工作效率问题。今天我要给大家介绍一款效率
“又被陈思诚骗了”

作者｜张思齐出品｜众面（ID：ZhongMian_ZM）如今的国产悬疑电影，成了陈思诚的天下。最近大爆电影《消失的她》票房突破30亿断层夺魁暑期档，陈思诚再度风头无两。你可以说陈思诚的
年轻人的“职场羞耻感”，无处不在

作者：冯晓亭陶淘李欣张琳马舒叶来源：燃次元“人在职场，应该选择什么样的着装？”近日，在网络上，一个与着装相关的帖子引发关注，在该帖子里，一位在高级写字楼亚洲金
信通院：小米、华为等11家应用商店基本完成APP签名及验签工作

中国信通院表示，目前，小米、华为、OPPO、vivo、360手机助手、百度手机助手、应用宝、豌豆荚和努比亚等9家应用商店，以及抖音和快手2家新型应用分发平
华为Mate60标准版细节曝光：经典星环相机模组回归

这段时间以来，关于华为新旗舰的爆料日渐密集。据此前多方爆料，今年华为将开始恢复一年双旗舰战略，除上半年推出的P60系列外，往年下半年的Mate系列也将
OPPO K11样张首曝：千元机影像“卷”得真不错！

一直以来，OPPO K系列机型都保持着较为均衡的产品体验，历来都是2K价位的明星机型，去年推出的OPPO K10和OPPO K10 Pro两款机型凭借各自的出色配置，堪称有
英特尔Xe HPG游戏显卡：拥有512EU，单风扇版本

据10 月 30 日外媒 TheVerge 消息报道，英特尔 Xe HPG Arc Alchemist 的正面实被曝光，不仅拥有 512 EU 版显卡，还拥有 128EU 的单风扇版本。另外，这款显卡 PCB
“买真退假” 这种“羊毛”不能薅

□ 法治日报记者王春　　□ 本报通讯员胡佳丽　　2020年初，还在上大学的小东加入了一个大学生兼职QQ群。群主“七王”在群里介绍一些刷单赚