Передача данных от дочернего к родительскому в nodejs

Ваш код работает, но при использовании пакета streamifier для создания потока чтения из строки ваш канал связи автоматически закрывается после передачи этой строки, из-за чего вы получаете ошибку ENOTCONN.

Чтобы иметь возможность отправлять несколько сообщений по потоку, рассмотрите возможность использования в нем .write. Вы можете вызывать это так часто, как хотите:

child.stdio[3].write('First message.\n');
child.stdio[3].write('Second message.\n');

Если вы хотите использовать этот метод для отправки нескольких отдельных сообщений (что, как я полагаю, имеет место на основе вашего замечания об использовании child.send() ранее), рекомендуется использовать какой-либо символ-разделитель, чтобы иметь возможность разделить сообщения при чтении потока в ребенке. В приведенном выше примере я использовал для этого символы новой строки. Полезным пакетом для помощи в этом разделении является event-stream.

Теперь, чтобы создать еще один канал связи из дочернего в родительский, просто добавьте еще один «канал» в свой stdio.

Вы можете написать ему в дочернем:

fs.createWriteStream(null, {fd: 4}).write('Sending a message back.');

И читаем из него в родительском:

child.stdio[4].pipe(process.stdout);

Это напечатает «Отправка сообщения обратно». к консоли.

Я столкнулся с той же проблемой и использовал параметр {end:false}, чтобы исправить ошибку. К сожалению, принятый ответ работает только при обработке дискретной записи коротких объемов данных. Если у вас много данных (а не только короткие сообщения), вам нужно управлять потоком, и использование .write() не самое лучшее. Для подобных сценариев (передача больших объемов данных) лучше использовать функцию .pipe(), как изначально в вашем коде, для управления потоком.

Ошибка возникает из-за того, что доступный для чтения поток в вашем родительском процессе пытается завершить и закрыть доступный для записи поток ввода вашего дочернего процесса. Вы должны использовать опцию {end: false} в родительском канале процесса:

Исходный код: require('streamifier').createReadStream('test 2').pipe(child.stdio[3]);

Предлагаемая модификация: require('streamifier').createReadStream('test 2').pipe(child.stdio[3], {end:false});

См. подробности здесь из документации NodeJs: https://nodejs.org/dist/latest-v5.x/docs/api/stream.html#stream_readable_pipe_destination_options

Надеюсь, это поможет кому-то еще столкнуться с этой проблемой.

Вы можете сделать это с помощью fork()

Я только что решил это для себя ... fork() - это версия спавна более высокого уровня, и в целом рекомендуется использовать fork() вместо spawn().

если вы используете опцию {silent:true}, stdio будет передаваться родительскому процессу

          const cp = require('child_process');

          const n = cp.fork(<path>, args, {
              cwd: path.resolve(__dirname),
              detached: true,
           });

          n.stdout.setEncoding('utf8');

          // here we can listen to the stream of data coming from the child process:
          n.stdout.on('data', (data) => {
            ee.emit('data',data);
          });

          //you can also listen to other events emitted by the child process
          n.on('error', function (err) {
            console.error(err.stack);
            ee.emit('error', err);
          });

          n.on('message', function (msg) {
            ee.emit('message', msg);
          });

          n.on('uncaughtException', function (err) {
            console.error(err.stack);
            ee.emit('error', err);
          });


          n.once('exit', function (err) {
             console.error(err.stack);
             ee.emit('exit', err);
          });