Линейно-ориентированные потоки в Node.js

Я разрабатываю многопроцессорное приложение с использованием Node.js. В этом приложении родительский процесс порождает дочерний процесс и взаимодействует с ним, используя протокол обмена сообщениями на основе JSON по каналу. Я обнаружил, что большие сообщения JSON могут быть «обрезаны», так что один «кусок», отправленный прослушивателю данных в канале, не содержит полного сообщения JSON. Кроме того, небольшие сообщения JSON могут быть сгруппированы в один блок. Каждое сообщение JSON будет разделено символом новой строки, и поэтому мне интересно, существует ли уже утилита, которая буферизует поток чтения канала, чтобы он выдавал по одной строке за раз (и, следовательно, для моего приложения, один документ JSON вовремя). Похоже, это довольно распространенный вариант использования, поэтому мне интересно, было ли это уже сделано.

Буду признателен за любые рекомендации, которые кто-нибудь может предложить. Спасибо.

5
задан kanaka 17 August 2017 в 14:46
поделиться