从队列读取Azure服务总线中的所有消息

Question

我想从azure服务总线（队列）读取所有消息。

我已经按照下面的指示链接https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-php-how-to-use-queues

目前它只能获取一条消息。。

我想从服务总线（队列）获取所有消息。

提前谢谢。。

Answer 1

使用服务总线的Peek操作概念，可以读取队列中的所有消息。

MessagingFactory messagingFactory = MessagingFactory.CreateFromConnectionString(<Your_Connection_String>);
var queueClient = messagingFactory.CreateQueueClient(<Your_Queue_Name>, ReceiveMode.PeekLock); // Receive mode is by default PeekLock and hence, optional.
BrokeredMessage message = null;
while(true)
{
  message = queueClient.Peek(); // You have read one message
  if (message == null) // Continue till you receive no message from the Queue
    break; 
}

这也可以返回过期的或锁定的消息。如果邮件浏览符合您阅读邮件的要求，请快速阅读。

Answer 2

我认为不可能指定您希望从队列中读取的消息数量（至少在PHP SDK中，这当然是可能的。NET SDK）.本质上是一个包装器，用于包装Peek-Lock消息（非破坏性读取）或接收和删除消息（破坏性读取）（取决于配置）REST API方法，它们都只返回单个消息。

解决这个问题的一种方法是循环运行代码，直到从队列中没有收到任何消息。您可能遇到的问题是，您可能会返回重复的消息，因为一旦peek-lock方法获取的锁过期，消息将再次可见。