求助：基于MassTransit Azure Service Bus的测试中止订阅清理方案

针对测试中止（手动/自动）导致MassTransit创建的Service Bus订阅无法自动移除的问题，结合你的技术栈（XUnit+SpecFlow+MassTransit+Azure Service Bus），可以通过以下几种方式解决：

1. 给动态创建的ReceiveEndpoint单独设置AutoDeleteOnIdle #

你之前在Bus级别设置的AutoDeleteOnIdle仅作用于MassTransit内部的控制队列，不会覆盖动态创建的ReceiveEndpoint对应的订阅。需要在创建ReceiveEndpoint时显式配置该属性，确保订阅在闲置后快速被Azure Service Bus自动删除：

修改你的SetupConsumer<TEventType>方法：

public async Task SetupConsumer<TEventType>(Action<ConsumeContext<TEventType>> handler)
where TEventType : class
{
    var handle = Bus!.ConnectReceiveEndpoint(endpoint =>
    {
        // 给当前订阅设置闲置自动删除时间（比如1分钟，可根据测试调整）
        endpoint.AutoDeleteOnIdle = TimeSpan.FromMinutes(1);
        endpoint.Handler<TEventType>(context =>
        {
            handler(context);
            return Task.CompletedTask;
        });
    });
    await handle.Ready;
}

这样即使测试进程突然终止，订阅在1分钟无活动后会被Azure自动清理，避免残留。

2. 利用XUnit的异步销毁机制确保Bus正常停止 #

XUnit的IAsyncDisposable接口会在测试类/集合生命周期结束时自动调用，即使测试中途中止。可以把Bus的管理逻辑放到Fixture类中：

public class ServiceBusTestFixture : IAsyncDisposable
{
    public IBusControl Bus { get; private set; }

    public async Task InitializeAsync()
    {
        Bus = MassTransit.Bus.Factory.CreateUsingAzureServiceBus(config =>
        {
            config.Host("<connection string goes here>");
        });
        await Bus.StartAsync();
    }

    public async ValueTask DisposeAsync()
    {
        if (Bus != null)
            await Bus.StopAsync();
    }
}

然后在测试类中使用IClassFixture<ServiceBusTestFixture>：

public class YourFeatureTests : IClassFixture<ServiceBusTestFixture>
{
    private readonly ServiceBusTestFixture _fixture;

    public YourFeatureTests(ServiceBusTestFixture fixture)
    {
        _fixture = fixture;
    }

    // 测试方法中使用_fixture.Bus
}

XUnit会保证即使测试崩溃，DisposeAsync也会被触发，从而正常停止Bus，MassTransit会主动删除创建的订阅。

3. 结合SpecFlow的钩子强制执行清理 #

在SpecFlow的共享上下文或StepDefinition中添加AfterScenario钩子，确保无论场景成功/失败/中止，都调用StopBusAsync：

[Binding]
public class ServiceBusHooks
{
    private readonly YourSharedContext _context;

    public ServiceBusHooks(YourSharedContext context)
    {
        _context = context;
    }

    [AfterScenario]
    public async Task CleanupAfterScenario()
    {
        await _context.StopBusAsync();
    }
}

同时，建议在共享上下文类中实现IAsyncDisposable作为兜底：

public class YourSharedContext : IAsyncDisposable
{
    private IBusControl? Bus { get; set; }

    // ... 你的SetupBusAsync、SetupConsumer方法 ...

    public async Task StopBusAsync()
    {
        if (Bus != null)
            await Bus.StopAsync();
    }

    public async ValueTask DisposeAsync()
    {
        await StopBusAsync();
    }
}

SpecFlow会在场景结束时自动处理实现了IAsyncDisposable的上下文对象。

4. 兜底：手动清理脚本 #

如果以上方法仍有残留，可以编写一个简单的清理工具，使用Azure Service Bus SDK批量删除测试相关的订阅（建议给测试订阅设置统一命名前缀，比如test-）：

using Azure.Messaging.ServiceBus.Administration;

public static async Task CleanupTestSubscriptions(string connectionString, string topicPrefix = "test-")
{
    var adminClient = new ServiceBusAdministrationClient(connectionString);
    var topics = adminClient.GetTopicsAsync();
    
    await foreach (var topic in topics)
    {
        if (topic.Name.StartsWith(topicPrefix))
        {
            var subscriptions = adminClient.GetSubscriptionsAsync(topic.Name);
            await foreach (var subscription in subscriptions)
            {
                await adminClient.DeleteSubscriptionAsync(topic.Name, subscription.Name);
            }
            await adminClient.DeleteTopicAsync(topic.Name);
        }
    }
}

可以把这个脚本加到测试套件的初始化步骤，或者定期运行清理测试环境。

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