Дочерние процессы

В Node.js дочерние процессы создаются для выполнения ресурсоемких операций, которые во время выполнения блокируют цикл событий основного процесса. Создаваемые дочерние процессы полностью независимы от родительского процесса и имеют свои собственные экземпляры V8 и выделенные мощности процессора и объем памяти.

Для создания дочернего процесса в Node.js используется встроенный модуль child_process и его методы spawn() и fork(), каждый из которых возвращает экземпляр класса ChildProcess.

child_process.spawn()

Метод child_process.spawn() создает новый дочерний процесс (не обязательно Node.js) командой, переданной ему в качестве параметра. Вторым параметром можно передать массив аргументов команды.

app.js

const child_process = require('child_process');

//Переход в директорию /srv/app
const cd = child_process.spawn('cd'['/srv/app']);

cd.on('error', (error) =>
    console.log('Cannot change dir: \n', error)
);

//Получение списка файлов и директорий для Linux
const ls = child_process.spawn('ls');

ls.stdout.on('data', (data) =>
    console.log('Files list: \n', data)
);
ls.stderr.on('error', (error) =>
    console.log('Error: \n', error)
);

Практически всегда в качестве дополнительного процесса вам придется запускать модуль Node.js. Для этого вместо метода child_process.spawn() используйте child_process.fork().

child_process.fork()

Метод child_process.fork() является частным случаем метода child_process.spawn(), только вместо команды он принимает путь к модулю, который должен быть запущен как новый процесс. Вторым параметром передается массив аргументом для запуска модуля.

app.js

const child_process = require('child_process');

const child_3 = child_process.fork('child.js', [3]);
const child_9 = child_process.fork('child.js', [9]);

child_3.on('close', (code) =>
    console.log(`Child process 3 exited. Code: ${code}`)
);
child_9.on('close', (code) =>
    console.log(`Child process 9 exited. Code: ${code}`)
);

child.js

console.log(`Child process ${process.argv[2]} is running`);

Для запуска примера выполните команду.

node app.js

В результате в консоли вы должны увидеть следующее.

Child process 3 is running
Child process 9 is running
Child process 3 exited. Code: 0
Child process 9 exited. Code: 0

Для взаимодействия основного и дочернего процессов используется метод send(), который устанавливает между процессами IPC канал для обмена сообщениями и параметром принимает данные для отправки другому процессу. Переданные данные являются аргументами для callback-функции, определяемой для обработки сообщения.

app.js

const child_process = require('child_process');

const child = child_process.fork('child.js');

child.send('Ping child');

child.on('message', (code) =>
    console.log(`Message to parent: ${code}`)
);

child.on('close', (code) =>
    console.log(`Child process exited. Code: ${code}`)
);

child.js

console.log(`Child process is running`);

process.on('message', (message) =>
    console.log('Message to child: ', message)
);

process.send('Ping parent');

Результат должен быть таким.

Child process is running
Message to child:  Ping child
Message to parent: Ping parent

Завершение дочернего процесса можно инициировать вызовом метода disconnect() или exit(). Вызов disconnect() закроет IPC канал для обмена сообщениями, сгенерирует событие disconnect и завершит процесс после выполнения всех его операций.

Внесем изменения в предыдущий пример в файл child.js.

console.log(`Child process is running`);

process.on('message', (message) =>
    console.log('Message to child: ', message)
);

process.send('Ping parent');
process.exit();

Теперь в консоли должна быть выведена дополнительная строка.

Child process exited. Code: 0

Комментарии