如何使用带有N个ode.js?的Azure服务总线监听队列

Question

我有几个客户端向Azure服务总线队列发送消息。为了匹配它，我需要几台机器从该队列中读取消息，并在消息到达时使用Node.js.

我已经阅读了azure service bus队列教程，我知道我可以使用receiveQueueMessage从队列中读取消息。

但是，本教程没有提到如何在消息到达时收听队列并读取消息。

我知道我可以简单地轮询消息队列，但是这会给服务器发送垃圾邮件，没有真正的好处。

在SO中搜索后，我发现了一个讨论，其中有人有类似的问题：

• 侦听队列（事件驱动无轮询）服务总线/存储队列

我知道他们最终使用了C#async方法ReceiveAsync，但我不清楚是否：

1. 该方法可用于节点。js

Node.js的留档几乎不存在，那一个教程是我找到的唯一主要文档。

1. 如何在Azure总线服务队列中通知我的工作人员传入消息？

Answer 1

您可以使用“ServiceBusQueueTrigger”的无服务器函数，消息到达队列时会立即调用这些函数，

在nodejs中非常简单，您需要在函数中定义绑定。类型为的json

“类型”：“ServiceBustigger”，

本文(https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus#trigger---（javascript示例）可能会更详细地提供帮助。

Answer 2

我问了我自己同样的问题，以下是我的发现。

使用谷歌PubSub，它完全符合你的要求。

如果你想继续使用Azure，以下是可能的：

• 可以从SBS消息触发云函数
• 使用该云函数触发事件中心事件
• 接收事件并从SBS获取消息

Answer 3

根据Azure支持，当队列收到消息时，不可能收到通知。这对每种语言都有效。

这个问题有两个主要的工作：

>

连续投票。让客户端每X秒检查一次队列。这个解决方案很可怕，因为你最终支付了你产生的网络流量，并且用无用的请求来垃圾邮件服务。为了最大限度地减少这种情况，有一个称为长轮询的概念，它的文档记录得非常糟糕，甚至可能不存在。我确实发现了这个NPM模块：https://www.npmjs.com/package/azure-awesome-queue

老实说，在这一点上，你可能想知道为什么你应该使用这项服务。我同意。。。

作为一种选择，有RabbitMQ是免费的，有一个社区，良好的留档和一吨更多的功能。

这里的缺点是维护RabbitMQ容错集群并不是一件小事。

另一种选择是ApacheKafka，它也是非常可靠的。