Java代码无法修改Azure Service Bus主题订阅状态求助

环境与依赖 #

使用Spring Boot 2.5.0、JDK 17，为实现Service Bus主题/队列/订阅的管理操作（创建、删除、启用/禁用等），在pom.xml中添加了以下依赖：

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-core</artifactId>
    <version>1.52.0</version>
</dependency>

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-xml</artifactId>
    <version>1.1.0</version>
</dependency>

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-core-amqp</artifactId>
    <version>2.9.9</version>
</dependency>

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-core-http-netty</artifactId>
    <version>1.15.4</version>
</dependency>

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-identity</artifactId>
    <version>1.13.3</version>
</dependency>

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-messaging-servicebus</artifactId>
    <version>7.17.4</version>
</dependency>

<dependency>
    <groupId>com.azure.spring</groupId>
    <artifactId>spring-cloud-azure-starter-servicebus-jms</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jms</artifactId>
</dependency>

<dependency>
    <groupId>com.microsoft.azure</groupId>
    <artifactId>azure-servicebus</artifactId>
    <version>2.0.0-PREVIEW-5</version>
</dependency>

<dependency>
    <groupId>com.azure</groupId>
    <artifactId>azure-resourcemanager-servicebus</artifactId>
    <version>2.24.0</version>
</dependency>

<dependency>
    <groupId>com.azure.resourcemanager</groupId>
    <artifactId>azure-resourcemanager</artifactId>
    <version>2.40.0</version>
</dependency>

（注：原依赖中存在重复的azure-core，且azure-storage-blob、azure-storage-common与当前需求无关，可考虑移除；同时azure-servicebus 2.0预览版为旧SDK，建议统一使用新的azure-messaging-servicebus）

问题描述 #

编写了以下代码尝试修改订阅状态，调用后返回200 OK，但订阅状态并未从ACTIVE/DISABLED发生变更：

import com.azure.messaging.servicebus.administration.ServiceBusAdministrationClient;
import com.azure.messaging.servicebus.administration.ServiceBusAdministrationClientBuilder;

public class SubscriptionManager {
    public static void main(String[] args) {
        String connectionString = "<service-bus-connection-string>";
        String topicName = "<topic-name>";
        String subscriptionName = "<subscription-name>";

        // 创建Service Bus管理客户端
        ServiceBusAdministrationClient adminClient = new ServiceBusAdministrationClientBuilder()
            .connectionString(connectionString)
            .buildClient();

        // 调用方法更新订阅状态
        updateSubscriptionStatus(adminClient, topicName, subscriptionName, true); // true启用，false禁用
    }

    public static void updateSubscriptionStatus(ServiceBusAdministrationClient client, String topicName, String subscriptionName, boolean enable) {
        if (enable) {
            client.getSubscription(topicName, subscriptionName)
                .setStatus(com.azure.messaging.servicebus.administration.models.EntityStatus.ACTIVE);
        } else {
            client.getSubscription(topicName, subscriptionName)
                .setStatus(com.azure.messaging.servicebus.administration.models.EntityStatus.DISABLED);
        }
    }
}

问题原因与解决方案 #

问题根源 #

client.getSubscription()返回的是本地内存中的SubscriptionProperties对象，调用setStatus()只是修改了本地对象的属性，并没有将变更提交到Azure Service Bus服务端。

修正后的代码 #

需要先获取订阅的属性对象，修改状态后，调用client.updateSubscription()方法将变更提交到服务端：

import com.azure.messaging.servicebus.administration.ServiceBusAdministrationClient;
import com.azure.messaging.servicebus.administration.ServiceBusAdministrationClientBuilder;
import com.azure.messaging.servicebus.administration.models.EntityStatus;
import com.azure.messaging.servicebus.administration.models.SubscriptionProperties;

public class SubscriptionManager {
    public static void main(String[] args) {
        String connectionString = "<service-bus-connection-string>";
        String topicName = "<topic-name>";
        String subscriptionName = "<subscription-name>";

        ServiceBusAdministrationClient adminClient = new ServiceBusAdministrationClientBuilder()
            .connectionString(connectionString)
            .buildClient();

        updateSubscriptionStatus(adminClient, topicName, subscriptionName, true);
    }

    public static void updateSubscriptionStatus(ServiceBusAdministrationClient client, String topicName, String subscriptionName, boolean enable) {
        // 获取当前订阅的属性
        SubscriptionProperties subscriptionProps = client.getSubscription(topicName, subscriptionName);
        
        // 设置目标状态
        subscriptionProps.setStatus(enable ? EntityStatus.ACTIVE : EntityStatus.DISABLED);
        
        // 将变更提交到服务端
        client.updateSubscription(topicName, subscriptionProps);
    }
}

额外优化 #

1. 移除pom.xml中重复的azure-core依赖，以及与当前需求无关的azure-storage系列依赖；
2. 删除旧的azure-servicebus预览版依赖，统一使用azure-messaging-servicebus新SDK；
3. 可以添加异常处理，捕获操作中的可能错误（比如订阅不存在、权限不足等）。

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