Async Await异步调用WebApi

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Async Await异步调用WebApi相关的知识,希望对你有一定的参考价值。

先铺垫一些基础知识

在 .net 4.5中出现了 Async Await关键字,配合之前版本的Task 来使得开发异步程序更为简单易控。
 
在使用它们之前 我们先关心下 为什么要使用它们。好比 一个人做几件事,那他得一件一件的做完,而如果添加几个人手一起帮着做
很显然任务会更快的做好。这就是并行的粗浅含义。
 
在程序中,常见的性能瓶颈在于 NetWork I/O 瓶颈 , CPU 瓶颈, 数据库I/O瓶颈,这些瓶颈使得我们的程序运行的很慢,我们想办法去优化。因为并行开发本身就加重CPU负担,所以一般将并行用来优化 由另外两种I/O造成的瓶颈。
//sync method sample
        public static void DownLoadWebPage()
        {
            //TODO  cost 5s           
            Console.WriteLine( "DownLoadWebPage on Thread:{0}", Thread.CurrentThread.ManagedThreadId);
            Thread.Sleep(5000);
            Console.WriteLine( "End downloading the page.." );
        }

        public static void LoadDatafromDB()
        {
            //TODO  cost 5s           
            Console.WriteLine( "LoadDataFromDB on Thread:{0}", Thread.CurrentThread.ManagedThreadId);
            Thread.Sleep(5000);
            Console.WriteLine( "End loading Data.." );
        }
比如这边的两个方法, 通过Thread.Sleep来模拟程序耗时5秒,那如果我们再写一个方法来调用
   public static void OurSyncJob()
        {
            Console.WriteLine( "start doing things sync" );
            DownLoadWebPage();
            LoadDatafromDB();
            //do some other things
            Console.WriteLine( "do some other things" );           
        }
很显然 会耗时超过10s钟,如果我们用task开启两个线程 同时执行 如下
       public static async Task OurAsyncJobTask()
        {
            Console.WriteLine( "start doing things async" );
            var taskA= Task.Run(() => { DownLoadWebPage(); });
            var taskB= Task.Run(() => { LoadDatafromDB(); });
            await Task.WhenAll(taskA,taskB);                  
            Console.WriteLine( "do some other things" );
        }
那执行时间只会是5s多一点, 大大提升了我们程序的性能。
 
在了解了这些基础之后,我们来接触异步程序的实际运用场景。
我们调用 WebApi的时候,因为要经过网络传输,有时候会很慢。 这时候便有了我们用异步一展身手的时候了。
我们的webapi如下
    public class ProductController : ApiController
    {
        public productRepo repo = new productRepo();
        public IEnumerable< Product> getProducts()
        {
            Thread.Sleep(5000); 
            return repo.GetAll();
        }
    }
    public class WidgetController : ApiController
    {
        public widgetRepo repo = new widgetRepo();
        public IEnumerable< Widget> getWidgets()
        {
            Thread.Sleep(5000);
            return repo.GetAll();
        }
    }
都是模拟耗时5秒钟,现在要同时调用这些api获得 数据并一起展示
    public static List <Product > TaskGetProduct()
    {
       using( HttpClient client= new HttpClient())
       {
                client.BaseAddress = new Uri( "http://localhost:52593/" );
                client.DefaultRequestHeaders.Accept.Clear();
                client.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue ("application/json" ));
                string json = client.GetString("api/Product/Products" );
                return JsonConvert.DeserializeObject< List< Product>>(json);
       }
    }
很显然 调用这个webapi要5秒多,那么我们要同时获取的时候,就要分别调用TaskGetProduct() TaskGetWidget() TaskGetGizmos()
和前面的经验一样,这要是同步的话不得15秒多。。这要如何忍受。。
很显然要异步获取
public static async Task< List< Product>> TaskGetProduct()
        {
            using( HttpClient client= new HttpClient())
            {
                client.BaseAddress = new Uri( "http://localhost:52593/" );
                client.DefaultRequestHeaders.Accept.Clear();
                client.DefaultRequestHeaders.Accept.Add( new MediaTypeWithQualityHeaderValue ("application/json" ));
                string json = await client.GetStringAsync("api/Product/Products" );
                return JsonConvert.DeserializeObject< List< Product>>(json);
            }
        }

       public static async Task< pwgVM> RunTaskGetAll()
        {
            var task1 = TaskGetItem< Product>();
            var task2 = TaskGetItem< Gizmos>();
            var task3 = TaskGetItem< Widget>();
            await Task.WhenAll(task1,task2,task3);
            pwgVM vm = new pwgVM(task1.Result,task2.Result,task3.Result);
            return vm;
        }
三个任务同时进行,花费5秒多。ok
技术分享
 
 附上源代码 
http://files.cnblogs.com/files/JasonShenW/WebApi.rar
http://files.cnblogs.com/files/JasonShenW/WebMVC.rar
 

以上是关于Async Await异步调用WebApi的主要内容,如果未能解决你的问题,请参考以下文章

在 webapi 中正确使用 await async

使用 Async /Await 调用 Web API

通过 ASP.NET Web API 有效地使用 async/await

async和await

async和await

async await 异步编程杂记