Node.js中如何实现实时通信

发布时间：2025-03-31 04:19:35 作者：小樊
来源：亿速云阅读：110

在Node.js中，实现实时通信的常用方法是使用WebSocket。WebSocket是一种网络通信协议，它允许客户端和服务器之间进行双向、实时的数据传输。在Node.js中，可以使用ws库或者socket.io库来实现WebSocket。

下面是使用ws库和socket.io库实现实时通信的简单示例：

使用ws库实现实时通信：

首先，需要安装ws库：

npm install ws

然后，创建一个简单的WebSocket服务器：

// server.js
const WebSocket = require('ws');

const server = new WebSocket.Server({ port: 8080 });

server.on('connection', (socket) => {
  console.log('Client connected');

  // 向客户端发送消息
  socket.send('Hello from server!');

  // 接收客户端消息
  socket.on('message', (message) => {
    console.log(`Received message: ${message}`);
  });

  // 客户端断开连接
  socket.on('close', () => {
    console.log('Client disconnected');
  });
});

接下来，创建一个简单的HTML页面作为客户端：

<!-- index.html -->
<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <title>WebSocket Client</title>
  <script>
    document.addEventListener('DOMContentLoaded', () => {
      const socket = new WebSocket('ws://localhost:8080');

      socket.addEventListener('open', () => {
        console.log('Connected to server');
        socket.send('Hello from client!');
      });

      socket.addEventListener('message', (event) => {
        console.log(`Received message: ${event.data}`);
      });

      socket.addEventListener('close', () => {
        console.log('Disconnected from server');
      });
    });
  </script>
</head>
<body>
  <h1>WebSocket Client</h1>
</body>
</html>

使用socket.io库实现实时通信：

首先，需要安装socket.io库：

npm install socket.io

然后，创建一个简单的Socket.IO服务器：

// server.js
const http = require('http');
const socketIO = require('socket.io');

const server = http.createServer();
const io = socketIO(server);

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

  // 向客户端发送消息
  socket.emit('message', 'Hello from server!');

  // 接收客户端消息
  socket.on('message', (message) => {
    console.log(`Received message: ${message}`);
  });

  // 客户端断开连接
  socket.on('disconnect', () => {
    console.log('Client disconnected');
  });
});

server.listen(8080, () => {
  console.log('Server listening on port 8080');
});

接下来，创建一个简单的HTML页面作为客户端：

<!-- index.html -->
<!DOCTYPE html>
<html lang="en">
<head>
  <meta charset="UTF-8">
  <title>Socket.IO Client</title>
  <script src="/socket.io/socket.io.js"></script>
  <script>
    document.addEventListener('DOMContentLoaded', () => {
      const socket = io('http://localhost:8080');

      socket.on('connect', () => {
        console.log('Connected to server');
        socket.emit('message', 'Hello from client!');
      });

      socket.on('message', (message) => {
        console.log(`Received message: ${message}`);
      });

      socket.on('disconnect', () => {
        console.log('Disconnected from server');
      });
    });
  </script>
</head>
<body>
  <h1>Socket.IO Client</h1>
</body>
</html>

这两个示例都实现了基本的实时通信功能。你可以根据自己的需求选择使用ws库或socket.io库。

Node.js中如何实现实时通信

相关阅读