Java 8获取Azure Service Bus队列消息数的依赖与代码问题

一、所需Maven依赖 #

你需要引入兼容Java 8的Azure Service Bus管理SDK依赖，以下是Maven pom.xml 中的配置：

<dependency>
    <groupId>com.microsoft.azure</groupId>
    <artifactId>azure-mgmt-servicebus</artifactId>
    <version>1.41.4</version> <!-- 该版本为最后一批支持Java 8的Azure管理SDK版本，更高版本需Java 11+ -->
</dependency>
<dependency>
    <groupId>com.microsoft.azure</groupId>
    <artifactId>azure-credentials</artifactId>
    <version>1.41.4</version>
</dependency>

二、现有代码评估 #

你提供的代码逻辑是可行的，但存在几个需要优化的点：

• 需确保导入com.microsoft.azure.AzureEnvironment类，否则AzureEnvironment.AZURE会报错；
• queue.inner().messageCount()返回Integer类型，直接转为int存在空指针风险，建议先判空；
• 缺少异常处理，认证失败、资源不存在等场景会导致程序崩溃。

三、完整示例代码 #

包含异常处理和空值校验的完整实现如下：

import com.microsoft.azure.AzureEnvironment;
import com.microsoft.azure.credentials.ApplicationTokenCredentials;
import com.microsoft.azure.management.Azure;
import com.microsoft.azure.management.servicebus.Queue;
import com.microsoft.azure.management.servicebus.ServiceBusNamespace;
import com.microsoft.rest.LogLevel;

public class ServiceBusQueueMessageCounter {
    public static void main(String[] args) {
        // 替换为你的Azure资源参数
        String clientId = "你的客户端ID";
        String domain = "你的租户ID";
        String secret = "你的客户端密钥";
        String subscriptionId = "你的订阅ID";
        String resourceGroupName = "资源组名称";
        String namespaceName = "Service Bus命名空间名称";
        String queueName = "目标队列名称";

        try {
            // 初始化认证凭据
            ApplicationTokenCredentials credentials = new ApplicationTokenCredentials(
                    clientId, domain, secret, AzureEnvironment.AZURE);

            // 创建Azure客户端实例
            Azure azure = Azure.configure()
                    .withLogLevel(LogLevel.NONE)
                    .authenticate(credentials)
                    .withSubscription(subscriptionId);

            // 获取目标命名空间和队列
            ServiceBusNamespace namespace = azure.serviceBusNamespaces()
                    .getByResourceGroup(resourceGroupName, namespaceName);
            Queue targetQueue = namespace.queues().getByName(queueName);

            // 安全获取消息数
            Integer messageCount = targetQueue.inner().messageCount();
            System.out.println("队列消息数：" + (messageCount != null ? messageCount : 0));

        } catch (Exception e) {
            System.err.println("获取消息数失败：" + e.getMessage());
            e.printStackTrace();
        }
    }
}

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