本章将带你详细了解Mediasoup是如何设计的，它又是如何达到高可用，可扩展的，性能是如何优化的，本章你将不仅领略到高性能流媒体服务器的设计精髓， 知道好的架构设计是如何的优美，也会知道所有高性能服务器的实现都是每个细微处的不断打磨才造就出来的。…

15-1 mediasoup库的架构讲解

Worker：节点，进程
Router：相当于房间，路由器
Producer：音频和视频的生产者，一个视频会议，参加的每个人都是音频和视频的生产者，音频一个Producer，视频一个Producer。
Consumer：和Producer对应。
Transport：传输Producer和Consumer

Worker之间，可以通过PipeTransport来通信。

DataChannel使用STCP协议，可以传输文本。

15-2 MediasoupJS的作用

下面是mediasoup-demo/server/node_modules/mediasoup/lib/ 下面的js文件介绍。

AudioLevelObserver.js :检测声音大小
Channel.js 跟C++部分进行信令通信
Consumer.js 消费者，音频一个，视频也一个。
DataConsumer.js
DataProducer.js
DirectTransport.js
EnhancedEventEmitter.js： EventEmitter的一个封装，事件发射器
Logger.js ：日志
PayloadChannel.js
PipeTransport.js ： 每个进程Worker中连接Router之间的通信
PlainTransport.js ： 主要用于普通的非加密的RTP数据的传输
Producer.js ：视频或者音频的生产者
Router.js ：对应每个房间或者路由器
RtpObserver.js ：RTP观察者
RtpParameters.js
SctpParameters.js
SrtpParameters.js
Transport.js ：一个基类，PipeTransport和PlainTransport这些都继承它实现。
WebRtcTransport.js ：浏览器使用的传输
Worker.js ：进程
errors.js ：错误信息
index.js ：Mediasoup的库，上层引入Mediasoup最先导入的库，也为库的索引
ortc.js ：以对象的形式存储帧率码率等相关信息，和sdp对比。
scalabilityModes.js
supportedRtpCapabilities.js ：支持rtp的能力
types.js
utils.js：配置


可以看到，几乎所有的类都继承EnhancedEventEmitter

https://blog.csdn.net/Frederick_Fung/article/details/106919882

15-3 WebRTC中的C++类关系图

RembServer和RembClient用于带宽评估。
[

](https://blog.csdn.net/gjy_it/category_9483663.html)
https://blog.csdn.net/gjy_it/article/details/104474095

15-4 Mediasoup启动详解

server.js调用runMediasoupWorkers()函数中，每创建一个Worker
mediasoup.createWorker,都会调用mediasoup-demo/server/node_modules/worker/src/main.cpp里面去。

main.cpp

#define MS_CLASS "mediasoup-worker"
// #define MS_LOG_DEV_LEVEL 3
#include "MediaSoupErrors.hpp"
#include "lib.hpp"
#include <cstdlib> // std::_Exit(), std::genenv()
#include <string>
static constexpr int ConsumerChannelFd{ 3 };
static constexpr int ProducerChannelFd{ 4 };
static constexpr int PayloadConsumerChannelFd{ 5 };
static constexpr int PayloadProducerChannelFd{ 6 };
int main(int argc, char* argv[])
{
    // Ensure we are called by our Node library.
    if (!std::getenv("MEDIASOUP_VERSION"))
    {
        MS_ERROR_STD("you don't seem to be my real father!");
        std::_Exit(EXIT_FAILURE);
    }
    std::string version = std::getenv("MEDIASOUP_VERSION");
//mediasoup\worker\src\lib.cpp
    auto statusCode = run_worker(
      argc,
      argv,
      version.c_str(),
      ConsumerChannelFd,
      ProducerChannelFd,
      PayloadConsumerChannelFd,
      PayloadProducerChannelFd);
    switch (statusCode)
    {
        case 0:
            std::_Exit(EXIT_SUCCESS);
        case 1:
            std::_Exit(EXIT_FAILURE);
        case 42:
            std::_Exit(42);
    }
}

Worker进程所在目录。
mediasoup-demo/server/node_modules/mediasoup/worker/out/Release