Spring Boot集成Azure Service Bus：订阅者关联过滤器未生效问题

核心问题排查及修复方案 #

1. 删除默认规则$Default #

Azure Service Bus创建订阅时会自动生成名为$Default的规则，该规则使用TrueFilter，会接收主题下所有消息。即便添加了自定义关联过滤器，默认规则的存在会让所有消息仍流入订阅，导致自定义过滤器看似未生效。

修复操作：
在创建订阅后，手动删除默认规则：

adminClient.deleteRule("topic name", "subscriber", "$Default");

2. 确保消息属性与过滤器完全匹配 #

发送消息时，必须保证消息的自定义属性键和值与过滤器设置的完全一致（包括大小写、空格等细节）。比如你设置的过滤器属性是"X number"，发送消息时需对应设置：

ServiceBusMessage message = new ServiceBusMessage("test content");
message.getApplicationProperties().put("X number", "12345");
// 发送消息到目标主题

3. 验证规则创建的正确性 #

你的代码中规则创建逻辑是正确的，但需额外确认：

• 规则名称唯一，避免重复创建导致规则被覆盖
• 订阅创建完成后，通过Azure Portal检查订阅的规则列表，确认自定义规则已成功添加

修正后的完整代码示例 #

final String connectionString = "";
final String topicName = "topic name";
final String subscriptionName = "subscriber";
final String ruleName = "Rule name";

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

// 创建自定义关联过滤器规则
CreateRuleOptions ruleOptions = new CreateRuleOptions();
CorrelationRuleFilter correlationFilter = new CorrelationRuleFilter();
correlationFilter.getProperties().put("X number", "12345");
ruleOptions.setFilter(correlationFilter);

// 创建订阅配置
CreateSubscriptionOptions subscriptionOptions = new CreateSubscriptionOptions()
        .setAutoDeleteOnIdle(Duration.ofDays(7))
        .setMaxDeliveryCount(10)
        .setDefaultMessageTimeToLive(Duration.ofDays(2))
        .setUserMetadata("some metadata");

// 创建订阅并绑定规则
adminClient.createSubscription(topicName, subscriptionName, ruleName, subscriptionOptions, ruleOptions);

// 删除默认规则，确保只有自定义过滤器生效
adminClient.deleteRule(topicName, subscriptionName, "$Default");

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