如何通过Partition Key获取Azure Service Bus Queue指定分区的全部消息

Azure Service Bus 没有原生提供直接按Partition Key过滤拉取消息的API，你可以按照以下步骤实现需求： #

前置准备 #

• 首先确认你的队列已经开启分区功能：创建队列时勾选「启用分区」选项，只有分区队列支持Partition Key路由逻辑。
• 发送消息时必须显式设置Partition Key：同个Partition Key的所有消息会被路由到同一个分区分片，且严格保序。以.NET SDK为例，设置方式如下：

  var message = new ServiceBusMessage(Encoding.UTF8.GetBytes("消息内容"))
  {
      PartitionKey = "your_target_partition_key"
  };
  await sender.SendMessageAsync(message);
  

检索特定分区消息的两种实现方案 #

方案1：结合会话功能实现（推荐） #

这是最稳定的官方推荐实现方式，不会产生额外无效请求：

• 先为队列开启「需要会话」属性，注意该属性创建队列后无法修改。
• 发送消息时将SessionId设置为和PartitionKey完全相同的值。
• 检索消息时调用会话接收方法，直接传入你要查询的Partition Key作为SessionId，即可拉取到该分组下的所有消息，.NET SDK示例：

  var receiver = await client.AcceptSessionAsync("your_target_partition_key");
  var messages = await receiver.ReceiveMessagesAsync(maxMessages: 100);
  

方案2：手动过滤（仅适合小流量场景） #

如果队列没有开启会话功能，可以用临时拉取过滤的方式实现：

• 批量拉取队列中的消息，遍历每条消息的PartitionKey属性，匹配到目标Key后执行后续业务逻辑。
• 不匹配的消息调用AbandonAsync()方法放回队列，等待后续被其他消费者处理。

注意：该方式会产生大量无效拉取请求，增加服务端负载和消息延迟，高吞吐量场景不建议使用。

注意事项 #

• Partition Key最大长度为128字符，仅允许使用字母、数字、-、.、_、~这几个特殊字符。
• 非必要场景不要给所有消息设置相同的Partition Key，会导致流量集中在单分片，无法发挥分区队列的高吞吐能力。

内容的提问来源于stack exchange，提问作者Imran Ahmad Mughal