Socket.io 是一个在浏览器和服务器之间建立实时、双向和基于事件的通信通道的 JavaScript 库。基于 Socket.io，我们可以构建实时的用户互动功能，例如聊天系统、直播系统等。在这篇文章中，我将介绍如何使用 Socket.io 实现一个简单的直播系统。
前置要求
在开始之前，需要具备以下技术要求：
- JavaScript 的基本语法和编程能力；
- Node.js 的了解和安装；
- Express.js 的了解和基本应用；
- 关于 Socket.io 的基本概念。
项目结构
在开始开发之前，我们先建立好项目目录结构。
|-- node_modules |-- public | |-- css | |-- js | |-- index.html |-- server.js |-- package.json
其中，public 目录下存放的是前端展示的相关代码和资源，server.js 是服务器的代码，package.json 是项目的配置文件。
安装和配置
首先，我们需要安装 Socket.io 和 Express.js 。在项目根目录下打开终端，执行以下命令：
npm i socket.io express --save
接下来，在 server.js 中引入 socket.io 和 express 的相关代码：
-- -------------------- ---- ------- ----- ------- - ------------------- ----- ---- - ---------------- ----- -------- - --------------------- ----- --- - ---------- ----- ------ - ----------------------- ----- -- - ----------------- -------------------------------- - ------------ ----- ---- - ---------------- -- ----- ------------------- -- -- - ------------------- --------- -- ---- ------------- --- ------------------- -------- -- - -------------- ---- ------------- ---
这里我们创建了一个 Express 应用，然后创建了一个 HTTP 服务器并使用 Socket.io 在服务器端启用了 WebSockets。同时，我们使用 app.use(express.static(__dirname + '/public')); 将 public 目录下的静态资源暴露出来。
在控制台中运行 node server.js，如果一切顺利，你会看到服务器已经在本地的 3000 端口监听。
在前端发送直播流
我们在 index.html 中添加如下代码：
-- -------------------- ---- -------
--------- -----
------
------
----- --------------- --
---------------- --------------
-------
------ -
------- ------
------ ------
-
--------
-------
------
------ ---------- -------- -----------------
------- ---------------------------------------
--------
----- ------ - ----------------------------
----- ----- - ---------------------------------
----- ----------- - - ------ ----- ------ ---- --
------------------------------------------------
------------ -- -
--------------- - -------
-------------------------- -----------
------------ -- ------------------
---------
-------
-------在前端页面中，我们使用 getUserMedia() 方法获取用户的摄像头和麦克风信息，并将视频流添加到 video 元素中。同时，我们使用 socket.emit('broadcaster', socket.id) 将当前用户的 Socket ID 发送到服务器。
在后台接收直播流
在服务器端，我们需要监听客户端发送的“broadcaster”事件，并将收到的视频流数据广播给所有的客户端。在 server.js 中添加如下代码：
-- -------------------- ---- -------
--- ------------
------------------- -------- -- -
-------------- ---- -------------
------------------------ ---- -- -
----------- - ---
------------------------------------ -------------
---
-------------------- -- -- -
-------------------------------------- -----------
---
----------------------- -- -- -
---------------------------------- -----------
---
---我们使用 socket.on('broadcaster', (id) => {...}) 监听客户端发送的“broadcaster”事件，并将当前的摄像头用户 ID 广播给所有其它的客户端。在客户端，我们可以监听 broadcaster 事件并获取该摄像头用户 ID。同时，我们使用 socket.to(broadcaster).emit('watcher', socket.id) 实现将视频流数据发送给客户端。
在前端接收直播流
在客户端，我们利用前段调用 getUserMedia() 方法获取到视频流数据，并将数据通过 socket.emit('watcher') 发送给服务器。在 index.html 中我们可以加入如下代码：
-- -------------------- ---- -------
--------- -----
------
------
----- --------------- --
---------------- --------------
-------
------ -
------- ------
------ ------
-
--------
-------
------
------ ---------- -------- -----------------
------- ---------------------------------------
--------
----- ------ - ----------------------------
----- ----- - ---------------------------------
----- ----------- - - ------ ----- ------ ---- --
------------------------------------------------
------------ -- -
--------------- - -------
-------------------------- -----------
------------ -- ------------------
------------------------ ---- -- -
-----------------------
---
-------------------- ---- -- -
----- -------------- - --- --------------------
-------------------------------- -- ------------------------------ ---------
----------------------------
--------- -- -
----------------------------------------
-------------------- ---- ---------- ----
--
-------- -- ----------------
---
------------------- ----- --- -- -
--------------------------------------- ----------------------------
---
---------------------- ----------- --- -- -
----- ------------ - --- ---------------------------
---------------------------------------------
---
--------------- - --------------------- - -- -- -
---------------
-----------------------
--
---------
-------
-------最后，我们在客户端利用 RTCPeerConnection 实例实现 WebSocket 的实时连接。在客户端实现 offer 事件、answer 事件、candidate 事件的监听，并广播给其它客户端。在服务器端实现与客户端的连接，并将 offer 事件、answer 事件、candidate 事件广播给其它客户端，以此实现所有客户端之间的实时连接。
总结
通过上述代码，我们已经成功地实现了一个基于 Socket.io 的直播系统。这个简单的直播系统可以在现代浏览器中完美运行，但它并不是一个成熟的、完全功能的系统。 Socket.io 的强大和灵活性使其成为实时应用程序和直播应用程序的理想选择。我希望这篇简短的文章可以让你更好的理解 Socket.io 的基本知识，并能够运用它来实现其他有趣的应用。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/648e5df748841e9894cb80a1