Peek 如何在启用分区的服务总线队列中工作？

Question

我从 Microsoft docs 了解到，在第一次 Peek() 操作期间，任何一个可用的消息代理都会响应并发送其最旧的消息。然后在后续的 Peek() 操作中，我们可以遍历分区以查看每条增加序列号的消息。

我的问题是，在第一次 Peek() 操作期间，我会从任何第一个响应的分区中收到一条消息。是否可以保证我可以查看队列中的所有消息？

以更简单的方式，有三个分区： 分区“A”有 10 条消息，序列号从 1 到 10。 分区“B”有 10 条消息，序列号从 11 到 20。 分区“C”有 10 条消息，序列号从 21 到 30。

现在，如果我执行 Peek() 操作，如果分区“B”首先响应，我将得到的第一条消息是序列号为 11 的消息。下一个 peek 操作将查找序列号递增的消息。我不会错过来自分区“A”的消息，它的序列号为 1-10，因为它总是搜索递增的序列号，所以 peek 操作永远无法到达？

更新

QueueClient queueClient = messagingFactory.CreateQueueClient("QueueName", ReceiveMode.PeekLock);
BrokeredMessage message = null;
while (iteration < messageCount)
{
  message = queueClient.Peek(); // According to docs, Peeks the oldest message from any responding broker, and next iterations peek the message with incremented sequence number
  if (message == null)
    break;
  Console.WriteLine(message.SequenceNumber);
  iteration++;
}

上面的sn-p能保证我可以浏览一个分区队列的所有消息吗？

Answer 1

对于分区实体，序列号是相对于分区发布的。

[...]

SequenceNumber 值是分配给消息的唯一 64 位整数，因为它被代理接受和存储并用作其内部标识符。对于分区实体，最高 16 位反映分区标识符。 (https://docs.microsoft.com/en-us/azure/service-bus-messaging/message-sequencing)

因此，您无法跨分区比较序列号以查看哪个更旧。

例如，我刚刚创建了一个分区队列并将一些消息放入两个分区（按顺序）：

1. Partition 1, SequenceNumber 61924494876344321
2. Partition 2, SequenceNumber 28991922601197569
3. Partition 1, SequenceNumber 61924494876344322
4. Partition 1, SequenceNumber 61924494876344323
5. Partition 2, SequenceNumber 28991922601197570

浏览/查看消息：仅在较旧的 WindowsAzure.ServiceBus 库中可用。 PeekBatch 并不总是返回 MessageCount 属性中指定的消息数。这种行为有两个常见的原因。一个原因是消息集合的聚合大小超过了 256 KB 的最大大小。另一个原因是，如果队列或主题的 EnablePartitioning 属性设置为 true，则分区可能没有足够的消息来完成请求的消息数量。 一般来说，如果一个应用程序想要接收特定数量的消息，它应该重复调用 PeekBatch 直到它获得该数量的消息，或者没有更多消息可以查看。 （https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-partitioning，已添加重点）

因此，您应该能够反复调用 Peek / PeekBatch 以最终获取所有消息。至少，如果您使用官方 SDK。

Answer 2

无法保证返回的消息是所有分区中最旧的消息。

因此，这取决于哪个消息代理首先响应，并且将显示来自该分区的最旧消息。在您的示例中，没有关于哪个分区首先响应的一般规则，但可以保证首先显示来自该分区的最旧消息。

如果要按序列号检索消息，请使用重载的 Peek 方法 Peek(Sequencenumber)，参见：https://docs.microsoft.com/en-us/azure/service-bus-messaging/message-browsing