RError.com

RError.com Logo RError.com Logo

RError.com Navigation

  • 主页

Mobile menu

Close
  • 主页
  • 系统&网络
    • 热门问题
    • 最新问题
    • 标签
  • Ubuntu
    • 热门问题
    • 最新问题
    • 标签
  • 帮助
主页 / 问题 / 1609098
Accepted
TaskMaster
TaskMaster
Asked:2025-03-21 20:38:23 +0000 UTC2025-03-21 20:38:23 +0000 UTC 2025-03-21 20:38:23 +0000 UTC

在任何测试开始之前释放 WebFactory,无需调用 DisposeAsync

  • 772

我有一个集成测试,为此我定义了一个工厂,在其中启动了一个 Postgres 容器

public class IntegrationTestsWebFactory: WebApplicationFactory<Program>,IAsyncLifetime
{
    private readonly PostgreSqlContainer _dbContainer = new PostgreSqlBuilder()
        .WithImage("postgres:alpine")
        .WithDatabase("animalAllies_tests")
        .WithUsername("postgres")
        .WithPassword("345890")
        .Build();

    protected override void ConfigureWebHost(IWebHostBuilder builder)
    {
        Environment.SetEnvironmentVariable("ADMIN__USERNAME", "Admin");
        Environment.SetEnvironmentVariable("ADMIN__EMAIL", "[email protected]");
        Environment.SetEnvironmentVariable("ADMIN__PASSWORD", "Admin123");
        
        builder.ConfigureTestServices(ConfigureDefaultServices);
    }

    protected virtual void ConfigureDefaultServices(IServiceCollection services)
    {
        var writeContext = services.SingleOrDefault(s =>
            s.ServiceType == typeof(WriteDbContext));
        
        var readContext = services.SingleOrDefault(s =>
            s.ServiceType == typeof(ReadDbContext));
        
        if(writeContext is not null)
            services.Remove(writeContext);
        
        if(readContext is not null)
            services.Remove(readContext);

        var configuration = new ConfigurationBuilder()
            .AddInMemoryCollection(new Dictionary<string, string>
            {
                { "ConnectionStrings:DefaultConnection", _dbContainer.GetConnectionString() }
            }!)
            .Build();
        
        services.AddScoped<WriteDbContext>(_ => new WriteDbContext(configuration));
        services.AddScoped<IReadDbContext>(_ => new ReadDbContext(configuration));
    }

    public async Task InitializeAsync()
    {
        await _dbContainer.StartAsync();

        using var scope = Services.CreateScope();
        
        var dbContext = scope.ServiceProvider.GetRequiredService<WriteDbContext>();
        await dbContext.Database.EnsureDeletedAsync();
        await dbContext.Database.EnsureCreatedAsync();
    }

    public new async Task DisposeAsync()
    {
        await _dbContainer.StopAsync();
        await _dbContainer.DisposeAsync();
    }
}

有一个基类,我在其中初始化测试的所有依赖项。当我尝试通过已发布的工厂对象创建范围时,会发生错误 System.ObjectDisposedException:无法访问已处置的对象。对象名称:'IServiceProvider'。可能存在什么问题?我在什么阶段可以离开工厂?我尝试调试执行,但是在调试中我没有进入由 IAsyncLifetime 实现的 DisposeAsync。

public class VolunteerTestsBase: IClassFixture<IntegrationTestsWebFactory>, IAsyncLifetime
{
    protected readonly IntegrationTestsWebFactory _factory;
    protected readonly IServiceScope _scope;
    protected readonly WriteDbContext _context;
    protected readonly Fixture _fixture;

    protected VolunteerTestsBase(IntegrationTestsWebFactory factory)
    {
        _factory = factory;
        _scope = factory.Services.CreateScope();
        _context = _scope.ServiceProvider.GetRequiredService<WriteDbContext>();
        _fixture = new Fixture();
    }

    public Task InitializeAsync()
    {
        return Task.CompletedTask;
    }

    public Task DisposeAsync()
    {
        _scope.Dispose();
        
        return Task.CompletedTask;
    }
}

课程本身和测试

