.net异步质量测试(包涵ASP.NET MVC WebAPI异步方法)

图片 1图片 2

经验教训:

 

View Code

只顾,你只怕必要接纳Nuget加多上边这一个包:

终极,运维这一个测试,结果如下:

图片 3图片 4

异步调用:

  public static async Task<string> ExecuteAIO(int sleepTime)
        {
            //await Task.Delay(sleepTime);
            //return "Hello world," + sleepTime;
            //await Task.Delay(sleepTime);
            //semaphoreSlim.Wait(sleepTime);
            System.Threading.Thread.Sleep(sleepTime);
            return await Task.FromResult("Hello world," + sleepTime);
        }

        public static string ExecuteBIO(int sleepTime2)
        {
            System.Threading.Thread.Sleep(sleepTime2);
            //semaphoreSlim.Wait(sleepTime2);
            //不能在非异步方法里面使用 Task.Delay,否则可能死锁
            //Task.Delay(sleepTime2).Wait();
            return "Hello world," + sleepTime2;
        }
使用 semaphoreSlim 的情况:

请输入线程数:1000
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:10
Result:Hello world,10
1000次 BIO(同步)测试(睡眠10 毫秒):
耗时(秒):1.2486964,QPS:    800.84
1000次 AIO(异步)测试(睡眠10 毫秒):
耗时(秒):10.5259443,QPS:     95.00
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:100
Result:Hello world,100
1000次 BIO(同步)测试(睡眠100 毫秒):
耗时(秒):12.2754003,QPS:     81.46
1000次 AIO(异步)测试(睡眠100 毫秒):
耗时(秒):100.5308431,QPS:      9.95
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:1000
Result:Hello world,1000
1000次 BIO(同步)测试(睡眠1000 毫秒):
耗时(秒):54.0055828,QPS:     18.52
1000次 AIO(异步)测试(睡眠1000 毫秒):
耗时(秒):1000.4749124,QPS:      1.00
 class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("按任意键开始测试 ");
            Console.Write("请输入线程数:");
            int threadNum = 100;
            int.TryParse(Console.ReadLine(), out threadNum);
            while (Test(threadNum)) ;

            Console.ReadLine();
            Console.ReadLine();
        }

        private static bool Test(int TaskNumber)
        {
            Console.Write("请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:");
            string input = Console.ReadLine();
            int SleepTime = 50;
            if (!int.TryParse(input, out SleepTime))
                return false;

            var result = ExecuteAIO(SleepTime).Result;
            Console.WriteLine("Result:{0}", result);
            //int TaskNumber = 1000;


            Console.WriteLine("{0}次 BIO(同步)测试(睡眠{1} 毫秒):", TaskNumber, SleepTime);
            System.Diagnostics.Stopwatch sw = new System.Diagnostics.Stopwatch();


            sw.Start();
            Task[] taskArr = new Task[TaskNumber];
            for (int i = 0; i < TaskNumber; i++)
            {
                Task task = Task.Run<string>(()=> ExecuteBIO(SleepTime));
                taskArr[i] = task;

            }
            Task.WaitAll(taskArr);
            sw.Stop();
            double useTime1 = sw.Elapsed.TotalSeconds;
            Console.WriteLine("耗时(秒):{0},QPS:{1,10:f2}", useTime1, TaskNumber / useTime1);
            sw.Reset();

            Console.WriteLine("{0}次 AIO(异步)测试(睡眠{1} 毫秒):", TaskNumber, SleepTime);
            sw.Start();
            for (int i = 0; i < TaskNumber; i++)
            {
                Task task = ExecuteAIO(SleepTime);
                taskArr[i] = task;
            }
            Task.WaitAll(taskArr);
            sw.Stop();
            double useTime2 = sw.Elapsed.TotalSeconds;
            Console.WriteLine("耗时(秒):{0},QPS:{1,10:f2}", useTime2, TaskNumber / useTime2);
            return true;
        }

        public static async Task<string> ExecuteAIO(int sleepTime)
        {
            await Task.Delay(sleepTime);
            return "Hello world," + sleepTime;
        }

        public static string ExecuteBIO(int sleepTime2)
        {
            System.Threading.Thread.Sleep(sleepTime2);
            //不能在非异步方法里面使用 Task.Delay,否则可能死锁
            //Task.Delay(sleepTime2).Wait();
            return "Hello world," + sleepTime2;
        }
    }

只顾,关键代码唯有上面五个办法:

总结:

 

