Asp.Net Core 轻松学-常用异步的你,可能须要看看这个文章

前言

事情的原由是因为一段简单的数据库链接代码引发,这段代码从语法上看,是没有任何问题;可是就是莫名其妙的报错了,这段代码极其简单,就是打开数据库链接,读取一条记录,而后当即更新到数据库中。可是,惨痛的事实证实,老司机也是会翻车的。git

1. 异常的发生来得太忽然

1.1 引发不温馨的代码片断
[HttpPut]
        public async void Put([FromBody] TopicViewModel model)
        {
            var topic = this.context.Topics.Where(f => f.Id == model.Id).FirstOrDefault();
            topic.Content = model.Content;
            this.context.Update(topic);
            var affrows = await this.context.SaveChangesAsync();
        }

这是一段不太标准的异步接口,可能你也这么写过, 从结构和语法上看,这段代码没有任何问题,并且正常状况下,它还能执行成功github

1.2 报错信息

从报错信息中能够看出,数据库上下文对象被销毁了,是在何时销毁的呢,经过跟踪程序,了解到,是在 this.context.Update(topic); ,调用 Update 后执行了 DbContext.Dispose(),为了证实这点,咱们重写 DbContext.Dispose() 方法,并简单的输出一句话数据库

1.3 重写 DbContext.Dispose()
public class ForumContext : DbContext
    {
        public ForumContext(DbContextOptions<ForumContext> options) : base(options)
        {

        }

        public DbSet<Topic> Topics { get; set; }
        public DbSet<Post> Posts { get; set; }

        public override void Dispose()
        {
            base.Dispose();

            Console.WriteLine("Dispose");
        }
    }
1.4 再次执行程序,查看结果

经过输出结果红色方框处能够看到,确实是在执行了 Update 之后执行了 Dispose 方法,关于这点,若是咱们使用了同步方法,先 Update 再 SaveChanges ,这是没有任何问题的,理论上说,EFCore 中启用了 AutoDetectChangesEnabled,咱们在上面的代码中其实无需调用 Update,直接 SaveChangesAsync 便可,也不会抛出异常,同理,若是是在同步方法中,先执行 Update 再 SaveChanges ,也是没有任何问题的异步

1.5 同步 SaveChanges
[HttpPut]
        public void Put([FromBody] TopicViewModel model)
        {
            var topic = this.context.Topics.Where(f => f.Id == model.Id).FirstOrDefault();
            topic.Content = model.Content;
            this.context.Update(topic);
            Console.WriteLine("Updated");
            var affrows = this.context.SaveChanges();
            Console.WriteLine("affrows:{0}", affrows);
        }
  • 输出结果

从输出结果可知,先执行了 Update,而后执行了 SaveChanges 输出 affrows,最后执行了 Dispose 方法async

2. 问题所在

那究竟是什么问题引发了程序执行的不肯定性呢,答案就是 async/await,咱们先来尝试改进一下最初的代码ide

2.1 改进后的代码
[HttpPut]
        public async Task Put([FromBody] TopicViewModel model)
        {
            var topic = this.context.Topics.Where(f => f.Id == model.Id).FirstOrDefault();
            topic.Content = model.Content;
            this.context.Update(topic);
            Console.WriteLine("Updated");
            var affrows = await this.context.SaveChangesAsync();
            Console.WriteLine("affrows:{0}", affrows);
        }

细心的你已经发现,这段代码和 1.1 之中的没有太多的不一样,无非是增长了一些跟踪信息,其中,最关键的是:增长了返回值为:Task ,替换了 voidthis

2.2 再次执行修正的程序

输出结果和 1.5 中的同步方法彻底相同,至此,问题解决code

3. 问题的解决方案

3.1 问题分析

为何会发生这种问题呢,缘由就是由于使用了异步方法 async/await 时,当没有值须要返回时,使用了 void 形成的,正确的作法是若是没有返回值,则返回 Task,若是有返回值,则使用 Task ;当一个异步方法内部没有返回 Task 的时候,基于任务的异步模式(TAP)并不知道异步任务的状态,当 this.context.Update 执行完成后,发现挂载在内存中的链接已经没有使用,就执行了回收;实际上,此时程序尚未执行完成,可是 TAP 并不知道,因此它不会去阻止这个回收的过程(使用标记),因此 async/await 应该成对出现,而且应该始终返回 Task 或者 Task ,以确保 TAP 可以将上下文进行正确的挂载,不然,当异常发生时,TAP 无非将异常信息挂载到相应的 Task 上,亦没法跟踪其执行状态等信息 对象

3.2 解决方案

请牢记下面的铁律blog

  • 3.2.1 在 EFCore 中,应当始终发挥 AutoDetectChangesEnabled 的特性,不要再更新实体的时候去调用 Update 方法
  • 3.2.2 使用 async/await 修饰方法时,应该始终返回 Task 或者 Task
  • 适当的使用同步方法,可避免异步踩坑
演示代码下载

https://github.com/lianggx/EasyAspNetCoreDemo/tree/master/Ron.TaskThird

相关文章
相关标签/搜索