不断从子进程标准输出读取 json

Question

我想在 nodejs 中从 java 子进程读取和发送 json 消息。 childprocess 将存在一段时间。通过stdio 发送和接收的消息代表两个进程之间的事件。因此，消息必须在完成后立即处理。

输出格式为

{"type":"eventType","data":...}
{"type":"anotherEventType","data":...}
...
{"type":"anotherEventType","data":...}

写消息没问题，但阅读是。特别是因为我不能依赖\n 上的消息拆分，也不能依赖一个块包含一条消息。

不幸的是，我能找到的每个示例都会缓冲stdout 的输出，直到进程终止，然后才解析它。我能找到的所有 IPC 节点模块都使用我想避免的套接字。

是否有提供此类功能的现有库或者我必须自己扮演角色？

Answer 1

JSONStream 完全符合我的要求。

child.stdout
    .pipe(require('JSONStream').parse())
    .on('data', processMessage);