node.js中，子进程发送文件流，主进程如何监听文件流是否发送完成，然后再下载文件流

在 Node.js 中，可以使用 `child_process` 模块创建子进程，并通过管道（`pipe()`）方式将文件流发送到主进程。

主进程可以使用 `Readable` 流来监听子进程发送的文件流是否传输完成。当 `Readable` 流触发 `end` 事件时，表示数据已经传输完成，此时主进程可以进行文件下载操作。

以下是一个示例代码：

子进程代码：

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

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

child.stdout.pipe(process.stdout);
child.stderr.pipe(process.stderr);

在子进程中，我们使用 `spawn` 方法创建了一个 `ls -la` 的命令行进程，并将 `stdout` 的输出通过管道传输到主进程的 `process.stdout` 中。同时，我们也将 `stderr` 的输出通过管道传输到主进程的 `process.stderr` 中。

主进程代码：

const fs = require('fs');
const { spawn } = require('child_process');
const { Readable } = require('stream');

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

let data = '';
child.stdout.on('data', chunk => {
  data += chunk;
});

child.stdout.on('end', () => {
  const fileStream = new Readable();
  fileStream.push(data);
  fileStream.push(null);

  const writeStream = fs.createWriteStream('./output.txt');
  fileStream.pipe(writeStream);
  console.log('文件下载完成！');
});

child.stderr.pipe(process.stderr);

在主进程中，我们监听了子进程的 `stdout` 的 `data` 事件和 `end` 事件。在 `data` 事件中，我们将子进程发送的数据累加到 `data` 变量中。在 `end` 事件中，我们创建了一个 `Readable` 流，并将 `data` 变量中的数据推送到 `Readable` 流中。然后，我们使用 `fs.createWriteStream` 方法创建了一个可写流，将 `Readable` 流中的数据写入到指定的文件中。

总之，通过此方法，我们可以轻松地在主进程中监听子进程发送的文件流是否传输完成，并进行文件下载操作。