WebApplicationFactory后台服务注册替换失效，测试环境注册残留问题

问题根源 #

• WebApplicationFactory默认会复用测试服务器实例，DI容器里的服务注册不会在每次测试后彻底重置，尤其是后台服务这种长生命周期组件，就算释放了实例，RabbitMQ的消费者连接可能还没断开，照样用旧服务实例处理消息。
• 后台服务里的RabbitMQ消费者要是单例模式，或者连接是全局持有的，测试结束后没彻底关掉连接/消费者，旧逻辑就会一直跑。

解决办法 #

1. 每个测试单独创建WebApplicationFactory实例

别共享工厂对象，每次测试都new一个，保证DI容器完全重置：

[Fact]
public async Task FirstTest1()
{
    using var factory = new WebApplicationFactory<Program>();
    // 替换IMessage为MessageTest1
    factory.WithWebHostBuilder(builder =>
    {
        builder.ConfigureServices(services =>
        {
            services.Replace(ServiceDescriptor.Scoped<IMessage, MessageTest1>());
        });
    });
    // 测试逻辑
}

[Fact]
public async Task SecondTest2()
{
    using var factory = new WebApplicationFactory<Program>();
    // 替换IMessage为MessageTest2
    factory.WithWebHostBuilder(builder =>
    {
        builder.ConfigureServices(services =>
        {
            services.Replace(ServiceDescriptor.Scoped<IMessage, MessageTest2>());
        });
    });
    // 测试逻辑
}

2. 给后台服务加异步释放逻辑，彻底关闭RabbitMQ连接

修改后台服务实现IAsyncDisposable接口，释放时关掉通道和连接：

public class RabbitMqBackgroundService : BackgroundService, IAsyncDisposable
{
    private IModel _channel;
    private IConnection _connection;

    // 原有消息监听逻辑...

    public async ValueTask DisposeAsync()
    {
        if (_channel?.IsOpen == true)
        {
            await _channel.CloseAsync();
            _channel.Dispose();
        }
        if (_connection?.IsOpen == true)
        {
            await _connection.CloseAsync();
            _connection.Dispose();
        }
        GC.SuppressFinalize(this);
    }
}

3. 强制WebApplicationFactory每次创建新服务器

自定义工厂子类，重写CreateHost方法，确保后台服务每次测试都重新注册：

public class CustomWebApplicationFactory : WebApplicationFactory<Program>
{
    protected override IHost CreateHost(IHostBuilder builder)
    {
        builder.ConfigureServices(services =>
        {
            // 把后台服务改成瞬态，每次测试都生成新实例
            services.Replace(ServiceDescriptor.Transient<IHostedService, RabbitMqBackgroundService>());
        });
        return base.CreateHost(builder);
    }
}

4. 测试前清空RabbitMQ队列

避免旧消息干扰测试，每次测试前清空目标队列：

private async Task ClearQueue(string queueName)
{
    var factory = new ConnectionFactory();
    using var connection = factory.CreateConnection();
    using var channel = connection.CreateModel();
    channel.QueuePurge(queueName);
}

[Fact]
public async Task FirstTest1()
{
    await ClearQueue("test-queue");
    // 测试逻辑
}

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