(Fluent) NHibernate异步循环发布领域事件的连接异常问题

你的问题核心是领域事件处理器共享了同一个非线程安全的数据库上下文（DbContext）实例，再加上异步执行时的并发操作，导致数据库连接状态异常：

1. DbContext本身设计为非线程安全，多个异步操作同时访问同一实例会干扰连接的状态管理，引发MultipleActiveResultSets错误；
2. 开启MARS后，虽然允许同一连接上的多个结果集，但DbContext的并发访问仍会导致连接被意外关闭（比如前一个操作完成后释放了连接，后一个操作还在使用）；
3. 用.Wait()同步执行时，事件处理器串行运行，同一时间只有一个操作占用DbContext，因此不会触发并发冲突，但这种方式会阻塞线程，不是最佳实践。

1. 确保每个事件处理器使用独立的DbContext实例 #

这是最根本的解决办法，因为DbContext的生命周期应该和业务操作的边界绑定：

• 如果使用ASP.NET Core依赖注入，将DbContext的注册改为Scoped（默认就是Scoped，若之前改成了Singleton，改回默认配置即可）：

  services.AddDbContext<YourDbContext>(options => 
      options.UseSqlServer(Configuration.GetConnectionString("YourConnection")));
  

• 对于MediatR的事件处理器，若处理器是Singleton注册，可通过IServiceScopeFactory创建独立作用域来获取DbContext：

  public class YourEventHandler : INotificationHandler<YourDomainEvent>
  {
      private readonly IServiceScopeFactory _scopeFactory;
  
      public YourEventHandler(IServiceScopeFactory scopeFactory)
      {
          _scopeFactory = scopeFactory;
      }
  
      public async Task Handle(YourDomainEvent notification, CancellationToken cancellationToken)
      {
          using var scope = _scopeFactory.CreateScope();
          var userRepo = scope.ServiceProvider.GetRequiredService<IUserRepository>();
          
          // 使用独立作用域内的仓库实例执行数据库操作
          var approver = await userRepo.GetAsync(emailConfiguration.Notification.ApproverId).ConfigureAwait(false);
          // ...后续业务逻辑
      }
  }
  

2. 优雅的异步串行执行事件 #

如果暂时无法调整DbContext生命周期，可以用异步串行的方式执行事件，避免并发访问DbContext，同时保持异步非阻塞特性：

foreach (var domainEvent in domainEvents)
{
    _logger.Information("Publishing Event {@DomainEvent}", domainEvent);
    await _mediator.Publish(domainEvent, CancellationToken.None).ConfigureAwait(false);
}

3. 修正仓库/服务的生命周期配置 #

如果你的UserRepository是单例注册，它会持有同一个DbContext实例，导致并发问题。将仓库注册为Scoped，确保每次请求都获取新的仓库实例：

services.AddScoped<IUserRepository, UserRepository>();

4. 检查数据库连接字符串配置 #

确保连接字符串中的MARS配置正确，同时避免手动管理数据库连接：

Server=your-server;Database=your-db;Trusted_Connection=True;MultipleActiveResultSets=true;

注意：MARS仅允许同一连接上的多个结果集，无法解决DbContext的并发安全问题，必须配合正确的生命周期配置使用。

最推荐的方案是调整DbContext和相关服务的生命周期为Scoped，从根源上避免并发访问非线程安全的DbContext。如果因为架构限制无法调整，再考虑用异步串行的方式执行事件。

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