Express.js 中使用 Socket.io 实现实时通信-JavaScript中文网-JavaScript教程资源分享门户

WebSocket 技术是实现实时通信的一种好方法，但是它需要自己实现大量的逻辑和管理代码。 Socket.io 基于 WebSocket，但封装了很多底层的逻辑和协议。使用 Socket.io，实现实时通信变得更加容易。

在 Node.js 技术栈中，Express.js 是一种广泛使用的 Web 框架，它可以帮助我们快速搭建 Web 应用，同时 Socket.io 也是一个广泛使用的实现实时通信的库。在本文中，我们将介绍如何在 Express.js 中使用 Socket.io 实现实时通信。

什么是 Socket.io？

Socket.io 是一种实现实时双向通信的 JavaScript 库，它可以运行在浏览器和服务器端。它基于 WebSocket，并向下兼容，如果 WebSocket 不可用，Socket.io 会使用其它传输方式来实现实时通信。

Socket.io 提供了一些很棒的功能，例如：房间管理、消息传递、广播等等。另外，使用 Socket.io 可以让我们在 Web 应用中实现实时通信变得更加容易。

为什么要使用 Socket.io?

在传统 Web 应用中，通常使用 AJAX 轮询来实现实时通信。但是，使用轮询会浪费大量的带宽和资源，因为它会导致一些无用的请求。另外，轮询可能会导致消息延迟，这对于需要实时响应的应用程序是不可接受的。

与轮询不同，Socket.io 提供了一种实时，低延迟，高效的通信方式。因此，在需要实时通信的应用场景下，Socket.io 是更好的选择。

如何在 Express.js 中使用 Socket.io?

在 Express.js 中使用 Socket.io，我们需要做以下几个步骤：

安装 socket.io 和 socket.io-client

npm install socket.io socket.io-client

创建 server

我们需要创建一个 server 对象，代码如下：

// javascriptcn.com 代码示例
const express = require('express');
const http = require('http');
const socketio = require('socket.io');

const app = express();
const server = http.createServer(app);
const io = socketio(server);

server.listen(3000, () => console.log('server is running on port 3000'));

在上面的代码中，我们创建了一个 express 应用，然后创建了一个 http 服务器，并将 express 应用传递给它。接下来，我们将创建一个 Socket.io 服务器，并将其作为参数传递给我们的服务器。

创建连接

我们需要为连接事件注册一个监听器，这样我们就可以处理客户端连接到 Socket.io 服务器的事件。代码如下：

io.on('connection', socket => {
  console.log('a user connected');
});

处理消息

在连接事件中，我们可以处理来自客户端的消息。代码如下：

io.on('connection', socket => {
  console.log('a user connected');

  socket.on('message', message => {
    console.log('received message:', message);
    // 处理消息
  });
});

发送消息

在处理消息之后，我们可以使用 emit 方法将消息发送给客户端。代码如下：

// javascriptcn.com 代码示例
io.on('connection', socket => {
  console.log('a user connected');

  socket.on('message', message => {
    console.log('received message:', message);
    // 处理消息

    // 发送消息
    socket.emit('message', 'message received');
  });
});

在上面的例子中，我们使用了 socket.emit 方法将消息发送给客户端。当然，还有其他的方法可以实现广播。

示例代码

// javascriptcn.com 代码示例
const express = require('express');
const http = require('http');
const socketio = require('socket.io');

const app = express();
const server = http.createServer(app);
const io = socketio(server);

app.use(express.static(__dirname + '/public'));

server.listen(3000, () => console.log('server is running on port 3000'));

io.on('connection', socket => {
  console.log('a user connected');

  socket.on('message', message => {
    console.log('received message:', message);
    // 处理消息

    // 发送消息
    socket.emit('message', 'message received');
  });
});

总结

在本文中，我们介绍了 Socket.io，在 Express.js 中如何使用 Socket.io 实现实时通信，并提供了示例代码。使用 Socket.io 可以简化实时通信的逻辑，让我们更方便地构建实时应用程序。

来源：JavaScript中文网，转载请注明来源本文地址：https://www.javascriptcn.com/post/653906dd7d4982a6eb23ca0f