使用 azure-sb 的并行消息处理

Question

serviceBusService.receiveQueueMessage() 在并行处理方面的行为是什么？不幸的是，在简短的 Microsoft 文档中找不到任何内容。

单例侦听器或具有最大活动消息数的异步处理程序？

Answer 1

serviceBusService.receiveQueueMessage 将接收一条消息并对其进行处理。如果你愿意，你可以有逻辑来并行调用这个方法，但问题可能是，如果你有很长的处理消息并且你的拉动速度比处理速度快，你可能会遇到麻烦，或者你需要管理自己拉动的数量。

看起来有新的库 [@azure/service-bus][1]，您可以在其中 register message handlers 处理多条消息

const myMessageHandler = async (message) => {
  // your code here
};
const myErrorHandler = (error) => {
  console.log(error);
};
receiver.registerMessageHandler(myMessageHandler, myErrorHandler, {maxConcurrentCalls: 10});

使用 azure-sb 的并行消息处理

Parallel message handling using azure-sb

javascript

azure

node.js

azureservicebus