在我编写的一些Node.js脚本中,我注意到即使最后一行是同步调用,有时也不会在Node.js退出之前完成。
我从来没有见过console.log
语句在退出之前无法运行/完成,但我也看到过其他一些语句在退出之前无法完成,我相信它们都是同步的。当然,在这种情况下,我可以理解为什么异步函数的回调无法触发。
所讨论的代码是一个ZeroMQ .send()
调用,如下所示:
var zmq = require('zmq');
var pub = zmq.socket('pub');
pub.bindSync('tcp://127.0.0.1:5555');
setInterval(function(){
pub.send('polyglot');
},500);
如果我删除setInterval()
并像这样调用它,上面的代码就像expected...but一样工作:
var zmq = require('zmq');
var pub = zmq.socket('pub');
pub.bindSync('tcp://127.0.0.1:5555');
pub.send('polyglot'); //this message does not get delivered before exit
process.exit(0);
...Then消息将不会被传递-程序显然将在pub.send()
调用完成之前退出。
确保语句在退出Node.js之前完成的最佳方法是什么?关闭钩子可以在这里工作,但我担心这只会掩盖问题,因为您不能将确保运行所需的所有东西都放在关闭钩子中。
这个问题也可以这样演示:
if (typeof messageHandler[nameOfHandlerFunction] == 'function') {
reply.send('Success');
messageHandler[nameOfHandlerFunction](null, args);
} else {
reply.send('Failure'); //***this call might not complete before the error is thrown below.***
throw new Error('SmartConnect error: no handler for ZMQ message sent from Redis CSV uploader.');
}
我认为这是一个合法/严重的问题,因为许多程序只需要发布消息,然后就会死亡,但我们如何有效地确保所有消息都被发送(尽管不一定收到)?
编辑:修复此问题的一种(潜在)方法是:
socket.send('xyz');
socket.close(); // supposedly this will block until the above message is sent
process.exit(0);
https://stackoverflow.com/questions/29906637
复制相似问题