NodeJS ZeroMQ - 生产者何时准备好在连接后发送消息？

Question

我对 zeromq 支持的模式进行了少量研究。我想描述 PUB/SUB 模式的问题，但可能我在最近的项目中也发现了这个问题，也是 PUSH/PULL 模式。我使用 NodeJS zeromq 实现。

我准备了两个示例（server.js 和 client.js）。我认识到每次重新启动服务器时来自 server.js 的第一条消息都会丢失（每 1 秒发送一次消息）。 client.js 没有收到第一条消息。这可能是由于发送消息前的时间太短造成的。当我在一段时间后（例如 1 秒）开始发送消息时，一切正常。我认为 zmq 需要一些时间来初始化发布者和订阅者之间的连接。

我想知道生产者（服务器）何时准备好为订阅的客户端发送消息。如何获取这些信息？

我不明白为什么 client.js 连接和订阅消息没有得到它，因为服务器在重启后还没有准备好支持订阅。

也许它是这样设计的。

server.js：

var zmq = require('zmq');
console.log('server zmq: ' + zmq.version);

var publisher = zmq.socket('pub');
publisher.bindSync("tcp://*:5555");

var i = 0;
var msg = "get_status OK ";
function sendMsg () {
    console.log(msg + i);
    publisher.send(msg + i);
    i++;
    setTimeout(sendMsg, 1000);
}
sendMsg();

process.on('SIGINT', function() {
    publisher.close();
    process.exit();
});

client.js：

var zmq = require('zmq');
console.log('client zmq: ' + zmq.version);

var subscriber = zmq.socket('sub');
subscriber.subscribe("get_status");

subscriber.on('message', function(data) {
    console.log(data.toString());
});
subscriber.connect("tcp://127.0.0.1:5555");

process.on('SIGINT', function() {
    subscriber.close();
    process.exit();
});

Answer 1

在 node zmq lib repo 中，您已经声明了supported monitoring events。订阅它可以让您监控您的连接，在本例中为accept 事件。但是不要忘记，您还必须在套接字to activate monitoring 上调用monitor() 函数。

你应该得到类似的结果：

var publisher = zmq.socket('pub');
publisher.on('accept', function(fd, ep) {
    sendMsg();
});
publisher.monitor(100, 0);
publisher.bindSync("tcp://*:5555");