0

嗨，我在我的节点应用程序中使用 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')
})

如果发布者和订阅者都在运行，上面的代码工作正常。如果我停止订阅者，当订阅者离线时，我将无法接收发布者的数据。即使订阅者关闭，我也想保留数据。我我被困在这里。任何帮助将不胜感激。

4

1 回答 1

0

请参阅zmq 文档站点上的“最后一个值缓存”模式。您可以扩展该示例，客户端首先订阅具有它收到的最新项目的模式，并使用 lvc 代理重新发送丢失的值（它必须先缓存它们）。但这可能适用于很少发生断开连接的少量缓存项目，否则 PUSH 可能是更好的选择。PUB-SUB 不打算支持缓冲。

于 2013-12-16T20:59:03.500 回答