Socket.io 是一个适用于浏览器和服务器之间实时通信的 JavaScript 库。它封装了 WebSocket，提供了一个简单的 API，可以轻松地进行双向通信。Socket.io 具有广泛的应用场景，例如在线聊天、实时协作和经常更新的数据展示等。
在本文中，我们将学习如何使用 Socket.io 进行消息推送，并创建一个基于 Node.js 的简单聊天室。
准备工作
在开始使用 Socket.io 之前，我们需要先准备好一些工具和环境。
下载 Socket.io
我们可以通过 NPM 下载 Socket.io：
npm install socket.io
这将在当前项目中安装 Socket.io 的最新版本。
创建 Node.js 服务器
我们还需要创建一个 Node.js 服务器。我们可以使用 Express 库来创建服务器。
为此，我们需要安装 Express：
npm install express
然后创建 index.js 文件，并编写服务器的基本结构：
const express = require('express');
const app = express();
app.use(express.static(__dirname + '/public'));
const server = app.listen(3000, function () {
console.log('Server listening on port 3000');
});这个代码片段创建了一个 Express 应用程序，并将静态文件夹设置为 public。它还启动了服务器，并在控制台输出“Server listening on port 3000”。
运行服务器
最后，我们可以使用以下命令来启动服务器：
node index.js
服务器将运行在 localhost:3000 上。
Socket.io 的基本用法
在我们继续之前，我们需要确保已经在客户端（如 HTML 或 ReactJS）中安装了 Socket.io 客户端库：
npm install socket.io-client
连接服务器
与其他 WebSocket 库一样，Socket.io 不是通过 HTTP 请求连接，而是需要使用其自己的协议。我们可以使用以下代码来创建 Socket.io 客户端：
const socket = io('http://localhost:3000');这将连接我们的 Socket.io 服务器，并创建一个与服务器的连接。
发送消息
要发送消息，我们可以使用以下代码：
socket.emit('message', 'Hello, world!');这将发送一条带有“Hello, world!”消息的消息。
监听消息
要监听来自服务器的消息，我们可以使用以下代码：
socket.on('message', function (data) {
console.log(data);
});这将在控制台上打印出我们收到的消息。
将 Socket.io 用于聊天室
现在，我们已经了解了如何使用 Socket.io 中的基本功能，让我们将其用于创建聊天室。
创建聊天室
为了创建聊天室，我们需要使用 Express 应用程序来提供我们的 HTML 页面和 Socket.io 服务器。
首先，我们需要为我们的应用程序添加 Socket.io 服务器。我们可以使用以下代码：
-- -------------------- ---- -------
----- ------- - -------------------
----- --- - ----------
----- ---- - ----------------------------------
----- -- - ---------------------------
-- ---
----------------- -------- -- -
------------------- --------- -- ---- -------
---这将创建一个 http 服务器，并使用 Socket.io 绑定它。
接下来，我们需要在我们的 HTML 页面中添加以下代码来连接 Socket.io 服务器：
<script src="/socket.io/socket.io.js"></script>
<script>
const socket = io();
</script>这将在我们的 HTML 页面中创建一个新的 Socket.io 客户端，连接到我们的服务器。
发送和接收消息
为了发送消息，我们可以在客户端上使用以下代码：
socket.emit('chatMessage', message);这将发送 chatMessage 事件，并将消息发送到服务器。
在服务器上，我们需要监听 chatMessage 事件，并将消息发送回所有连接的客户端：
io.on('connection', (socket) => {
socket.on('chatMessage', (message) => {
io.emit('message', message);
});
});这将在服务器上监听 chatMessage 事件，并在接收到消息时将其广播回所有连接的客户端。
添加聊天室功能
最后，我们将向聊天室添加一些额外的功能，例如用户加入和退出聊天室、欢迎消息和提示消息。
在服务器上，我们可以监听 connection 事件，并在新用户加入时发送欢迎消息：
io.on('connection', (socket) => {
// ...
socket.broadcast.emit('message', 'A new user has joined the chat');
});这将在新用户加入时向聊天室中的所有其他用户发送一条欢迎消息。
我们还可以在用户离开聊天室时发送提示消息。为此，我们可以侦听 disconnect 事件：
io.on('connection', (socket) => {
// ...
socket.on('disconnect', () => {
io.emit('message', 'A user has left the chat');
});
});这将在用户关闭应用程序或与服务器断开连接时发送一条提示消息。
示例代码
本文代码示例可从以下链接中下载：
git clone https://github.com/MicrosoftDocs/mslearn-use-socket-io
总结
在本文中，我们介绍了如何使用 Socket.io 进行消息推送，并创建了一个基于 Node.js 的简单聊天室。我们了解了如何连接服务器、发送和接收消息，以及如何为聊天室添加额外的功能，例如用户加入和退出和欢迎和提示消息。希望这篇文章能够为您提供有关如何使用 Socket.io 的详细指南！
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64903dad48841e9894e693fb