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

Question

Я использую библиотеку кластера для запуска другого кода.

Мастер-вилки, а затем отправляет сообщение в кластер с начальным файлом, который затем начинается require() и запускается.

Я сделал перенаправления различных process.send() рабов, чтобы они могли общаться.

Моя проблема заключается в том, что у меня есть код, который долго запускается и должен получить сообщение от другого кода, чтобы начать правильно. Проблема заключается в том, что она не запускалась вовремя, process.on('message') не загружался, поэтому сообщение потеряно.

Есть ли способ узнать, когда это произойдет, поэтому я могу попытаться отправить его снова?

.________.-------------------------------. 
| master |<--------------------. message | 
|________|      |   | 
| | start      |   | 
| |_________________________. |   | 
|       | |   | 
V       V |  /
.______.     ._______. /Lost because long didn t load at time 
| long |     | short |  | 
|______|     |_______|  | 
^         | 
    |______________________________________| 

Answer 1

Вам не нужно отправлять сообщение своим работникам, где вы сообщаете им, какой файл начать. вы можете просто добавить конфигурации в то время как разветвление:

cluster.fork('yourConfig': {"fileToStart": "someFileName"}) 

, а затем в вашем работника:

var config = JSON.parse(process.env.yourConfig) 
require(config.fileToStart); 

есть также possibilty получить «онлайн» событие, когда новый работник раздвоенный. поэтому вам нужно не отправлять сообщение от своего хозяина в рабочем месте, когда он не находится в сети, просто поставите в очередь эти сообщения и отправьте их, когда ваш рабочий находится в сети. cluster.workers - один из методов работы здесь.

я думаю, что все, что вам нужно что-то я уже сделал и опубликовал в НПМ реестре:

кластер-обертка:

various-cluster

обмена сообщениями между рабочими:

msghub

репозитории github связаны, взгляните на код или просто используйте оба модули ;-)