【发布时间】:2020-12-14 06:47:50
【问题描述】:
我正在使用 Azure 服务总线在我的 K8s 设置中跨容器发送消息。接收消息的服务的实现在 Node.js 中完成。从文档页面,这是我用来接收消息的代码。
serviceBusService.receiveQueueMessage('feedback', function(error, receivedMessage) {
if (!error) {
// Message received and deleted
console.log(receivedMessage);
//..
}
});
第一次一切正常,但第二次没有收到消息。当代码 sn-p 保存在 setInterval 块内时,它按预期工作。这似乎不是这样做的预期方式。
有什么想法可能是错的吗?
【问题讨论】:
-
我认为这是意料之中的:
receiveQueueMessage只收到一条消息 -
那么理想的实现方式应该是什么?使用 setInterval 似乎过于幼稚,浪费资源。
-
也许看看 AMQP 库?
-
好的,这对我来说是新的,我会检查一下。谢谢:)
-
@Mikhail 但我期待它能够像 firebase 一样工作。它将自动收到更改通知。
标签: javascript node.js azure azureservicebus azure-servicebus-queues