public class CreateVolunteerTests : VolunteerTestsBase
{
    private ICommandHandler<CreateVolunteerCommand, VolunteerId> _sut;
    
    public CreateVolunteerTests(IntegrationTestsWebFactory factory) : base(factory)
    {
        _sut = _scope.ServiceProvider.GetRequiredService<ICommandHandler<CreateVolunteerCommand, VolunteerId>>();
    }
    
    [Fact]
    public async Task Create_volunteer()
    {
        //Arrange
        var command = _fixture.CreateVolunteerCommand();
        
        //Act
        var result = await _sut.Handle(command, CancellationToken.None);
        
        //Assert
        result.IsSuccess.Should().BeTrue();
        result.Value.Should().NotBeNull();
        
        var volunteer = await _context.Volunteers.FirstOrDefaultAsync(v => v.Id == result.Value);
        
        volunteer.Should().NotBeNull();
        volunteer.Id.Should().Be(result.Value);
    }
}
.net
  • 2 2 个回答
  • 95 Views

2 个回答

  • Voted
  1. Aybek Sultanov
    2025-03-24T20:13:59Z2025-03-24T20:13:59Z

    在您的代码中,主要问题出在 IntegrationTestsWebFactory 类的 DisposeAsync 方法中。您在此 DisposeAsync 方法的声明中使用了 new 关键字。发生的情况是,您释放了 Postgres 容器,但底层 WebApplicationFactory 基础设施并未正确释放。同时,通过其他资源释放机制(内置于xUnit和.NET中),底层WebApplicationFactory仍然释放其资源——包括IServiceProvider。然后就发生了混乱:您认为您的工厂仍然完全具有功能性,并且您尝试使用它通过 VolunteerTestsBase 类中的 factory.Services.CreateScope() 创建服务,但服务提供商已经被发布。因此解决方案很简单 - 从 DisposeAsync 方法中删除新关键字并添加对基方法的调用

    public async Task DisposeAsync()
    {
        await _dbContainer.StopAsync();
        await _dbContainer.DisposeAsync();
        await base.DisposeAsync();
    }
    

    这将按照正确的顺序释放资源 - 首先是您自己的(Postgres 容器),然后是底层的 WebApplicationFactory 资源。这样,所有内容将以协调的方式发布,并且不会对何时可以使用什么内容产生混淆。

    还有一点:你的错误在调试时没有出现,因为xUnit在调试模式下对对象的生命周期的管理不同,调用的顺序可能不同。这就是为什么您在调试中没有看到对 DisposeAsync 的调用——它可能稍后发生或通过不同的接口发生。

    • 0
  2. Best Answer
    TaskMaster
    2025-03-24T22:13:52Z2025-03-24T22:13:52Z

    删除配置中的所有后台服务有助于解决问题

    public class IntegrationTestsWebFactory: WebApplicationFactory<Program>,IAsyncLifetime
    {
        private readonly PostgreSqlContainer _dbContainer = new PostgreSqlBuilder()
            .WithImage("postgres")
            .WithDatabase("animalAllies_tests")
            .WithUsername("postgres")
            .WithPassword("postgres")
            .Build();
    
        private Respawner _respawner = null!;
        private DbConnection _dbConnection = null!;
    
        protected override void ConfigureWebHost(IWebHostBuilder builder)
        {
            Environment.SetEnvironmentVariable("ADMIN__USERNAME", "Admin");
            Environment.SetEnvironmentVariable("ADMIN__EMAIL", "[email protected]");
            Environment.SetEnvironmentVariable("ADMIN__PASSWORD", "Admin123");
            
            builder.ConfigureTestServices(ConfigureDefaultServices);
        }
    
        protected virtual void ConfigureDefaultServices(IServiceCollection services)
        {
            services.RemoveAll(typeof(IHostedService));
            
            services.RemoveAll(typeof(WriteDbContext));
    
            var connectionString = _dbContainer.GetConnectionString();
            
            var configuration = new ConfigurationBuilder()
                .AddInMemoryCollection(new Dictionary<string, string>
                {
                    { "ConnectionStrings:DefaultConnection", connectionString }
                }!)
                .Build();
    
            services.AddScoped<WriteDbContext>(_ =>
                new WriteDbContext(configuration));
        }
    
        public async Task InitializeAsync()
        {
            await _dbContainer.StartAsync();
    
            using var scope = Services.CreateScope();
            var dbContext = scope.ServiceProvider.GetRequiredService<WriteDbContext>();
            await dbContext.Database.MigrateAsync();
            
            _dbConnection = new NpgsqlConnection(_dbContainer.GetConnectionString());
            await InitializeRespawner();
        }
    
        private async Task InitializeRespawner()
        {
            await _dbConnection.OpenAsync();
            _respawner = await Respawner.CreateAsync(_dbConnection, new RespawnerOptions
                {
                    DbAdapter = DbAdapter.Postgres,
                    SchemasToInclude = ["public"]
                }
            );
        }
        
        public async Task ResetDatabaseAsync()
        {
            await _respawner.ResetAsync(_dbConnection); 
        }
        
        public new async Task DisposeAsync()
        {
            await _dbContainer.StopAsync();
            await _dbContainer.DisposeAsync();
            await base.DisposeAsync();
        }
    }
    
    • 0

