如何搭建WebRTC信令服务器

时间  2020-05-05
标签 如何 搭建 webrtc 信令 服务器 繁體版
原文   原文链接
WebRTC 有一整套规范，如怎样使用它的接口、使用SDP进行媒体协商、经过ICE收集地址并进行连通性检测等等。除此以外，WebRTC还须要房间服务器将多端汇集到一块儿管理，以及信令服务器进行信令数据交换（如媒体描述信息SDP的交换，链接地址的交换等），但在WebRTC的规范中没有对这部份内容进行规定，因此须要由用户本身处理。
安装 Nodejs
下面咱们就来看看具体如何安装 Nodejs。
安装 Nodejs 很是的简单:
在Ubuntu系统下执行：
apt install nodejs
或在Mac 系统下执行：
brew install nodejs
经过上面的步骤咱们就将 Nodejs 安装好了。我这里安装的 Nodejs版本为： v8.10.0 。
安装NPM
除了安装 Nodejs 以外，咱们还要安装NPM(Node Package Manager），也就是 Nodejs 的包管理器。它就像Ubuntu下的 apt 或Mac 系统下的brew 命令相似，是专门用来管理各类依赖库的。
对于 Nodejs的安装包也是如此，NPM 就是至关于 Linux 下的 apt，它的出现大大提升了人们的工做效率。
NPM 的安装像安装 Nodejs 同样简单:
在Ubuntu下执行:
apt install npm
或在Mac下执行：
brew install npm
这次，咱们使用 Nodejs 下的  socket.io 6  库来实现 WebRTC 信令服务器。socket.io特别适合用来开发WebRTC的信令服务器，经过它来构建信令服务器特别的简单，这主要是由于它内置了 房间  的概念。
socket.io.jpg 2308×895 139 KB
上图是  socket.io 6  与 Nodejs配合使用的逻辑关系图， 其逻辑很是简单。 socket.io 6  分为服务端和客户端两部分 。服务端由 Nodejs加载后侦听某个服务端口，客户端要想与服务端相连，首先要加载  socket.io 6  的客户端库，而后调用  io.connect(); 就与服务端连上了。
须要特别强调的是  socket.io 6  消息的发送与接收。 socket.io 6  有不少种发送消息的方式 ，其中最多见的有下面几种，是咱们必需要撑握的：
  • 给本次链接发消息
socket.emit()
  • 给某个房间内全部人发消息
io.in(room).emit()
  • 除本链接外，给某个房间内全部人发消息
socket.to(room).emit()
  • 除本链接外，给因此人发消息
socket.broadcast.emit()
消息又该如何接收呢？
  • 发送 command 命令
S : socket.emit('cmd’); C : socket.on('cmd',function(){...});
  • 送了一个 command 命令，带 data 数据
S: socket.emit( 'action' , data); C: socket.on( 'action' , function (data){...});
  • 发送了command命令，还有两个数据
S: socket.emit(action,arg1,arg2); C: socket.on( 'action' , function (arg1,arg2){...});
有了以上这些知识，咱们就能够实现信令数据通信了。
搭建信令服务器
接下来咱们来看一下，如何经过 Nodejs下的  socket.io 6  来构建的一个服务器：
这是客户端代码，也就是在浏览器里执行的代码。index.html：
<!DOCTYPE html> < html > < head > < title > WebRTC client </ title > </ head > < body > < script src= '/socket.io/socket.io.js' ></ script > < script src= 'js/client.js' ></ script > </ body > </ html >
该代码十分简单，就是在body里引入了两段 JS 代码。其中，socket.io.js 是用来与服务端创建 socket 链接的。client.js 的做用是作一些业务逻辑，并最终经过 socket 与服务端通信。
首先，在 server.js 目录下建立  js  子目录，而后在 js目录下生成 client.js。
下面是client.js的代码：
var isInitiator; room = prompt( 'Enter room name:' ); // 弹出一个输入窗口 const socket = io.connect(); // 与服务端创建socket链接 if (room !== '' ) { // 若是房间不空，则发送 "create or join" 消息 console .log( 'Joining room ' + room); socket.emit( 'create or join' , room); } socket.on( 'full' , (room) => { // 若是从服务端收到 "full" 消息 console .log( 'Room ' + room + ' is full' ); }); socket.on( 'empty' , (room) => { // 若是从服务端收到 "empty" 消息 isInitiator = true; console .log( 'Room ' + room + ' is empty' ); }); socket.on( 'join' , (room) => { // 若是从服务端收到 “join " 消息 console.log('Making request to join room ' + room); console.log('You are the initiator!'); }); socket.on('log', (array) => { console.log.apply(console, array); });
在该代码中：
  • 首先弹出一个输入框，要求用户写入要加入的房间。
  • 而后，经过 io.connect() 创建与服务端的链接，
  • 根据socket返回的消息作不一样的处理：
  • 当收到房间满"full"时的状况;
  • 当收到房间空“empty"时的状况；
  • 当收到加入“join"时的状况；
以上是客户端（也就是在浏览器）中执行的代码。下面咱们来看一下服务端的处理逻辑：
服务器端代码，server.js：
const static = require ( 'node-static' ); const http = require ( 'http' ); const file = new ( static .Server)(); const app = http.createServer( function (req, res) { file.serve(req, res); }).listen( 2013 ); const io = require ( 'socket.io' ).listen(app); //侦听 2013 io.sockets.on( 'connection' , (socket) => { // convenience function to log server messages to the client function log (){ const array = [ '>>> Message from server: ' ]; for ( var i = 0 ; i < arguments.length; i++) { array .push(arguments[i]); } socket.emit( 'log' , array ); } socket.on( 'message' , (message) => { //收到message时，进行广播 log( 'Got message:' , message); // for a real app, would be room only (not broadcast) socket.broadcast.emit( 'message' , message); //在真实的应用中，应该只在房间内广播 }); socket.on( 'create or join' , (room) => { //收到 “create or join” 消息 var clientsInRoom = io.sockets.adapter.rooms[room]; var numClients = clientsInRoom ? Object.keys(clientsInRoom.sockets).length : 0 ; //房间里的人数 log( 'Room ' + room + ' has ' + numClients + ' client(s)' ); log( 'Request to create or join room ' + room); if (numClients === 0 ){ //若是房间里没人 socket.join(room); socket.emit( 'created' , room); //发送 "created" 消息 } else if (numClients === 1 ) { //若是房间里有一我的 io.sockets.in(room).emit( 'join' , room); socket.join(room); socket.emit( 'joined' , room); //发送 “joined”消息 } else { // max two clients socket.emit( 'full' , room); //发送 "full" 消息 } socket.emit( 'emit(): client ' + socket.id + ' joined room ' + room); socket.broadcast.emit( 'broadcast(): client ' + socket.id + ' joined room ' + room); }); });
在服务端引入了  node-static  库，使服务器具备发布静态文件的功能。服务器具备此功能后，当客户端（浏览器）向服务端发起请求时，服务器经过该模块得到客户端（浏览器）运行的代码，也就是上我面咱们讲到的 index.html 和 client.js 并下发给客户端（浏览器）。
服务端侦听 2013 这个端口，对不一样的消息作相应的处理：
  • 服务器收到 message 消息时，它会直接进行广播，全部链接到该服务器的客户端都会收收广播的消息。
  • 服务端收到 “create or join”消息时，它会对房间里有人数进行统计，若是房间里没有人，则发送"created" 消息；若是房间里有一我的，发送"join"消息和“joined"消息；若是超过两我的，发送"full"消息。
要运行该程序，须要使用 NPM 安装  socket.io 6  和  node-static 1 ，安装方法以下：
进入到  server.js  所在的目录，而后执行下面的命令。
npm install socket.io npm install node- static
启动服务器并测试
经过上面的步骤咱们就使用  socket.io 6  构建好一个服务器，如今能够经过下面的命令将服务启动起来了：
node server.js
若是你是在本机上搭建的服务，则能够在浏览器中输入 localhost:2013 ，而后新建一个tab 在里边再次输入localhost:2013 。此时，打开控制台看看发生了什么?
小结
以上我向你们介绍了 Nodejs 的工做原理、Nodejs的安装与布署，以及如何使用  要sokcet.io 1  构建 WebRTC 信令消息服务器。 socket.io 6  因为有房间的概念因此与WebRTC很是匹配，用它开发WebRTC信令服务器很是方便。
IM和视频聊天的，能够参考下这个 https://github.com/starrtc/starrtc-android-demo
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程