如何从 Node.js 中的分叉子进程正确发送流？

如何解决如何从 Node.js 中的分叉子进程正确发送流？

我在分叉的子进程中尝试了这样的事情：

WriterPlugin.js（子进程）

  function sendCursor(){
                        try {
                let cursor = await getQueryCursor(reqBody,db);
                cursor.on('data',(data) => {
                    process.send(data);
                })
            } catch (error) {
                process.send({
                    message: error.toString(),status: 400
                })
            }
        }

controller.js（父进程）

function sendCursor(){ try { let cursor = await getQueryCursor(reqBody,status: 400 }) } }

这个只打印了光标的最后一个数据，我遇到了一个fastifyError：

const childProcess = fork(fileToExec);
    childProcess.send(objectToProcess);
    childProcess.on('message',(data) => {
            reply.send(data);
    })

const childProcess = fork(fileToExec); childProcess.send(objectToProcess); childProcess.on('message',(data) => { reply.send(data); })

如何使用 fastify 正确处理来自分叉子进程的cursor.stream()？

解决方法

您需要将数据推送到流中才能完成此任务：

const { fork } = require('child_process')
const { Readable } = require('stream')

const fastify = require('fastify')()

fastify.get('/',(request,reply) => {
  const stream = new Readable({
    read (size) {}
  })

  const childProcess = fork('./external-file.js')
  childProcess.on('message',(data) => {
    stream.push(JSON.stringify(data)) // it must be a string
  })
  childProcess.on('close',(data) => {
    stream.push(null)
  })

  reply.send(stream)
})

fastify.listen(8080)

external-file.js 在哪里：

let iteration = 0
const timer = setInterval(() => {
  const data = { iteration: iteration++ }
  process.send(data)

  if (iteration === 3) {
    clearInterval(timer)
  }
},1000)