EF6迁移EF Core遇DbContext共享问题：多线程操作冲突报错

这个错误我在帮开发者从EF6迁移到EF Core时遇到过很多次，核心原因很明确：EF Core的DbContext实例从设计上就不是线程安全的。哪怕你把它注册为Scoped服务，只要同一个实例被多个线程同时执行数据库操作（比如并行异步调用、阻塞式异步等待），就会触发这个异常。结合你的场景和报错代码，给你几个可落地的解决步骤：

1. 修复异步代码中的阻塞调用（最常见原因） #

很多时候这个错误是因为你在异步代码里用了.Result或.Wait()来阻塞等待，而不是正确的await。这种阻塞会导致DbContext被卡在主线程，同时其他线程又尝试使用同一个实例。

错误示例： #

// 用.Result阻塞，导致上下文被多线程同时访问
var data = _dbContext.Query<EntityModel>().FromSql(query, new SqlParameter("@userId", userId)).ToListAsync().Result;

正确写法： #

// 用await确保操作串行执行，同一时间只有一个操作在DbContext上运行
var data = await _dbContext.Query<EntityModel>().FromSql(query, new SqlParameter("@userId", userId)).ToListAsync();

如果你的代码里有多个异步操作，一定要用await逐个等待，不要并行调用未加处理的异步方法。

2. 并行操作时使用独立的DbContext实例 #

如果你需要并行处理多个请求（比如批量处理用户数据），绝对不能共享同一个Scoped DbContext。此时应该使用IDbContextFactory<T>来为每个并行任务创建独立的上下文实例（EF Core 3.1及以上版本支持）。

步骤： #

1. 注册DbContext工厂：

// 在Program.cs中注册
builder.Services.AddDbContextFactory<YourDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("YourConnectionString")));

2. 在服务中注入工厂并创建独立上下文：

private readonly IDbContextFactory<YourDbContext> _contextFactory;

public YourService(IDbContextFactory<YourDbContext> contextFactory)
{
    _contextFactory = contextFactory;
}

public async Task ProcessBatchUsersAsync(List<int> userIds)
{
    // 为每个用户创建独立的上下文实例
    var tasks = userIds.Select(async userId =>
    {
        using var context = _contextFactory.CreateDbContext();
        var data = await context.Query<EntityModel>().FromSql(query, new SqlParameter("@userId", userId)).ToListAsync();
        // 处理当前用户的数据
    });

    await Task.WhenAll(tasks);
}

这样每个并行任务都有自己的DbContext，不会互相干扰。

3. 避免嵌套的客户端查询 #

错误提示里也提到了另一种可能：嵌套查询在客户端执行。比如你的查询中包含了在客户端求值的嵌套方法调用，而这个方法内部又使用了同一个DbContext，导致隐式的并发操作。

错误示例： #

// Select中的GetRelatedData方法内部使用了同一个DbContext，导致客户端求值时并发访问
var data = _dbContext.Query<EntityModel>()
                     .FromSql(query, new SqlParameter("@userId", userId))
                     .Select(e => new 
                     {
                         e.Id,
                         RelatedData = GetRelatedData(e.Id) // 这里会触发客户端查询
                     })
                     .ToList();

解决方法： #

重写查询，让所有操作在数据库端执行，或者先获取主数据，再单独查询关联数据：

// 先获取主数据
var mainData = await _dbContext.Query<EntityModel>().FromSql(query, new SqlParameter("@userId", userId)).ToListAsync();
// 再批量查询关联数据
var relatedIds = mainData.Select(e => e.Id).ToList();
var relatedData = await _dbContext.Query<RelatedModel>()
                                 .Where(r => relatedIds.Contains(r.EntityId))
                                 .ToListAsync();
// 手动关联主数据和关联数据
foreach(var item in mainData)
{
    item.RelatedData = relatedData.Where(r => r.EntityId == item.Id).ToList();
}

4. 确认DbContext的注册范围 #

最后再检查一下你的DbContext注册是否真的是Scoped。有时候不小心会把它注册成Singleton，这会导致所有请求共享同一个实例，必然触发并发错误。

正确的Scoped注册： #

builder.Services.AddDbContext<YourDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("YourConnectionString")));

错误的Singleton注册（绝对要避免）： #

// 不要这样做！
builder.Services.AddDbContext<YourDbContext>(options => 
    options.UseSqlServer(builder.Configuration.GetConnectionString("YourConnectionString")), 
    ServiceLifetime.Singleton);

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