在历次睡眠一秒的异步方法测试中,很久都并未有出来结果,不用思量,QPS肯定低于1秒了。

请输入线程数:1000
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:10
Result:Hello world,10
1000次 BIO(同步)测试(睡眠10 毫秒):
耗时(秒):1.3099217,QPS:    763.40
1000次 AIO(异步)测试(睡眠10 毫秒):
耗时(秒):10.9869045,QPS:     91.02
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:100
Result:Hello world,100
1000次 BIO(同步)测试(睡眠100 毫秒):
耗时(秒):8.5861461,QPS:    116.47
1000次 AIO(异步)测试(睡眠100 毫秒):
耗时(秒):100.9829406,QPS:      9.90
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:1000
Result:Hello world,1000
1000次 BIO(同步)测试(睡眠1000 毫秒):
耗时(秒):27.0158904,QPS:     37.02
1000次 AIO(异步)测试(睡眠1000 毫秒):

注:以上测试结果的测试景况是 

那三个主意跟WebAPI的测试方法代码是千篇一律的,不过调用代码稍微差异:

看得出,这里测试的时候,同步和异步调用,客户端代码都以行使的二10拾二线程,首要的区别正是异步方法应用了
async/await 语句。

然后,创立叁个调节台程序,来测试这么些web API:

 // GET api/values?sleepTime=10
        [HttpGet]
        public async Task<string> ExecuteAIO(int sleepTime)
        {
            await Task.Delay(sleepTime);
            return  "Hello world,"+ sleepTime;
        }

        [HttpGet]
        // GET api/values?sleepTime2=10
        public string ExecuteBIO(int sleepTime2)
        {
            System.Threading.Thread.Sleep(sleepTime2);
            return "Hello world," + sleepTime2;
        }
 class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("按任意键开始测试 WebAPI:http://localhost:62219/api/values?sleepTime={int}");
            Console.Write("请输入线程数:");
            int threadNum = 100;
            int.TryParse(Console.ReadLine(), out threadNum);
            while (Test(threadNum)) ;

            Console.ReadLine();
            Console.ReadLine();
        }

        private static bool Test(int TaskNumber)
        {
            Console.Write("请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:");
            string input = Console.ReadLine();
            int SleepTime = 50;
            if (!int.TryParse(input, out SleepTime))
                return false;
            HttpClient client = new HttpClient();
            client.BaseAddress = new Uri("http://localhost:62219/");
            var result = client.GetStringAsync("api/values?sleepTime=" + input).Result;
            Console.WriteLine("Result:{0}", result);
            //int TaskNumber = 1000;


            Console.WriteLine("{0}次 BIO(同步)测试(睡眠{1} 毫秒):", TaskNumber, SleepTime);
            System.Diagnostics.Stopwatch sw = new System.Diagnostics.Stopwatch();


            sw.Start();
            Task[] taskArr = new Task[TaskNumber];
            for (int i = 0; i < TaskNumber; i++)
            {
                Task task = client.GetStringAsync("api/values?sleepTime2=" + SleepTime);
                taskArr[i] = task;

            }
            Task.WaitAll(taskArr);
            sw.Stop();
            double useTime1 = sw.Elapsed.TotalSeconds;
            Console.WriteLine("耗时(秒):{0},QPS:{1,10:f2}", useTime1, TaskNumber/useTime1);
            sw.Reset();

            Console.WriteLine("{0}次 AIO(异步)测试(睡眠{1} 毫秒):", TaskNumber, SleepTime);
            sw.Start();
            for (int i = 0; i < TaskNumber; i++)
            {
                Task task = client.GetStringAsync("api/values?sleepTime=" + SleepTime);
                taskArr[i] = task;
            }
            Task.WaitAll(taskArr);
            sw.Stop();
            double useTime2 = sw.Elapsed.TotalSeconds;
            Console.WriteLine("耗时(秒):{0},QPS:{1,10:f2}", useTime2, TaskNumber / useTime2);
            return true;
        }
    }

View Code

在异步方法中,不要使用
Thread.Sleep;在一块儿方法中,不要选择Task.Delay
,不然也许现身线程死锁,结果难出来。

 for (int i = 0; i < TaskNumber; i++)
            {
                Task task = ExecuteAIO(SleepTime);
                taskArr[i] = task;
            }
            Task.WaitAll(taskArr);
 Task[] taskArr = new Task[TaskNumber];
            for (int i = 0; i < TaskNumber; i++)
            {
                Task task = Task.Run<string>(()=> ExecuteBIO(SleepTime));
                taskArr[i] = task;

            }
            Task.WaitAll(taskArr);

 

