由于cluster.fork是在child_process.fork之上实现的，因此您可以使用来将消息从主服务器发送到工作服务器，而可以通过将消息从
worker.send({msg: 'test' })工作服务器发送到主服务器process.send({ msg: 'test'});。您会收到以下消息：（worker.on('message',callback)从工作人员到主服务器）和process.on('message', callback);（从主服务器到工作器）。这是我的完整示例，您可以通过浏览http：// localhost：8000
/进行测试，然后工作人员将消息发送给主服务器，主服务器将回复：
var cluster = require('cluster');var http = require('http');var numReqs = 0;var worker;if (cluster.isMaster) { // Fork workers. for (var i = 0; i < 2; i++) { worker = cluster.fork(); worker.on('message', function(msg) { // we only want to intercept messages that have a chat property if (msg.chat) { console.log('Worker to master: ', msg.chat); worker.send({ chat: 'Ok worker, Master got the message! Over and out!' }); } }); }} else { process.on('message', function(msg) { // we only want to intercept messages that have a chat property if (msg.chat) { console.log('Master to worker: ', msg.chat); } }); // Worker processes have a http server. http.Server(function(req, res) { res.writeHead(200); res.end("hello worldn"); // Send message to master process process.send({ chat: 'Hey master, I got a new request!' }); }).listen(8000);}
