嗨,我在我的节点应用程序中使用 zeroMQ,我使用发布者和订阅者进行消息队列。下面是我的代码
Publisher.js
var zmq = require('zmq')
var publisher = zmq.socket('pub')
publisher.bind('tcp://127.0.0.1:7000', function(err) {
if(err)
console.log(err)
else
console.log("Listening on 7000...")
})
setTimeout(function() {
console.log('sent');
publisher.send("hi")
}, 1000)
process.on('SIGINT', function() {
publisher.close()
console.log('\nClosed')
})
订阅者.js
var zmq = require('zmq')
var subscriber = zmq.socket('sub')
subscriber.on("message", function(reply) {
console.log('Received message: ', reply.toString());
})
subscriber.connect("tcp://localhost:7000")
subscriber.subscribe("")
process.on('SIGINT', function() {
subscriber.close()
console.log('\nClosed')
})
如果发布者和订阅者都在运行,上面的代码工作正常。如果我停止订阅者,当订阅者离线时,我将无法接收发布者的数据。即使订阅者关闭,我也想保留数据。我我被困在这里。任何帮助将不胜感激。