0
  • 我编写了代码(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))


}
4

0 回答 0