如何在C#中检查Service Bus主题是否为空？NuGet包使用遇阻求方案

看来你在使用旧版的WindowsAzure.ServiceBus NuGet包时碰到了问题——不仅创建TopicClient不顺畅，想检查主题是否为空的思路也没法落地。先给你划个重点：这个旧包已经被官方弃用了，现在推荐使用Azure.Messaging.ServiceBus这个全新的SDK，功能更完善，API也更直观。下面给你两种可行的解决方案：

第一步：切换到官方推荐的NuGet包 #

先卸载旧的WindowsAzure.ServiceBus，然后安装新包：
用Package Manager Console：

Install-Package Azure.Messaging.ServiceBus

或者.NET CLI：

dotnet add package Azure.Messaging.ServiceBus

方法一：通过管理客户端获取主题运行时统计 #

这种方法能直接拿到主题的各类消息计数（活跃、死信、延迟等），一次性判断主题是否完全为空：

using Azure.Messaging.ServiceBus.Administration;

// 初始化管理客户端，传入你的Service Bus连接字符串
var adminClient = new ServiceBusAdministrationClient("Your-Service-Bus-Connection-String");

// 获取目标主题的运行时属性
var topicRuntimeProps = await adminClient.GetTopicRuntimePropertiesAsync("Your-Topic-Name");

// 判断主题是否为空：所有类型的消息数都为0才算完全空
bool isTopicEmpty = 
    topicRuntimeProps.ActiveMessageCount == 0
    && topicRuntimeProps.DeadLetterMessageCount == 0
    && topicRuntimeProps.ScheduledMessageCount == 0
    && topicRuntimeProps.TransferDeadLetterMessageCount == 0
    && topicRuntimeProps.TransferMessageCount == 0;

Console.WriteLine($"当前主题是否为空：{isTopicEmpty}");

方法二：通过接收器Peek消息（不消费） #

如果你只关心有没有可被订阅者接收的消息，可以用ServiceBusReceiver尝试Peek一条消息，返回null就代表当前没有可消费的消息：

using Azure.Messaging.ServiceBus;

// 初始化Service Bus客户端
var serviceBusClient = new ServiceBusClient("Your-Service-Bus-Connection-String");

// 创建针对目标主题和订阅的接收器
var receiver = serviceBusClient.CreateReceiver("Your-Topic-Name", "Your-Subscription-Name");

// Peek一条消息（不会从队列/主题中移除）
var peekedMsg = await receiver.PeekMessageAsync();

// 判断是否有消息：peek不到则代表当前订阅下无可用消息
bool hasNoAvailableMessages = peekedMsg == null;

Console.WriteLine($"主题的该订阅下是否有消息：{!hasNoAvailableMessages}");

// 记得释放资源
await receiver.DisposeAsync();
await serviceBusClient.DisposeAsync();

如果你必须用旧包（不推荐） #

如果因为历史项目限制必须使用WindowsAzure.ServiceBus，创建TopicClient的正确方式是用静态工厂方法：

var topicClient = TopicClient.CreateFromConnectionString("Your-Connection-String", "Your-Topic-Name");

之后你可以用Peek()方法尝试获取消息，如果返回null就代表没有消息。但还是强烈建议迁移到新包，旧包已经停止维护，不会再有功能更新和安全补丁了。

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