开源个.NetCore写的 - 并发请求工具PressureTool

发布时间：2017-07-26 14:23:18.507作者：IT网络文摘

本篇和大家分享的是一个并发请求工具，并发往往代表的就是压力，对于一些订单量比较多的公司这种情况很普遍，也因此出现了很多应对并发的解决方案如：分布式，队列，数据库锁等；

对于没有遇到过或者不可能线上来处理并发问题的我们来说，需要模拟这种环境，不错这就是写并发请求工具的目的：

. 对于api接口做并发请求

. NetCore来写的能跨平台运行

. 允许配置多个目标地址，进行同时并发请求

. 支持Get，Post请求方式（post参数支持：xml，json格式）

工具设计的原理

工具的全部代码都开源至：https://github.com/shenniubuxing3/PressureTool（不妨标个*），下面将举例演示如何使用；工具设计的原理主要采用Task，通过配置目标地址，请求数量来拆分成多个Task，以此完成并行的请求：

平面设计培训,网页设计培训,美工培训,游戏开发,动画培训

由上图可以看出，该工具主要有3层树形结构，最底层是真实发出对目标url地址的请求，使用的Task，Task对于多核CPU来说效果更显著；在讲解例子前咋们先来看看配置文件对应的实体类：

 1 #region 配置信息 2  3         public class MoToolConf 4         { 5             /// <summary> 6             /// 执行结果日志记录路径(全局，默认程序根目录) 7             /// </summary> 8             public string ResultLogPath { get; set; } 9 10             /// <summary>11             /// 多个任务12             /// </summary>13             public List<MoTaskInfo> MoTaskInfoes { get; set; }14         }15 16         /// <summary>17         /// 任务信息18         /// </summary>19         public class MoTaskInfo20         {21 22             /// <summary>23             /// 请求方式，目前支持：httpget，httppost24             /// </summary>25             public string Method { get; set; }26 27             /// <summary>28             /// 请求地址29             /// </summary>30             public string Url { get; set; }31 32             /// <summary>33             /// 连接数34             /// </summary>35             public int LinkNum { get; set; }36 37             /// <summary>38             /// 参数（post使用）39             /// </summary>40             public string Param { get; set; }41 42             /// <summary>43             /// 执行结果日志记录路径（私有>全局）44             /// </summary>45             public string ResultLogPath { get; set; }46         }47         #endregion

httpget请求的配置

首先我们需要在根目录下找到配置文件：PressureTool.json，然后配置成如下get请求设置：

{  "ResultLogPath": "",//默认不设置，日志记录在根目录
  "MoTaskInfoes": [
    {      "Method": "httpget",      "Url": "https://www.baidu.com/",      "LinkNum": 10,      "Param": "",      "ResultLogPath": ""
    },
    {      "Method": "httpget",      "Url": "https://cloud.baidu.com/",      "LinkNum": 10,      "Param": "",      "ResultLogPath": ""
    }
  ]
}

httpget应该是最简单的请求方式了，如果你需要传递什么参数，就直接往您url上追加就行了，get请求方式是用不到Param参数的：

平面设计培训,网页设计培训,美工培训,游戏开发,动画培训

httppost请求的配置 - 参数为json

post的配置与get不同的是设置不同的Method参数（ "Method": "httppost_json" ），并且如果你有参数那么还需要配置Param节点（ "Param": "{\"Number\": 1,\"Name\": \"张三\"}" ），参考如下配置：

{  "ResultLogPath": "", //默认不设置，日志记录在根目录
  "MoTaskInfoes": [
    {      "Method": "httpget",      "Url": "https://www.baidu.com/",      "LinkNum": 10,      "Param": "",      "ResultLogPath": ""
    },
    {      "Method": "httppost_json",      "Url": "http://localhost:5000/api/Values/PostJson",      "LinkNum": 1,      "Param": "{\"Number\": 1,\"Name\": \"张三\"}",      "ResultLogPath": ""
    }
  ]
}

这里为了测试我写了一个简单的api接口，分别接收json和xml的参数，测试api接口代码如下：

 1 [Route("api/[controller]/[action]")] 2     public class ValuesController : Controller 3     { 4         public static List<MoStudent> _students = new List<MoStudent>(); 5  6         // GET api/values 7         [HttpGet] 8         public async Task<MoBaseResponse> Get() 9         {10 11             return new MoBaseResponse { Data = _students };12         }13 14         // GET api/values/515         [HttpGet("{id}")]16         public string Get(int id)17         {18             return "value";19         }20 21         // POST api/values22         [HttpPost]23         public MoBaseResponse PostJson([FromBody]MoStudent student)24         {25             var response = new MoBaseResponse() { Msg = "添加失败" };26             if (student == null) { return response; }27 28             _students.Add(student);29             response.Msg = "添加成功";30             response.Status = 1;31 32             return response;33         }34 35         [HttpPost]36         public async Task<MoBaseResponse> PostXml()37         {38             var response = new MoBaseResponse() { Msg = "添加失败" };39             var strReq = string.Empty;40             using (var stream = Request.Body)41             {42                 using (var reader = new StreamReader(stream))43                 {44                     strReq = await reader.ReadToEndAsync();45                 }46             }47 48             if (string.IsNullOrWhiteSpace(strReq)) { return response; }49 50             var match = Regex.Match(strReq, "<Number>(?<number>[^<]+)</Number>[^<]*<Name>(?<name>[^<]+)</Name>");51             if (match == null || match.Groups.Count <= 0) { return response; }52 53             var student = new MoStudent();54             student.Number = Convert.ToInt32(match.Groups["number"].Value);55             student.Name = match.Groups["name"].Value;56             _students.Add(student);57 58             response.Msg = "添加成功";59             response.Status = 1;60             return response;61         }62     }63 64     public class MoBaseResponse65     {66         public int Status { get; set; }67 68         public string Msg { get; set; }69 70         public object Data { get; set; }71     }72 73     public class MoStudent74     {75         public int Number { get; set; }76 77         public string Name { get; set; }78     }

我们往测试api地址 http://localhost:5000/api/Values/PostJson 发出请求，传递学生基本信息参数，然后通过api的get接口看看效果：

平面设计培训,网页设计培训,美工培训,游戏开发,动画培训