libuv

在内的一整套通信框架#xff0c;具有单线程、事件驱动和异步的典型特征#xff0c;是构建高性能

WebRTC

是一个跨平台的异步事件驱动库用于构建高性能和可扩展的网络应用程序。

mediasoup

libuv

在内的一整套通信框架具有单线程、事件驱动和异步的典型特征是构建高性能

WebRTC

this.#child.stdio[3],consumerSocket:

this.#pid,

进程对管道通信的封装看起来比较复杂涉及到多个类如下图所示。

由于这里面糅合了几个逻辑拆解以后会更好理解

libuv

ChannelSocekt::ListenerChannelSocket

4Worker

对象从名字上能看出这是一个“共享对象”通过传参的方式共享给各个对象本质上就是一个全局对象。

5Shared

ChannelNotifier。

ChannelMessageRegistor

用来管理管道消息处理器因为全局就一个

根据注册信息把管道消息分发给各个处理器。

ChannelNotifier

ChannelSocket

自己关注的消息自己先处理其他消息则根据“注册表”进行路由。

发送管道消息调用

libuv

UdpSocketHandle内部包含了一个数据监听对象用来接收

UDP

2PipeTransport、PlainTransport、WebRtcTransport

WebRtcServer

WebRtcServer::WebRtcServer(RTC::Shared*

shared,

flatbuffers::Vectorflatbuffers::OffsetTransport::ListenInfo*

listenInfos):

FBS::Transport::Protocol::UDP){RTC::UdpSocket*

udpSocket;//

RTC::UdpSocket(this,ip,listenInfo-portRange()-min(),listenInfo-portRange()-max(),flags,portRangeHash);}//

指定端口else

RTC::UdpSocket(this,ip,Settings::configuration.rtcMinPort,Settings::configuration.rtcMaxPort,flags,portRangeHash);}...}//

TCP

FBS::Transport::Protocol::TCP){RTC::TcpServer*

tcpServer;//

RTC::TcpServer(this,this,ip,listenInfo-portRange()-min(),listenInfo-portRange()-max(),flags,portRangeHash);}//

指定端口else

RTC::TcpServer(this,this,ip,Settings::configuration.rtcMinPort,Settings::configuration.rtcMaxPort,flags,portRangeHash);}...}}...

2.2.2.

WebRtcTransport::WebRtcTransport(...)

{...//

的转发列表this-webRtcTransportListener-OnWebRtcTransportCreated(this);...

Socket

PipeTransport::PipeTransport(RTC::Shared*

shared,const

FBS::PipeTransport::PipeTransportOptions*

options):

RTC::Transport::Transport(shared,

id,

RTC::UdpSocket(this,this-listenInfo.ip,this-listenInfo.portRange.min,this-listenInfo.portRange.max,this-listenInfo.flags,portRangeHash);}//

指定端口else

RTC::UdpSocket(this,this-listenInfo.ip,Settings::configuration.rtcMinPort,Settings::configuration.rtcMaxPort,this-listenInfo.flags,portRangeHash);}...

2.2.4.

的设计目的是为了使位于同一主机上或不同主机上的两个Router实例之间进行通信只支持

UDP

PipeTransport::PipeTransport(RTC::Shared*

shared,const

FBS::PipeTransport::PipeTransportOptions*

options):

RTC::Transport::Transport(shared,

id,

RTC::UdpSocket(this,this-listenInfo.ip,this-listenInfo.portRange.min,this-listenInfo.portRange.max,this-listenInfo.flags,portRangeHash);}else

0){this-udpSocket

this-listenInfo.flags);}else{uint64_t

portRangeHash{

RTC::UdpSocket(this,this-listenInfo.ip,Settings::configuration.rtcMinPort,Settings::configuration.rtcMaxPort,this-listenInfo.flags,portRangeHash);}...

2.3.

UdpSocketHandle::OnUvRecvUdpSocketHandle

再回调

UdpSocket::UserOnUdpDatagramReceived最终将消息回调给数据监听者

2.3.1.2.

UdpSocketHandle::onSendCallback*

cb)

uv_buf_init(reinterpret_castchar*(const_castuint8_t*(data)),

len);//

出错了可能是网络繁忙使用异步接口uv_udp_send发送else

(sent

UV_EAGAIN){MS_WARN_DEV(uv_udp_try_send()

failed,

作为自定义数据挂载到uv数据结构中sendData-req.data

拷贝待发送数据std::memcpy(sendData-store,

data,

uv_buf_init(reinterpret_castchar*(sendData-store),

len);//

static_castuv_udp_send_cb(onSend));if

(err

};UdpSocketHandle::onSendCallback*

cb{

static_castUdpSocketHandle::UvSendData*(req-data);auto*

handle

static_castUdpSocketHandle*(handle-data);const

auto*

(socket){socket-OnUvSend(status,

cb);}//

TcpServerHandle::OnUvConnection。

3TcpServerHandle

TcpServer::UserOnTcpConnectionAlloc。

4TcpServer

TcpServerHandle::AcceptTcpConnection

5TcpServerHandle

信号是进程间通信的一种机制也是操作系统用来通知进程有关系统事件或异常状况的重要手段。

信号可以由系统内核发送给进程也可以由一个进程发送给另一个进程。

在

Worker

(this-closed){return;}Close();break;}case

SIGTERM:{if

(this-closed){return;}Close();break;}default:{MS_WARN_DEV(received

non