【MediaSoup---源码篇】（二）Router

概述

Router：路由对象，类似于房间的功能，保存了流之间的订阅关系，它接收 Producer 的数据并转发给订阅该 Producer 的 Consumer

Router继承了以下类：

RTC::Transport::Listener,RTC::RtpObserver::Listener,Channel::ChannelSocket::RequestHandler

RTC::Transport，它用于在mediasoup与客户端之间传输实时音视频数据

RTC::RtpObserver，是一个用于观察和处理实时传输协议（RTP）数据的接口

Channel::ChannelSocket，是用于响应与上层之间的传输

{   //router和房间是一对一的关系，一个router就表示一个房间。当router接收到房间内成员的RTP数据后，会转发给所有房间内的其它成员，或者其它worker。
	class Router : public RTC::Transport::Listener,
	               public RTC::RtpObserver::Listener,
	               public Channel::ChannelSocket::RequestHandler

创建Router房间的流程

在Worker层，首先上层会传入一个创建Router的信令,先到达Worker

inline void Worker::HandleRequest(Channel::ChannelRequest* request)

通过类型判断进入到创建房间中，其中在Worker中保存了roomid与Router实例的映射关系

        //创建房间
		case Channel::ChannelRequest::MethodId::WORKER_CREATE_ROUTER:
		{
			std::string routerId;//保存上层传递的roomid

			try
			{   
				//根据上层信令传入的roomid来创建底层的房间概念
				SetNewRouterIdFromData(request->data, routerId);
			}
			catch (const MediaSoupError& error)
			{
				MS_THROW_ERROR("%s [method:%s]", error.what(), request->method.c_str());
			}
            //创建好了Router与Router内处理各种消息的事宜
			auto* router = new RTC::Router(this->shared, routerId, this);
            //把routerId和router实例进行绑定
			this->mapRouters[routerId] = router;

			MS_DEBUG_DEV("Router created [routerId:%s]", routerId.c_str());

			request->Accept();

			break;
		}

Router构造函数

	/* Instance methods. */
    // 实例化`Router` 类并注册其消息处理程序的构造函数。
	Router::Router(RTC::Shared* shared, const std::string& id, Listener* listener)
	  : id(id), shared(shared), listener(listener)
	{
		MS_TRACE();
        /*
		这段代码是C++中的函数调用，用于将一个请求处理程序注册到一个通道消息注册器中。具体来说，这个函数调用的参数包括：
        -`this->id`：表示当前对象的id或标识符。
        -`channelRequestHandler`：指向请求处理函数的指针。
        -`payloadChannelRequestHandler`：指向负载请求处理函数的指针，此处为nullptr，表示没有负载请求处理函数。
        -`payloadChannelNotificationHandler`：指向负载通知处理函数的指针，此处为nullptr，表示没有负载通知处理函数。
        通过注册请求处理程序，可以在接收到相应的通道消息时，调用相应的处理函数对消息进行处理。这个函数调用是一种常见的使用C++进行事件驱动编程的方式。
		*/
		// NOTE: This may throw.
		this->shared->channelMessageRegistrator->RegisterHandler(
		  this->id,
		  /*channelRequestHandler*/ this,
		  /*payloadChannelRequestHandler*/ nullptr,
		  /*payloadChannelNotificationHandler*/ nullptr);
	}

对以上代码深度解析，首先在Router中持有了RTC::Shared 和 Listener。

RTC::Shared实际为Worker中的shared，Listener为Worker.

在构造函数中有一个重要的地方，我们来分析一下this->shared->channelMessageRegistrator->RegisterHandler，这句调用的意义在于，将当前的Router注册为响应通道消息的处理函数，如果通道发生了响应消息，就会自动转到该Router中进行相应处理。其中保存的方法为roomid与房间实例进行映射。

/将当前路由器实例注册为消息处理程序。
//`RegisterHandler()` 方法为 mediasoup 应用程序提供通用消息通信区域，并可将不同的消息分发给不同的路由器实例进行处理。
void ChannelMessageRegistrator::RegisterHandler(
  const std::string& id,//当前路由器实例的 ID，用于标识路由器实例
  Channel::ChannelSocket::RequestHandler* channelRequestHandler,//指向处理特定类型的通用请求的函数的指针
  PayloadChannel::PayloadChannelSocket::RequestHandler* payloadChannelRequestHandler,//通用请求和通知处理程序，这些处理程序用于处理特定类型的请求和通知消息
  PayloadChannel::PayloadChannelSocket::NotificationHandler* payloadChannelNotificationHandler)
{
	MS_TRACE();
    //channelRequestHandler理论上为创建Router时候的实例
	if (channelRequestHandler != nullptr)
	{
		if (this->mapChannelRequestHandlers.find(id) != this->mapChannelRequestHandlers.end())
		{
			MS_THROW_ERROR("Channel request handler with ID %s already exists", id.c_str());
		}
        //把id作为key,处理特定类型的通用请求的函数的指针作为value保存
		this->mapChannelRequestHandlers[id] = channelRequestHandler;
	}
    //理论说用transport的时候会进行绑定
	if (payloadChannelRequestHandler != nullptr)
	{   //如果存在旧的，就先删除
		if (this->mapPayloadChannelRequestHandlers.find(id) != this->mapPayloadChannelRequestHandlers.end())
		{
			if (channelRequestHandler != nullptr)
			{
				this->mapChannelRequestHandlers.erase(id);
			}

			MS_THROW_ERROR("PayloadChannel request handler with ID %s already exists", id.c_str());
		}
        //重新为本次分配
		this->mapPayloadChannelRequestHandlers[id] = payloadChannelRequestHandler;
	}

	if (payloadChannelNotificationHandler != nullptr)
	{
		if (
		  this->mapPayloadChannelNotificationHandlers.find(id) !=
		  this->mapPayloadChannelNotificationHandlers.end())
		{
			if (channelRequestHandler != nullptr)
			{
				this->mapChannelRequestHandlers.erase(id);
			}

			if (payloadChannelRequestHandler != nullptr)
			{
				this->mapPayloadChannelRequestHandlers.erase(id);
			}

			MS_THROW_ERROR("PayloadChannel notification handler with ID %s already exists", id.c_str());
		}

		this->mapPayloadChannelNotificationHandlers[id] = payloadChannelNotificationHandler;
	}
}

当发生通道消息时候会先通过ID查找对应Router实例

//通过路由器ID查找相应的处理函数
Channel::ChannelSocket::RequestHandler* ChannelMessageRegistrator::GetChannelRequestHandler(
  const std::string& id)
{
	MS_TRACE();

	auto it = this->mapChannelRequestHandlers.find(id);

	if (it != this->mapChannelRequestHandlers.end())
	{
		return it->second;
	}
	else
	{
		return nullptr;
	}
}

在Worker中触发上面所说的

		default:
		{
			try
			{   //事件驱动机制通过id来查找相对应的处理模块
				auto* handler =
				  this->shared->channelMessageRegistrator->GetChannelRequestHandler(request->handlerId);

				if (handler == nullptr)
				{
					MS_THROW_ERROR("Channel request handler with ID %s not found", request->handlerId.c_str());
				}
                //一般是Router::HandleRequest
				handler->HandleRequest(request);
			}
			catch (const MediaSoupTypeError& error)
			{
				MS_THROW_TYPE_ERROR("%s [method:%s]", error.what(), request->method.c_str());
			}
			catch (const MediaSoupError& error)
			{
				MS_THROW_ERROR("%s [method:%s]", error.what(), request->method.c_str());
			}

			break;
		}

经过上面的周转，又回来的Router中的处理

    //房间内部处理指令
	void Router::HandleRequest(Channel::ChannelRequest* request)