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

Question

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

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

Answer 1

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

看起来有一个新的库[@azure/service-bus][1]您可以在其中注册消息处理程序来处理多条消息

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