上边是非Web的进度内异步十二线程和一块二1010二线程的结果:

多谢网上朋友“魔羯座”
的唤醒,笔者用非确定性信号量和都用线程Sleep的主意,对一只和异步方法举办了测试,结果如他所说,TPL异步形式,费用非常大,上面是测试数据:

应用线程 Sleep的代码改动:

 public static async Task<string> ExecuteAIO(int sleepTime)
        {
            await Task.Delay(sleepTime);
            return "Hello world," + sleepTime;
        }

        public static string ExecuteBIO(int sleepTime2)
        {
            System.Threading.Thread.Sleep(sleepTime2);
            //不能在非异步方法里面使用 Task.Delay,否则可能死锁
            //Task.Delay(sleepTime2).Wait();
            return "Hello world," + sleepTime2;
        }
HttpClient client = new HttpClient();
client.BaseAddress = new Uri("http://localhost:62219/");
var result = client.GetStringAsync("api/values?sleepTime=" + input).Result;

上面包车型大巴测试结果,QPS并不高,但出于应用的是IISExpress,不相同的Web服务器软件质量不平等,所以还得相比较下进程内QPS结果,于是新建1个调控台程序,代码如下:

按任意键开始测试 WebAPI:http://localhost:62219/api/values?sleepTime={int}
请输入线程数:1000
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:10
Result:"Hello world,10"
1000次 BIO(同步)测试(睡眠10 毫秒):
耗时(秒):1.2860545,QPS:    777.57
1000次 AIO(异步)测试(睡眠10 毫秒):
耗时(秒):0.4895946,QPS:   2042.51
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:100
Result:"Hello world,100"
1000次 BIO(同步)测试(睡眠100 毫秒):
耗时(秒):8.2769307,QPS:    120.82
1000次 AIO(异步)测试(睡眠100 毫秒):
耗时(秒):0.5435111,QPS:   1839.89

 

无论是是普通程序仍然Web程序,使用异步10贰线程,能够大幅的滋长系统的吞吐量。

当然想尝试测试10000个线程,但报错了。

运行结果如下:

Intel i7-4790K CPU,4核8线程,内存 16GB,Win10 企业版

后记:

实际上根本是下边几行代码:

先是,建三个 ASP.NET MVC WebAPI项目,在暗许的调控器
values里面,扩充多个主意:

Microsoft.AspNet.WebApi.Client

请输入线程数:1000
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:10
Result:Hello world,10
1000次 BIO(同步)测试(睡眠10 毫秒):
耗时(秒):1.3031966,QPS:    767.34
1000次 AIO(异步)测试(睡眠10 毫秒):
耗时(秒):0.026441,QPS:  37820.05
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:100
Result:Hello world,100
1000次 BIO(同步)测试(睡眠100 毫秒):
耗时(秒):9.8502858,QPS:    101.52
1000次 AIO(异步)测试(睡眠100 毫秒):
耗时(秒):0.1149469,QPS:   8699.67

请输入线程数:10000
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:10
Result:Hello world,10
10000次 BIO(同步)测试(睡眠10 毫秒):
耗时(秒):7.7966125,QPS:   1282.61
10000次 AIO(异步)测试(睡眠10 毫秒):
耗时(秒):0.083922,QPS: 119158.27
请输入此API方法的睡眠时间(毫秒),输入非数字内容退出:100
Result:Hello world,100
10000次 BIO(同步)测试(睡眠100 毫秒):
耗时(秒):34.3646036,QPS:    291.00
10000次 AIO(异步)测试(睡眠100 毫秒):
耗时(秒):0.1721833,QPS:  58077.64

结果表示,.NET程序开启一千0个义务(不是10000个原生线程,必要思索线程池线程),异步方法的QPS当先了八千0,而共同方法唯有一千多点,品质差异还是相当大的。

一路调用:

很久未有写博客了,二零一玖年做的出品集团这二日刚刚开了发表会,稍微清闲下来,想想我们做的制品还有未有总体性优化空间,于是想到了.Net的异步可以优化质量,但究竟能够升级多大的比重呢?恰好有一个爱人正在做种种语言的异步质量测试(有关异步和协助实行的难点,请参谋客《AIO与BIO接口质量相比较》),于是小编前几天写了2个C#的测试程序。

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图