Node.js中的进程间通信

2023-10-13 07:55:19

在本文中，我们将探索 Node.js 中的进程间通信 (IPC) 以及各种可用于促进不同进程之间交互的技术。 IPC 对于构建复杂应用程序至关重要，这些应用程序需要在不同进程之间共享数据和资源。 Node.js 提供了多种内置机制来实现 IPC，包括管道、Unix 域套接字、消息队列、共享内存和信号。我们将讨论每种机制的优缺点，并提供一些关于如何使用它们的示例。

管道

管道是一种简单的 IPC 机制，允许两个进程通过共享文件符进行通信。管道通常用于将数据从一个进程传输到另一个进程。例如，可以使用管道将子进程的输出重定向到父进程的输入。

const { spawn } = require('child_process');

const ls = spawn('ls', ['-l']);

ls.stdout.pipe(process.stdout);

Unix 域套接字

Unix 域套接字是一种 IPC 机制，允许两个进程通过一个共同的文件路径进行通信。Unix 域套接字通常用于在同一台机器上的进程之间进行通信。

const net = require('net');

const server = net.createServer();

server.on('connection', (socket) => {
  socket.on('data', (data) => {
    console.log(data.toString());
  });
});

server.listen(8080);

const client = net.createConnection(8080);

client.on('connect', () => {
  client.write('Hello from client');
});

消息队列

消息队列是一种 IPC 机制，允许两个进程通过一个共享的缓冲区进行通信。消息队列通常用于在不同机器上的进程之间进行通信。

const amqp = require('amqplib');

const connect = amqp.connect('amqp://localhost');

connect.then((connection) => {
  const channel = connection.createChannel();

  channel.assertQueue('my_queue');

  channel.sendToQueue('my_queue', Buffer.from('Hello from Node.js'));
});

共享内存

共享内存是一种 IPC 机制，允许两个进程共享一块内存。共享内存通常用于在不同机器上的进程之间进行通信。

const shm = require('shared-memory');

const segment = shm.create('my_segment', 1024);

segment.writeUInt32(0, 1234);

segment.readUInt32(0); // 1234

信号

信号是一种 IPC 机制，允许一个进程向另一个进程发送信号。信号通常用于通知另一个进程发生了某个事件。

const { spawn } = require('child_process');

const ls = spawn('ls', ['-l']);

ls.on('close', (code) => {
  console.log(`Child process exited with code ${code}`);
});

process.kill(ls.pid, 'SIGINT');