我编写了代码(Node Js),通过它我接收消息并将其发送到服务总线队列。但是,当我在一个循环中使用 5000 条消息对其进行测试时,它会失败,队列中只有几条超过 1000 条消息。
并发失败
这是我在 message.js 文件中的消息代码函数
queueMessage = (messageBody) => {
async function main()
{
try{
const sbClient = ServiceBusClient.createFromConnectionString(connectionString);
const queueClient = sbClient.createQueueClient(queueName)
const sender = queueClient.createSender();
sender.send({
body:messageBody,
// sessionId:'my-session'
});
console.log('message sent to the queue')
}
catch(err){
console.log(err)
}
}
main()
.catch(err=>console.log(err))
}