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