
问题如上,重要的代码如下:
--------------------app.js----------------------
var pm2 = require("pm2") var process = require("process")
process.on('message', function (packet) { console.log("---------packet-------------:\n", packet); });
pm2.connect(function (err) { if (err) { console.error(err); process.exit(2); }
pm2.start({ script: './config-service/config.js' // config.js 是一个 express 的 api }, function (err, apps) { pm2.list(function (err, list) { for (let i = 0; i < list.length; i++) { console.log("list[i].name:", list[i].name); if (list[i].name == "saas-config") { pm2.sendDataToProcessId(list[i].pm2_env.pm_id, { type: 'process:msg', data: { msg: 'hello from pm2' }, topic: "pm2 message" }, function (err, res) { console.log(err); }); break; } } pm2.disconnect(); }); if (err) throw err }); });
--------------------config-service/config.js---------------------------
var express = require('express') var process = require("process") app = express()
app.use(function (err, req, res, next) { console.log(' express app error:', err) res.status(500).send({ error: 'something blew up' }); });
var server = app.listen(0);//选择一个随机端口 server.on('listening', function () { var port = server.address().port console.log('**** [ service ] **** \nListening on port %d', port) //console.log("process.send:",process.send); process.send({ type: 'process:msg', data: { listenPort: port } });
})
process.on('message', function(packet) { console.log("message in config.js :\npacket:",packet); });
启动 app.js 后,能在控制台看到: PM2 | Starting execution sequence in -fork mode- for app name:config id:0 PM2 | App name:config id:0 online 0|saas-con | **** [ service ] **** 0|saas-con | Listening on port 30960 0|saas-con | message in config.js : 0|saas-con | packet: { type: 'process:msg', 0|saas-con | data: { msg: 'hello from pm2' }, 0|saas-con | topic: 'pm2 message', 0|saas-con | id: 0 }
我的想法是, config api 启动之后, 发一个消息给 pm2 , 其中包含其使用的端口, 然后 pm2 收到消息之后,再启动其他的一些服务,带上这个 config api 的端口号。
但目前的情况是, pm2 发出的消息, config 中能打印出来,但在 pm2 中收不到在 config 中发出的消息。 请教一下大家,这样的需求能否做到? 或者我的代码哪里有问题, 拜谢