createEndpoint
当我们打开index.js 后，看到的第一个重要的 API就是createEndpoint函数了。我们就以这个 API为开头，一步一步的分析一下medooze的运行机制。
createEndpoint函数定义在 medooze-media-server 库中的 lib 目录下的 MediaServer.js 中。代码如下：
/**
* Create a new endpoint object
* @memberof MediaServer
* @param {String} ip - External IP address of server, to be used when announcing the local ICE candidate
* @returns {Endpoint} The new created endpoing
*/
MediaServer.createEndpoint = function(ip)
{
//Cretate new rtp endpoint
return new Endpoint(ip);
};
它的作用是公布 ICE 本地候选者，当做一个终端。
顺着这个函数我们继续往下看，在该函数中会创建一个 Endpoint 对象。
Endpoint
在 medooze-media-server 库中的 lib 目录下的 Endpoint.js 文件是 Endpoint 的类文件。该类的作用如下：
/**
* An endpoint represent an UDP server socket.
* The endpoint will process STUN requests in order to be able to associate the remote ip:port with the registered transport and forward any further data comming from that transport.
* Being a server it is ICE-lite.
*/
/**
*endpoint 表示UDP服务器套接字。
*endpoint 将处理STUN请求，以便能够将远程ip:port与注册的传输相关联，并转发来自该传输的任何进一步的通信数据。
*作为一个服务器，它是轻量级的ICE。
*/
在创建 Endpoint 对象时，会调用它的构造函数。其代码如下：
constructor(ip)
{
//Store ip address of the endpoint
this.ip = ip;
//Create native endpoint
this.bundle = new Native.RTPBundleTransport();
//Start it
this.bundle.Init();
//Store all transports
this.transports = new Set();
//Create candidate
this.candidate = new CandidateInfo("1", 1, "UDP", 33554431, ip, this.bundle.GetLocalPort(), "host");
//Get fingerprint (global at media server level currently)
this.fingerprint = Native.MediaServer.GetFingerprint().toString();
}
通过上面的代码可以看到 Endpoint 包括以下几个成员：
- ip : STUN 服务器IP地址。
- bundle：native层的Endpoint。
- transports: 这是一个集合，用于存放所有用到的传输协议
- candidate: ICE 候选者
- fingerprint: 指纹，用于网络安全。
接下来，我们分别看一下 Native.RTPBundleTransport 和 CandidateInfo。
RTPBundleTransport
RTPBundleTransport 类定义在 media-server 中的 include/RTPBundleTransport.h文件中。该类的构造函数如下：
RTPBundleTransport::RTPBundleTransport()
{
//Init values
socket = FD_INVALID;
port = 0;
//No thread
setZeroThread(&thread);
running = false;
//Mutex
pthread_mutex_init(&mutex,0);
pthread_cond_init(&cond,0);
}
在 Endpoint 类的构函数中，首先创建了 RTPBundleTransport对象，然后又调用了该对象的 Init方法，其代码如下：
int RTPBundleTransport::Init()
{
int retries = 0;
sockaddr_in recAddr;
//Clear addr
memset(&recAddr,0,sizeof(struct sockaddr_in));
//Init ramdon
srand (time(NULL));
//Set family
recAddr.sin_family = AF_INET;
//Get two consecutive ramdom ports
while (retries++<100)
{
...
//Create new sockets
socket = ::socket(PF_INET,SOCK_DGRAM,0);
//Get random
port = (RTPTransport::GetMinPort()+(RTPTransport::GetMaxPort()-RTPTransport::GetMinPort())*double(rand()/double(RAND_MAX)));
//Make even
port &= 0xFFFFFFFE;
//Try to bind to port
recAddr.sin_port = htons(port);
//Bind the rtp socket
if(bind(socket,(struct sockaddr *)&recAddr,sizeof(struct sockaddr_in))!=0)
//Try again
continue;
...
Start();
//Done
Log("<RTPBundleTransport::Init()\n");
//Opened
return port;
}
//Error
Error("-RTPBundleTransport::Init() | too many failed attemps opening sockets\n");
//Failed
return 0;
}
通过上面的代码我们可以看到， 在Init函数中，主要做了两件事儿：
- 绑定端口号，打开sokcet服务。
- 通过 Start() 启动了一个新的线程。对于线程的启动与所做的事情我们将在下篇文章中再做介绍。
CandidateInfo
在另外一个称为 semantic-sdp-js的项目中的lib中可以找到 CandidateInfo 类的定义。其构造函数如下：
/**
* CanditateInfo constructor
* @constructor
* @alias CandidateInfo
* @param {String} foundation
* @param {Number} componentId
* @param {String} transport
* @param {Number} priority
* @param {String} address
* @param {Number} port
* @param {String} type
* @param {String} relAddr
* @param {String} relPort
*/
constructor(foundation, componentId, transport, priority, address, port, type, relAddr, relPort) {
this.foundation = foundation;
this.componentId = componentId;
this.transport = transport;
this.priority = priority;
this.address = address;
this.port = port;
this.type = type;
this.relAddr = relAddr;
this.relPort = relPort;
}
其代码非常简单，就是将传入的一些参数保存起来。
网友评论