相关问题

  • 此平台不支持 System.Data.SqlClient

  • 如何从 Net Framework 启动防火墙、电源等程序?

  • 静态常量

  • .NET 规范

  • 如何在 Windows 资源管理器中查找和打开路径

  • 在 EF Core 中创建迁移

Sidebar

Stats

  • 问题 10021
  • Answers 30001
  • 最佳答案 8000
  • 用户 6900
  • 常问
  • 回答
  • Marko Smith

    我看不懂措辞

    • 1 个回答
  • Marko Smith

    请求的模块“del”不提供名为“default”的导出

    • 3 个回答
  • Marko Smith

    "!+tab" 在 HTML 的 vs 代码中不起作用

    • 5 个回答
  • Marko Smith

    我正在尝试解决“猜词”的问题。Python

    • 2 个回答
  • Marko Smith

    可以使用哪些命令将当前指针移动到指定的提交而不更改工作目录中的文件?

    • 1 个回答
  • Marko Smith

    Python解析野莓

    • 1 个回答
  • Marko Smith

    问题:“警告:检查最新版本的 pip 时出错。”

    • 2 个回答
  • Marko Smith

    帮助编写一个用值填充变量的循环。解决这个问题

    • 2 个回答
  • Marko Smith

    尽管依赖数组为空,但在渲染上调用了 2 次 useEffect

    • 2 个回答
  • Marko Smith

    数据不通过 Telegram.WebApp.sendData 发送

    • 1 个回答
  • Martin Hope
    Alexandr_TT 2020年新年大赛! 2020-12-20 18:20:21 +0000 UTC
  • Martin Hope
    Alexandr_TT 圣诞树动画 2020-12-23 00:38:08 +0000 UTC
  • Martin Hope
    Air 究竟是什么标识了网站访问者? 2020-11-03 15:49:20 +0000 UTC
  • Martin Hope
    Qwertiy 号码显示 9223372036854775807 2020-07-11 18:16:49 +0000 UTC
  • Martin Hope
    user216109 如何为黑客设下陷阱,或充分击退攻击? 2020-05-10 02:22:52 +0000 UTC
  • Martin Hope
    Qwertiy 并变成3个无穷大 2020-11-06 07:15:57 +0000 UTC
  • Martin Hope
    koks_rs 什么是样板代码? 2020-10-27 15:43:19 +0000 UTC
  • Martin Hope
    Sirop4ik 向 git 提交发布的正确方法是什么? 2020-10-05 00:02:00 +0000 UTC
  • Martin Hope
    faoxis 为什么在这么多示例中函数都称为 foo? 2020-08-15 04:42:49 +0000 UTC
  • Martin Hope
    Pavel Mayorov 如何从事件或回调函数中返回值?或者至少等他们完成。 2020-08-11 16:49:28 +0000 UTC

热门标签

javascript python java php c# c++ html android jquery mysql

Explore

  • 主页
  • 问题
    • 热门问题
    • 最新问题
  • 标签
  • 帮助

Footer

RError.com

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

帮助

© 2023 RError.com All Rights Reserve   沪ICP备12040472号-5