Предаване на данни от дете към родител в nodejs

Вашият код работи, но като използвате пакета streamifier за създаване на поток за четене от низ, вашият комуникационен канал се затваря автоматично след предаването на този низ, което е причината да получите грешка ENOTCONN.

За да можете да изпращате множество съобщения през потока, обмислете използването на .write в него. Можете да наричате това толкова често, колкото желаете:

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

Ако искате да използвате този метод за изпращане на множество отделни съобщения (което според мен е така въз основа на вашата забележка за използване на child.send() преди), е добра идея да използвате някакъв разделителен символ, за да можете да разделяте съобщенията, когато потокът се чете в детето. В горния пример използвах нови редове за това. Полезен пакет за подпомагане на това разделяне е event-stream.

Сега, за да създадете друг комуникационен канал от детето в родителя, просто добавете още един 'pipe' към вашето 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() е версията на spawn от по-високо ниво и се препоръчва да се използва 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);
          });