实体框架核心在异步方法上失败

Question

我在 EF Core 中使用异步方法 - 通过内置 DI 获取上下文

 public async Task<bool> Upvote(int userId, int articleId)
{
    var article = await context.Articles
                               .FirstOrDefaultAsync(x => x.Id == articleId);
    if (article == null)
    {
        return false;
    }

    var existing = await context.Votes
                                .FirstOrDefaultAsync(x => x.UserId == userId
                                                       && x.ArticleId == articleId);
    if (existing != null)
    ...

当有人点赞一篇文章时运行。

如果这个函数一次运行一个（一个接一个），一切运行良好。

当我同时多次点击这个函数时，我得到了这个异常：

fail: Microsoft.EntityFrameworkCore.Query.Internal.MySqlQueryCompilationContextFactory[1]
      An exception occurred in the database while iterating the results of a query.
      System.NullReferenceException: Object reference not set to an instance of an object.
         at Microsoft.EntityFrameworkCore.Query.Internal.AsyncQueryingEnumerable.AsyncEnumerator.<BufferAllAsync>d__12.MoveNext()
      --- End of stack trace from previous location where exception was thrown ---
         at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
         at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)

断点命中： var existing = await context.Votes.FirstOrDefaultAsync(x => x.UserId == userId && x.ArticleId == articleId);

我也收到此错误：Message [string]:"A second operation started on this context before a previous operation completed. Any instance members are not guaranteed to be thread safe."

有哪些可能的解决方案？

编辑 1： 这就是我设置上下文的方式： 在 Startup.cs 中，我配置了上下文：

public void ConfigureServices(IServiceCollection services)
{
    services.AddDbContext<ArticlesContext>(options => 
        options.UseMySql(Configuration.GetConnectionString("ArticlesDB")));
...

然后我将它注入到包含类的构造函数中：

private ArticlesContext context;
private ILoggingApi loggingApi;

public VoteRepository(ArticlesContext context, ILoggingApi loggingApi)
{
    this.context = context;
    this.loggingApi = loggingApi;
}

编辑 2： 我一直在等待通过以下方式到达控制器：

public async Task<bool> Upvote(int articleId)
{
    return await this.votesRepository.Upvote(userId, articleId);
}

然后在控制器中...

[HttpPost]
[Route("upvote")]
public async Task<IActionResult> Upvote([FromBody]int articleId)
{
    var success = await votesService.Upvote(articleId);
    return new ObjectResult(success);
}

编辑 3：

我已将我的服务/存储库更改为瞬态而不是单例，但现在我遇到了另一个问题：

public int getCurrentUserId()
{
    if (!httpContextAccessor.HttpContext.User.HasClaim(c => c.Type == "UserId"))
    {
        return -1;
    }

这是同样的异步问题 - 但这次，HttpContext 为空。 我通过

注入上下文访问器

public UserService(IUserRepository userRepository, IHttpContextAccessor httpContextAccessor)
{
    this.userRepository = userRepository;
    this.httpContextAccessor = httpContextAccessor;
}

Answer: IHttpContextAccessor 需要注册为单例而非瞬态 services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();

Answer 1

应使用 Scoped 生命周期将实体框架添加到服务容器中，应将 repo 和服务配置为瞬态，以便根据需要创建和注入新实例，并保证实例不会被重用。

EF 应该有范围，以便在每个请求上创建它并在请求结束后释放它。

按照这些准则，我认为将注入的实例存储在控制器构造函数上没有问题。控制器应该在每个请求上实例化，并在请求结束时连同所有作用域注入的实例一起处理。

This Microsoft docs page explains all this.

Answer 2

其他一些代码同时使用相同的context。检查this question and answer。

如果包含Upvote 方法的类是单例的 - 请检查您是否没有在构造函数中存储context，而是应该从IServiceProvider (HttpContext.RequestServices) 为每个请求（范围）获取它，或者传递它作为参数。