构建 WebRTC 一对一信令服务器

news2025/1/4 16:40:52

构建 WebRTC 一对一信令服务器

  • 构建 WebRTC 一对一信令服务器
    • 前言
    • 为什么选择 Nodejs？
    • Nodejs 的基本原理
    • 浏览器使用 Nodejs
    • 安装 Nodejs 和 NPM
    • socket.io
    • 信令服务器
    • 搭建信令服务器
      • 客户端
      • 服务端
      • 启动服务器并测试
    • 总结
    • 参考

构建 WebRTC 一对一信令服务器

前言

我们在学习 WebRTC 时，首先要把实验环境搭建好，这样我们就可以在上面做各种实验了。

对于 WebRTC 来说，它有一整套规范，如怎样使用它的接口、使用SDP进行媒体协商、通过ICE收集地址并进行连通性检测等等。除此之外，WebRTC还需要房间服务器将多端聚集到一起管理，以及信令服务器进行信令数据交换（如媒体描述信息SDP的交换，连接地址的交抽换等），但在WebRTC的规范中没有对这部分内容进行规定，所以需要由用户自己处理。

你可以根据自己的喜好选择服务器（如 Apache，Nginx 或 Nodejs），我今天将介绍如何使用 Nodejs 来搭建信令服务器。

为什么选择 Nodejs？

Nodejs 的最大优点即是可以使用 JS 语言开发服务器程序。

一方面 JS 语言的简单性可以方便开发出各种各样功能的服务端程序。更可贵的是 Nodejs 的生态链非常的完整，有各种各样的功能库。你可以根据自己的需要通过安装工具 NPM 快速的安装，这也使它也得到了广大开发者的喜欢。

当然，如果你想对Nodejs作能力拓展的话，还是要写C/C++库，然后加载到 Nodejs 中去。

Nodejs 的基本原理

在这里插入图片描述

Nodejs 的核心是 V8 引擎。通过该引擎，可以让 JavaScript 调用 C/C++方法或对象。相反，通过它也可能让 C/C++ 访问 JavaScript 方法和变量。

Nodejs 首先将 JavaScript 写好的应用程序交给 V8 引擎进行解析，V8理解应用程序的语义后，再调用 Nodejs 底层的 C/C++ API将服务启动起来。 所以 Nodejs 的强大就在于 JavaScript 可以直接调用 C/C++ 的方法，使其能力可以无限扩展。

浏览器使用 Nodejs

在这里插入图片描述

如上图所示，在我们使用 Nodejs之后实际存在了两个 V8 引擎。一个V8用于解析服务端的 JS 应用程序，它将服务启动起来。另一个 V8 是浏览器中的 V8 引擎，用于控制浏览器的行为。

对于使用 Nodejs 的新手来说，很容易出现思维混乱，因为在服务端至少要放两个 JS 脚本。其中一个是服务端程序，控制 Nodejs 的行为，它由 Nodejs 的V8引擎解析处理；另一个是客户端程序，它是要由浏览器请求后，下发到浏览器，由浏览器中的 V8 引擎进行解析处理。如果分不清这个，那麻烦就大了。

安装 Nodejs 和 NPM

下载地址：https://nodejs.org/en/download/，安装很简单，不赘述。

除了安装 Nodejs 之外，我们还要安装NPM（Node Package Manager），也就是 Nodejs 的包管理器。它就像Ubuntu下的 apt 或Mac 系统下的brew 命令类似，是专门用来管理各种依赖库的。

socket.io

此次，我们使用 Nodejs 下的 socket.io 库来实现 WebRTC 信令服务器。socket.io特别适合用来开发WebRTC的信令服务器，通过它来构建信令服务器特别的简单，这主要是因为它内置了房间的概念。

在这里插入图片描述

上图是 socket.io 与 Nodejs 配合使用的逻辑关系图， 其逻辑非常简单。socket.io 分为服务端和客户端两部分。服务端由 Nodejs加载后侦听某个服务端口，客户端要想与服务端相连，首先要加载 socket.io 的客户端库，然后调用 io.connect()就与服务端连上了。

