MassTransit搭配Azure Service Bus移除消费者后残留队列如何处理

首先纠正认知偏差：你之前理解的Auto-delete配置作用是错的，Azure Service Bus 原生的AutoDeleteOnIdle属性是直接作用于队列/订阅实体本身的，并非仅清理队列内消息，配置正确即可实现闲置队列自动删除，是解决这个问题的官方标准方案。

具体配置方法 #

在配置MassTransit接收端点时，直接为队列设置AutoDeleteOnIdle属性即可，参考代码如下：

services.AddMassTransit(x =>
{
    x.AddConsumer<ConsumerA>();
    x.AddConsumer<ConsumerB>();

    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("你的ASB连接字符串");
        
        // 配置消费者A对应的接收端点
        cfg.ReceiveEndpoint("consumer-a-queue", e =>
        {
            // 队列闲置超过10分钟无任何连接/操作时，自动删除队列实体
            // 注意：Azure Service Bus 要求该值最小为5分钟，低于该值会抛出配置错误
            e.AutoDeleteOnIdle = TimeSpan.FromMinutes(10);
            e.ConfigureConsumer<ConsumerA>(context);
        });

        // 其他消费者端点按相同规则配置即可
        cfg.ReceiveEndpoint("consumer-b-queue", e =>
        {
            e.AutoDeleteOnIdle = TimeSpan.FromMinutes(10);
            e.ConfigureConsumer<ConsumerB>(context);
        });

        cfg.ConfigureEndpoints(context);
    });
});

存量残留队列处理 #

上述配置仅会在MassTransit创建新队列时生效，配置上线前已经存在的废弃队列不会自动更新属性，需要做一次存量处理：

• 手动清理：通过Azure Portal、Service Bus Explorer或是ASB管理SDK，筛选出所有已经没有对应消费者运行的废弃队列直接删除即可，后续新创建的队列因为配置了自动删除规则，消费者下线闲置后会自动清理，不会再出现囤积消息的问题。
• 自动清理孤儿订阅：在总线配置中开启无效订阅自动移除，服务每次启动时会自动扫描当前主题下的所有订阅，删除没有绑定当前运行实例消费者的无效订阅，从路由层面阻断消息发往废弃队列：

cfg.ConfigureServiceBusEndpoints(context, opt =>
{
    opt.RemoveInvalidSubscriptions = true;
});

配置注意事项 #

• AutoDeleteOnIdle不要设置过短，建议至少设置为10分钟以上，覆盖服务发版重启、临时故障恢复的时间窗口，避免服务短暂停机时队列被误删导致消息丢失。
• 不要将消息级TTL和队列级AutoDeleteOnIdle配置混淆：消息TTL控制单条消息在队列中的最长存活时间，队列AutoDeleteOnIdle控制整个队列实体闲置后的自动删除逻辑，二者作用层级完全不同。
• 如果你的服务采用弹性扩缩容架构，临时实例对应的专属队列可以适当调短AutoDeleteOnIdle时长，避免缩容后残留大量实例队列囤积消息。

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