使用 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});