Azure Service Bus：如何分别获取待处理与处理中消息的数量

嘿，这个问题我之前也碰到过，完全可以分开拿到这两类消息的统计数据，给你两种实用的方案：

1. 通过管理接口或SDK获取精准计数 #

Azure Service Bus的管理体系其实提供了更细粒度的消息统计属性，你之前查到的activeMessageCount确实是合并了待处理和正在处理的消息，但实际上有两个关键属性可以单独获取：

• activeMessageCount：队列里处于待处理状态的消息（还没被任何客户端接收，无锁定状态）
• inFlightMessageCount：正在处理中的消息（已被客户端接收并锁定，但还没完成Complete/Abandon/Deadletter操作）

用Management API调用的方式 #

发送GET请求到队列的管理端点：

GET https://<你的命名空间>.servicebus.windows.net/<目标队列>/?api-version=2021-11-01

返回的JSON响应里，就能找到activeMessageCount和inFlightMessageCount这两个字段，对应两类消息的数量。

用.NET SDK的方式（其他语言SDK逻辑类似） #

使用ServiceBusAdministrationClient可以轻松获取这些属性：

using Azure.Messaging.ServiceBus.Administration;

var connectionString = "你的Service Bus连接字符串";
var queueName = "目标队列名称";

var adminClient = new ServiceBusAdministrationClient(connectionString);
var queueProps = await adminClient.GetQueueAsync(queueName);

// 待处理消息数
long pendingCount = queueProps.ActiveMessageCount;
// 正在处理消息数
long inFlightCount = queueProps.InFlightMessageCount;

2. 通过Peek消息时区分状态 #

如果你是用Peek方法获取消息后想区分两类状态，可以检查消息的**LockedUntilUtc**属性：

• 如果LockedUntilUtc的值是过去的时间（或默认最小值），说明这条消息是待处理状态，没被任何客户端锁定
• 如果LockedUntilUtc是未来的时间，说明这条消息已经被客户端接收并锁定，处于正在处理的状态

比如.NET中处理Peek到的消息：

using Azure.Messaging.ServiceBus;

var client = new ServiceBusClient(connectionString);
var receiver = client.CreateReceiver(queueName);

var peekedMessages = await receiver.PeekMessagesAsync(10);
foreach (var msg in peekedMessages)
{
    if (msg.LockedUntilUtc <= DateTimeOffset.UtcNow)
    {
        // 待处理消息
        Console.WriteLine($"待处理消息ID: {msg.MessageId}");
    }
    else
    {
        // 正在处理消息
        Console.WriteLine($"正在处理消息ID: {msg.MessageId}，锁定到期时间: {msg.LockedUntilUtc}");
    }
}

这样就能完美区分开两类消息啦！

内容的提问来源于stack exchange，提问作者Venkatesh Laguduva