Node.js 中如何进行跨进程通信与数据共享-JavaScript中文网-JavaScript教程资源分享门户

Node.js 是一个基于事件驱动、非阻塞 I/O 的 JavaScript 运行环境，它的特点在于能够轻松创建可扩展的网络应用程序。在实际项目中，我们通常需要多个进程之间协同工作，甚至是在不同的服务器之间，这时就需要进行进程间通信（IPC）以及数据共享的操作。

本文介绍了 Node.js 中常用的进程间通信方法，并提供了一些示例代码，帮助读者更好地理解和应用这些技术。

1. 进程间通信（IPC）

进程间通信（IPC）是指多个进程之间进行信息交换的操作，它需要通过一些特殊的手段，使进程之间能够相互发送和接收信息。在 Node.js 中，我们通常使用以下方式实现 IPC。

1.1 通过子进程实现 IPC

Node.js 通过 child_process 模块提供了一些 API，用于创建并操作子进程。我们可以通过这个模块来实现进程间通信。

// javascriptcn.com 代码示例
const cp = require('child_process');

// 创建子进程
const childProcess = cp.spawn('node', ['child.js']);

// 监听子进程输出
childProcess.stdout.on('data', (data) => {
  console.log('Received message from child:', data.toString());
});

// 发送消息到子进程
childProcess.stdin.write('hello from parent\n');

这里我们使用 spawn 方法创建了一个子进程，并监听了子进程的标准输出。当子进程输出任何消息时，会触发 data 事件，然后我们就可以在回调函数中处理这些消息。此外，我们还可以使用 stdin 属性向子进程发送消息。

下面是子进程的代码示例：

process.stdin.on('data', (data) => {
  console.log('Received message from parent:', data.toString());
  process.stdout.write('hello from child\n');
});

这里我们只是通过监听 stdin 事件，处理了来自父进程的消息，然后通过 stdout 属性向父进程发送了一个简单的消息。

1.2 通过 TCP、UDP 实现 IPC

另一种进程间通信的方式是通过 TCP 或 UDP 套接字实现。这种方式可以支持更复杂的场景，例如在多台服务器之间进行通信。下面是一个简单的 TCP 服务器和客户端代码示例。

// javascriptcn.com 代码示例
// server.js
const net = require('net');

const server = net.createServer((socket) => {
  console.log('Client connected');

  // 监听客户端消息
  socket.on('data', (data) => {
    console.log('Received message from client:', data.toString());
    socket.write('hello from server\n');
  });

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

server.listen(3000, () => {
  console.log('Server started');
});

// client.js
const net = require('net');

const socket = net.createConnection({ port: 3000 }, () => {
  console.log('Connected to server');
  socket.write('hello from client\n');
});

// 监听服务端消息
socket.on('data', (data) => {
  console.log('Received message from server:', data.toString());
});

// 监听连接断开
socket.on('close', () => {
  console.log('Server disconnected');
});

这里我们使用了 net 模块创建了一个 TCP 服务器和客户端。当客户端发起连接请求时，服务器会通过 connection 事件监听到这个请求，并创建对应的套接字。然后我们可以通过监听套接字上的 data 事件，处理客户端发送的消息，并在回调函数中写回一条消息。客户端也可以通过 write 方法向服务端发送消息，然后监听服务端的 data 事件处理响应。

2. 数据共享

除了进程间通信，还有一种常见的需求是数据共享，即多个进程之间共享同一份数据。在 Node.js 中，我们通常使用一些特殊的机制，如共享内存和消息队列，来实现数据共享。

2.1 通过共享内存实现数据共享

共享内存是指多个进程可以访问同一块内存区域，从而实现一个或多个变量的共享。在 Node.js 中，我们可以使用共享内存来实现数据共享。

// javascriptcn.com 代码示例
const sharedBuffer = Buffer.alloc(1024);
const worker = new Worker('./worker.js');

// 向子进程传递共享内存
worker.postMessage({ buffer: sharedBuffer }, [sharedBuffer]);

// 监听子进程发送的消息
worker.on('message', (msg) => {
  console.log('Received message from worker:', msg);
});

这里我们使用了 Buffer.alloc 方法创建了一段共享内存。然后我们再创建了一个子进程 worker.js，并将这段共享内存作为消息传递给了子进程。在子进程中，我们可以通过访问 buffer 属性来读取和修改这段共享内存。

// javascriptcn.com 代码示例
const { parentPort } = require('worker_threads');

parentPort.once('message', (msg) => {
  const sharedBuffer = msg.buffer;

  // 在共享内存中写入内容
  sharedBuffer.write('hello from worker');

  // 发送消息到父进程
  parentPort.postMessage('done');
});

下面的代码示例中，子进程通过监听 message 事件处理父进程传递过来的共享内存。然后我们可以通过 write 方法向共享内存中写入内容。最后子进程通过 postMessage 向父进程发送一个简单的消息。

2.2 通过消息队列实现数据共享

消息队列是指通过一组消息传递机制来共享数据的方法。在 Node.js 中，我们通常使用 zeromq 模块来创建和管理消息队列。

// javascriptcn.com 代码示例
// server.js
const zmq = require('zeromq');

const socket = zmq.socket('push');
socket.bindSync('tcp://*:3000');

setInterval(() => {
  const msg = `hello from server at ${new Date()}`;
  console.log(`Sending message: ${msg}`);
  socket.send(msg);
}, 1000);

// client.js
const zmq = require('zeromq');

const socket = zmq.socket('pull');
socket.connect('tcp://127.0.0.1:3000');

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

这里我们使用了 zeromq 模块创建了一个消息队列。在服务端中，我们通过调用 bindSync 方法将队列绑定到本地地址，并使用 send 方法向队列发送消息。在客户端中，我们先是调用 connect 方法连接到队列，然后监听 message 事件来处理服务端发送的消息。

总结

本文介绍了 Node.js 中实现进程间通信和数据共享的两种主要方法，包括使用子进程、套接字、共享内存和消息队列等技术。对于开发中需要进行 IPC 和数据共享的场景，读者可以根据本文提供的示例代码来实现和定制自己的解决方案。

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

Node.js 中如何进行跨进程通信与数据共享

目录