Specflow+Testcontainers(.NET Core)场景间数据完整性问题咨询

我在C# SpecFlow中尝试使用Testcontainers时，发现自定义WebApplicationFactory中初始化容器时SpecFlow未等待容器启动。最终改成在BeforeFeature钩子中创建新容器并传入WebApplicationFactory类，相关代码如下：

BeforeFeature钩子代码 #

[BeforeFeature]
public static async Task BuildAndStartContainerAsync(IObjectContainer objectContainer,
    FeatureContext featureContext)
{
 var container = new PostgreSqlBuilder()
        .WithImage("postgres:15")
        .WithDatabase("customers")
        .WithUsername("customeruser")
        .WithPortBinding(5432, 5432)
        .WithPassword("AdminP003545")
        .WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(5432))
        .Build();
    try
    {
        await container.StartAsync();
        
    }
    finally
    {
        var (stdout, stderr) = await container.GetLogsAsync();
        Console.WriteLine(stdout);
    }

    var factory = new IntegrationTestFactory<Program, CustomerDBContext>(container);

    objectContainer.RegisterInstanceAs(factory, "factory");
}

自定义WebApplicationFactory代码 #

[Binding]
public class IntegrationTestFactory<TProgram, TDbContext> : WebApplicationFactory<TProgram>
    where TProgram : class where TDbContext : DbContext
{
    public PostgreSqlContainer _databaseContainer;

    public IntegrationTestFactory(PostgreSqlContainer databaseContainer)
    {
        _databaseContainer = databaseContainer;
    }
    protected override void ConfigureWebHost(IWebHostBuilder builder)
    {
        builder.ConfigureTestServices(services =>
        {
            services.RemoveDbContext<TDbContext>();
            var conn = _databaseContainer.GetConnectionString();
            services.AddDbContext<TDbContext>(options => { options.UseNpgsql(conn); });
         
        });
    }
}

步骤定义类代码 #

public CustomerManagerStepsDf(IObjectContainer objectContainer,ScenarioContext scenarioContext )
{
    _scenarioContext = scenarioContext;
    
    _testFactory=objectContainer.Resolve<IntegrationTestFactory<Program,CustomerDBContext>>("factory");
    _client = _testFactory.CreateDefaultClient(new Uri("http://localhost:5160"));
}

当前遇到的问题 #

• 场景并发运行时数据完整性遭到破坏，部分场景执行失败；
• 是否应在BeforeScenario中初始化容器以保证场景专属容器与数据隔离；
• 并发运行场景时，可采用哪些策略或最佳实践来保证数据完整性？

问题解答 #

1. 场景并发数据破坏的原因
   当前在BeforeFeature级别初始化容器，该Feature下的所有并发场景会共享同一个PostgreSQL实例，场景间的数据库操作（插入、修改、删除）会互相干扰，比如场景A刚写入的数据被场景B修改，直接导致断言失败，这就是数据完整性被破坏的核心原因。

2. 是否应在BeforeScenario中初始化容器
   是的，必须在BeforeScenario钩子中初始化容器。BeforeScenario会在每个场景执行前触发，每个场景拥有独立的数据库容器，天然实现场景间的数据隔离，从根源上避免并发场景的数据污染问题。

3. 并发场景保证数据完整性的策略与最佳实践

• 每个场景独立容器（推荐方案）
  在BeforeScenario中创建专属的PostgreSQL容器，场景结束后在AfterScenario中停止并销毁容器。注意不要固定绑定5432端口（移除.WithPortBinding(5432, 5432)），Testcontainers会自动分配随机可用端口，GetConnectionString()会自动使用正确的端口，避免并发时的端口冲突。修改后的钩子代码如下：

  [BeforeScenario]
  public static async Task BuildAndStartContainerAsync(IObjectContainer objectContainer, ScenarioContext scenarioContext)
  {
      var container = new PostgreSqlBuilder()
          .WithImage("postgres:15")
          .WithDatabase("customers")
          .WithUsername("customeruser")
          .WithPassword("AdminP003545")
          .WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(5432))
          .Build();
      try
      {
          await container.StartAsync();
      }
      finally
      {
          var (stdout, stderr) = await container.GetLogsAsync();
          Console.WriteLine(stdout);
      }
  
      var factory = new IntegrationTestFactory<Program, CustomerDBContext>(container);
      objectContainer.RegisterInstanceAs(factory, "factory");
  
      // 将容器实例存入ScenarioContext，方便场景结束后销毁
      scenarioContext.Add("databaseContainer", container);
  }
  
  [AfterScenario]
  public static async Task CleanupContainerAsync(ScenarioContext scenarioContext)
  {
      if (scenarioContext.TryGetValue<PostgreSqlContainer>("databaseContainer", out var container))
      {
          await container.StopAsync();
          await container.DisposeAsync();
      }
  }
  

• 容器复用+场景间数据清理
  如果创建容器的开销过大，可以在BeforeFeature创建一个共享容器，每个场景执行前通过执行TRUNCATE TABLE（带CASCADE）或重新应用数据库迁移脚本重置数据。但这种方式需要注意：并发场景下的数据清理操作必须加锁，避免冲突，且隔离性不如独立容器彻底，适合对测试性能要求极高的场景。

• 事务回滚机制
  在每个场景开始时开启数据库事务，场景结束后直接回滚事务，不提交任何数据到数据库。这种方式性能最高，但需要确保应用代码和测试逻辑兼容事务回滚（比如避免异步操作导致事务提前提交的情况）。

• SpecFlow并行配置优化
  在specflow.json中正确配置并行执行参数，确保场景级并行：

  {
    "execution": {
      "parallel": "scenarios",
      "threadCount": 4
    }
  }
  

  同时容器创建逻辑要保证线程安全，每个场景的容器实例完全独立，避免共享状态。

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