需要特别强调的是 socket.io 消息的发送与接收。socket.io 有很多种发送消息的方式，其中最常见的有下面几种：

  • 给本次连接发消息：socket.emit()
  • 给某个房间内所有人发消息：io.in(room).emit()
  • 除本连接外，给某个房间内所有人发消息：socket.to(room).emit()
  • 除本连接外，给所有人发消息：socket.broadcast.emit()

消息又该如何接收呢？

发送 command 命令：

Server: socket.emit('cmd’);
Client: socket.on('cmd',function(){...});

发送了一个 command 命令，带 data 数据：

Server: socket.emit('action', data);
Client: socket.on('action',function(data){...});

发送了command命令，还有两个数据：

Server: socket.emit(action,arg1,arg2);
Client: socket.on('action',function(arg1,arg2){...});

有了以上这些知识，我们就可以实现信令数据通讯了。

信令服务器

var log4js = require('log4js');
var http = require('http');
var https = require('https');
var fs = require('fs');
var socketIo = require('socket.io');
 
var express = require('express');
var serveIndex = require('serve-index');
 
var USERCOUNT = 3;
 
log4js.configure({
    appenders: {
        file: {
            type: 'file',
            filename: 'app.log',
            layout: {
                type: 'pattern',
                pattern: '%r %p - %m',
            }
        }
    },
    categories: {
       default: {
          appenders: ['file'],
          level: 'debug'
       }
    }
});
 
var logger = log4js.getLogger();
 
var app = express();
app.use(serveIndex('./public'));
app.use(express.static('./public'));
 
 
 
//http server
var http_server = http.createServer(app);
http_server.listen(80, '0.0.0.0');
 
var options = {
    key : fs.readFileSync('./public/cert/server-key.pem'),
    cert: fs.readFileSync('./public/cert/server-cert.pem')
}
 
//https server
var https_server = https.createServer(options, app);
var io = socketIo.listen(https_server);
 
//服务端收到连接后的处理函数
io.sockets.on('connection', (socket)=> {
 
/*处理此连接上的 message 类型的消息*/
    socket.on('message', (room, data)=>{
        logger.debug('message, room: ' + room + ", data, type:" + data.type);
        socket.to(room).emit('message',room, data);
    });
 
 
/*处理此连接上的 join 类型的消息*/
    socket.on('join', (room)=>{
        socket.join(room);
        var myRoom = io.sockets.adapter.rooms[room]; 
        var users = (myRoom)? Object.keys(myRoom.sockets).length : 0;
        logger.debug('the user number of room (' + room + ') is: ' + users);
 
        if(users < USERCOUNT){
            socket.emit('joined', room, socket.id); //发给除自己之外的房间内的所有人
            if(users > 1){
                socket.to(room).emit('otherjoin', room, socket.id);
            }
        
        }else{
            socket.leave(room); 
            socket.emit('full', room, socket.id);
        }
        //socket.emit('joined', room, socket.id); //发给自己
        //socket.broadcast.emit('joined', room, socket.id); //发给除自己之外的这个节点上的所有人
        //io.in(room).emit('joined', room, socket.id); //发给房间内的所有人
    });
 
/*处理此连接上的 leave 类型的消息*/
    socket.on('leave', (room)=>{
 
        socket.leave(room);
 
        var myRoom = io.sockets.adapter.rooms[room]; 
        var users = (myRoom)? Object.keys(myRoom.sockets).length : 0;
        logger.debug('the user number of room is: ' + users);
 
        //socket.emit('leaved', room, socket.id);
        //socket.broadcast.emit('leaved', room, socket.id);
        socket.to(room).emit('bye', room, socket.id);
        socket.emit('leaved', room, socket.id);
        //io.in(room).emit('leaved', room, socket.id);
    });
 
});
 
https_server.listen(443, '0.0.0.0');
console.log("start singal");

搭建信令服务器

接下来我们来看一下，如何通过 Nodejs下的 socket.io 来构建的一个服务器。

客户端

这是客户端代码，也就是在浏览器里执行的代码。index.html：

<!DOCTYPE html>
<html>

    <head>
        <title>WebRTC client</title>
    </head>

    <body>
        <script src='/socket.io/socket.io.js'></script>
        <script src='client.js'></script>
    </body>

</html>

该代码十分简单，就是在body里引入了两段 JS 代码。其中，socket.io.js 是用来与服务端建立 socket 连接的。client.js 的作用是做一些业务逻辑，并最终通过 socket 与服务端通讯。

然后在同目录下生成 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返回的消息做不同的处理：

  1. 当收到房间满”full”时的情况；
  2. 当收到房间空“empty”时的情况；
  3. 当收到加入“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 和 node-static。进入到 server.js 所在的目录，然后执行下面的命令：

npm install socket.io@2.3.0
npm install node-static

注意要下载旧版本的 socket.io，当前最新的socket.io为3.1.0版本，API有所不同，运行时会报错。

启动服务器并测试

通过上面的步骤我们就使用 socket.io 构建好一个服务器，现在可以通过下面的命令将服务启动起来了：

node server.js

如果你是在本机上搭建的服务，则可以在浏览器中输入 localhost:2013，然后新建一个 tab 在里边再次输入 localhost:2013。

在 Chrome 下你可以使用快捷键 Ctrl+Shift+J 打开 DevTools 访问控制台。输出如下：

在这里插入图片描述

打开 Edge 浏览器，同样在浏览器中输入 localhost:2013，然后新建一个 tab 在里边再次输入 localhost:2013。变化如下：

在这里插入图片描述

在这里插入图片描述

总结

以上我向大家介绍了 Nodejs 的工作原理、Nodejs的安装与布署，以及如何使用 要sokcet.io 构建 WebRTC 信令消息服务器。socket.io 由于有房间的概念所以与WebRTC非常匹配，用它开发WebRTC信令服务器非常方便。

另外，在本文中的例子只是一个简单例子并没有太多的实际价值。在后面的文章中我会以这个例子为基础，在其上面不断增加一些功能，最终你会看到一个完整的Demo程序。

参考

  1. https://webrtc.org.cn/webrtc-tutorial-1-setup-signaling/
  2. https://blog.csdn.net/agora_cloud/article/details/90378050
  3. https://cloud.tencent.com/developer/article/1755169

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1651560.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

一文读懂三维点云分割

一文读懂三维点云分割

点击下方卡片&#xff0c;关注“小白玩转Python”公众号 什么是点云分割&#xff1f; 点云是世界的一种非结构化三维数据表示&#xff0c;通常由激光雷达传感器、立体相机或深度传感器采集。它由一系列单个点组成&#xff0c;每个点由 x、y 和 z 坐标定义。 自动驾驶模型的点云…
阅读更多...
达梦数据库导入数据问题

达梦数据库导入数据问题

进行数据导入的时候遇到了导入数据问题 第一个问题&#xff1a; 该工具不能解析此文件&#xff0c;请使用更高版本的工具 这个是因为版本有点低&#xff0c;需要下载最新的达梦数据库 第二个问题&#xff1a; &#xff08;1&#xff09;本地编码&#xff1a;PG_GBK, 导入文…
阅读更多...
【JavaEE 初阶（三）】多线程代码案例

【JavaEE 初阶（三）】多线程代码案例

❣博主主页: 33的博客❣ ▶️文章专栏分类:JavaEE◀️ &#x1f69a;我的代码仓库: 33的代码仓库&#x1f69a; &#x1faf5;&#x1faf5;&#x1faf5;关注我带你了解更多线程知识 目录 1.前言2.单例模式2.1饿汉方式2.2饿汉方式 3.阻塞队列3.1概念3.2实现 4.定时器4.1概念4.…
阅读更多...
js原生写一个小小轮播案例

js原生写一个小小轮播案例

先上示例&#xff1a; 附上代码 html <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><meta name"viewport" content…
阅读更多...
西奥CHT-01软胶囊硬度测试仪：重塑行业标杆，引领硬度测试新纪元

西奥CHT-01软胶囊硬度测试仪：重塑行业标杆，引领硬度测试新纪元

西奥CHT-01软胶囊硬度测试仪&#xff1a;重塑行业标杆&#xff0c;引领硬度测试新纪元 在当今医药领域&#xff0c;软胶囊作为一种广泛应用的药品剂型&#xff0c;其品质的稳定性和安全性直接关系到患者的健康。而在确保软胶囊品质的各项指标中&#xff0c;硬度测试尤为关键。…
阅读更多...
Bookends for Mac v15.0.2 文献书籍下载管理

Bookends for Mac v15.0.2 文献书籍下载管理

Bookends Mac版可以轻松地将其导入参考 &#xff0c;并直接搜索和进口从数以百计的线上资料来源。Bookends Mac版使用内置在浏览器中下载参考与PDF格式的文件&#xff0c;或和/或网页的点击。 Bookends for Mac v15.0.2注册激活版下载 本文由 mdnice 多平台发布
阅读更多...
云密码机的定义与特点

云密码机的定义与特点

云密码机&#xff0c;作为云计算环境中保障数据安全的关键设备&#xff0c;其重要性不言而喻。它基于虚拟化技术&#xff0c;通过提供高性能的数据加解密、密钥管理等服务&#xff0c;确保云上数据的安全与隐私。下面&#xff0c;安策科技将从云密码机的定义、特点、应用场景以…
阅读更多...
JAVA中的线程、死锁、异常

JAVA中的线程、死锁、异常

线程 Thread 一、程序 1&#xff0e;一段静态代码&#xff08;静态&#xff09; 二、进程 1&#xff0e;动态的&#xff0c;有开始&#xff0c;有结束&#xff1b;2&#xff0e;程序的一次执行过程&#xff0c;3&#xff0e;操作系统调度分配资源的最小单位&#xff1b; 三、…
阅读更多...
图形渲染在AI去衣技术中的奇妙之旅

图形渲染在AI去衣技术中的奇妙之旅

在这个数字化飞速发展的时代&#xff0c;人工智能&#xff08;AI&#xff09;已经成为了我们生活中不可或缺的一部分。它像一位神秘的魔法师&#xff0c;以其不可思议的力量改变着我们的世界。今天&#xff0c;我要和大家探讨的&#xff0c;是一个颇具争议却技术含金量极高的话…
阅读更多...
群晖上部署农场管理系统farmOS

群晖上部署农场管理系统farmOS

什么是 farmOS &#xff1f; farmOS 是一个基于 Web 的应用程序&#xff0c;用于农场管理、规划和记录保存。它由志愿者社区开发&#xff0c;旨在为农民、开发人员和研究人员提供一个标准平台。 需要注意的是&#xff0c;群晖内核版本太低会遇到下面的错误&#xff0c;这个 AH0…
阅读更多...
2024暨南大学校赛热身赛解析

2024暨南大学校赛热身赛解析

文章目录 A 突发恶疾B Uzi 的真身C 时间管理大师D 基站建设E 在仙境之外weiwandaixu 题目地址 A 突发恶疾 斐波那契数列 fn [0]*1000006fn[0],fn[1] 0,1for i in range(2,1000002):fn[i] (fn[i-1]fn[i-2])%998244353n int(input()) print(fn[n])B Uzi 的真身 分析&#xff…
阅读更多...
SSM【Spring SpringMVC Mybatis】——Maven

SSM【Spring SpringMVC Mybatis】——Maven

目录 1、为什么使用Maven 1️⃣获取jar包 2️⃣添加jar包 3️⃣使用Maven便于解决jar包冲突及依赖问题 2、什么是Maven 3、Maven基本使用 3.1 Maven准备 3.2 Maven基本配置 3.3 Maven之Helloworld 4、Maven及Idea的相关应用 4.1 将Maven整合到IDEA中 4.2 在IDEA中新建…
阅读更多...
使用脚本一键部署项目的示例（脚本会创建syetemctl的系统服务）

使用脚本一键部署项目的示例（脚本会创建syetemctl的系统服务）

文章目录 说明使用脚本一键部署本项目开启/停止服务开启/关闭开机自动运行更新项目 参考地址&#xff1a;https://github.com/Evil0ctal/Douyin_TikTok_Download_API?tabreadme-ov-file 说明 后续相关项目可以使用这种方式创建脚本&#xff0c;脚本均放置在项目根目录下的bas…
阅读更多...
【C++干货基地】揭秘C++STL库的魅力：stiring的初步了解和使用

【C++干货基地】揭秘C++STL库的魅力：stiring的初步了解和使用

&#x1f3ac; 鸽芷咕&#xff1a;个人主页 &#x1f525; 个人专栏: 《C干货基地》《粉丝福利》 ⛺️生活的理想&#xff0c;就是为了理想的生活! 引入 哈喽各位铁汁们好啊&#xff0c;我是博主鸽芷咕《C干货基地》是由我的襄阳家乡零食基地有感而发&#xff0c;不知道各位的…
阅读更多...
AI大模型探索之路-训练篇17：大语言模型预训练-微调技术之QLoRA

AI大模型探索之路-训练篇17：大语言模型预训练-微调技术之QLoRA

系列篇章&#x1f4a5; AI大模型探索之路-训练篇1&#xff1a;大语言模型微调基础认知 AI大模型探索之路-训练篇2&#xff1a;大语言模型预训练基础认知 AI大模型探索之路-训练篇3&#xff1a;大语言模型全景解读 AI大模型探索之路-训练篇4&#xff1a;大语言模型训练数据集概…
阅读更多...
动态规划——路径问题：LCR 166.珠宝的最高价值

动态规划——路径问题：LCR 166.珠宝的最高价值

文章目录 题目描述算法原理1.状态表示&#xff08;题目经验&#xff09;2.状态转移方程3.初始化4.填表顺序5.返回值 代码实现CJava 题目描述 题目链接&#xff1a;LCR 166.珠宝的最高价值 算法原理 1.状态表示&#xff08;题目经验&#xff09; 对于这种路径类的问题&…
阅读更多...
Linux中动态库的用法及优缺点？怎样制作动态库和静态库？

Linux中动态库的用法及优缺点？怎样制作动态库和静态库？

一、什么是gcc gcc的全称是GNU Compiler Collection&#xff0c;它是一个能够编译多种语言的编译器。最开始gcc是作为C语言的编译器&#xff08;GNU C Compiler&#xff09;&#xff0c;现在除了c语言&#xff0c;还支持C、java、Pascal等语言。gcc支持多种硬件平台. 在 Linux…
阅读更多...
在做题中学习(52): 山脉数组的峰顶索引

在做题中学习(52): 山脉数组的峰顶索引

852. 山脉数组的峰顶索引 - 力扣&#xff08;LeetCode&#xff09; 解法&#xff1a;二分查找 思路&#xff1a;O(logn)的时间复杂度&#xff0c;很可能是二分法&#xff0c;再看看有没有二段性&#xff1a; 由题目可以知道&#xff0c;i的左边比i小&#xff0c;右边比i大&am…
阅读更多...
47.Redis学习笔记

47.Redis学习笔记

小林coding -> 图解redis的学习笔记 文章目录 Rediswindwos安装docker安装redis启动redis使用RDM访问虚拟机中的redispython连接redis缓存穿透、击穿、雪崩基本数据类型高级数据类型高并发指标布隆过滤器分布式锁Redis 的有序集合底层为什么要用跳表&#xff0c;而不用平衡…
阅读更多...
Spring_概述

Spring_概述

Spring 官网Spring Framework&#xff08;Spring&#xff09;文档位置重点内容Overview 官网 Spring官网 Spring Framework&#xff08;Spring&#xff09; 文档位置 重点 IoC容器AOP&#xff1a;面向切面编程AOT&#xff1a;ahead of time&#xff0c;提前编译Web 框架&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023