ZeroMQ + NodeJ：订户未收到消息

问题描述

我的发布者（zpub.js）循环发布，如下所示。

async function publishLoop() {
    let payload = []
    _.forEach(array,(a) => {
       // process a here to generate someKey and someValue
       payload.push({someKey:someValue})
    })

  return Promise.all(payload.map(async (p) => {
    await zmqp.publish({t:'topicString',m:p})
  }))
}

zmqp.publish如下。

async publish(payload) {
    // this.sock is just a bind to tcp://127.0.0.1:4030
    await this.sock.send([payload.t,JSON.stringify(payload.m,null,null)])
    return Promise.resolve()
}

我的订户（zsub.js）是ZeroMQ网站上看到的代码版本。

const zmq = require("zeromq")
const mom = require('moment-timezone')

async function run() {
  const sock = new zmq.Subscriber

  sock.connect("tcp://127.0.0.1:4030")
  sock.subscribe("topicString")

  for await (const [topic,msg] of sock) {
    console.log(`${mom().tz('Asia/Kolkata').format('YYYY-MM-DDTHH:mm:ss.SSS')}`)
  }
}

run()

我以node zsub.js > out的身份启动我的订户。
我以node zpub.js身份启动发布者。所有消息均已成功接收。
zpub.js进程结束，但是zsub.js继续运行。当我重新运行node zpub.js时，订阅者未收到一条消息。 out中的记录数保持不变。
运行zpub.js一次或两次似乎会向订阅者传递消息（最近的消息；而不是时间戳显示的更早的消息）。

因此，我不确定在发布/订阅端要做什么，以免消息“丢失”。请告知。

解决方法

Pub-Sub本质上是不可靠的，因为没有订阅者反馈给发布者以确认已收到消息。 The guide对此进行了详细描述并提供了一些解决方案。解决方案之一是不使用Pub-Sub，而是使用Router-Dealer。这是否是可行的选择，取决于您的用例。

关于您的特定问题，订阅者最终确定与发布者的连接已丢失，并将尝试重新连接，直到重新建立连接为止。根据时间的不同，订阅者可能会错过发布者发送的初始（或全部）消息。

通常，如果发布者是沟通的稳定部分（保持在线并像服务器一样在线）并且订阅者可以来来往往（例如客户端），则Pub-Sub的效果最好。

javascript message publish-subscribe zeromq