本篇和大家分享的是一個(gè) 并發(fā)請(qǐng)求工具,并發(fā)往往代表的就是壓力,對(duì)于一些訂單量比較多的公司這種情況很普遍,也因此出現(xiàn)了很多應(yīng)對(duì)并發(fā)的解決方案如:分布式,隊(duì)列,數(shù)據(jù)庫(kù)鎖等;

對(duì)于沒有遇到過(guò)或者不可能線上來(lái)處理并發(fā)問題的我們來(lái)說(shuō),需要模擬這種環(huán)境,不錯(cuò)這就是寫并發(fā)請(qǐng)求工具的目的:

. 對(duì)于api接口做并發(fā)請(qǐng)求

. NetCore來(lái)寫的能跨平臺(tái)運(yùn)行

. 允許配置多個(gè)目標(biāo)地址,進(jìn)行同時(shí)并發(fā)請(qǐng)求

. 支持Get,Post請(qǐng)求方式(post參數(shù)支持:xml,json格式)

工具設(shè)計(jì)的原理

工具的全部代碼都開源至:https://github.com/shenniubuxing3/PressureTool(不妨標(biāo)個(gè)*),下面將舉例演示如何使用;工具設(shè)計(jì)的原理主要采用Task,通過(guò)配置目標(biāo)地址,請(qǐng)求數(shù)量來(lái)拆分成多個(gè)Task,以此完成并行的請(qǐng)求:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

由上圖可以看出,該工具主要有3層樹形結(jié)構(gòu),最底層是真實(shí)發(fā)出對(duì)目標(biāo)url地址的請(qǐng)求,使用的Task,Task對(duì)于多核CPU來(lái)說(shuō)效果更顯著;在講解例子前咋們先來(lái)看看配置文件對(duì)應(yīng)的實(shí)體類:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

 1 #region 配置信息 2  3         public class MoToolConf 4         { 5             /// <summary> 6             /// 執(zhí)行結(jié)果日志記錄路徑(全局,默認(rèn)程序根目錄) 7             /// </summary> 8             public string ResultLogPath { get; set; } 9 10             /// <summary>11             /// 多個(gè)任務(wù)12             /// </summary>13             public List<MoTaskInfo> MoTaskInfoes { get; set; }14         }15 16         /// <summary>17         /// 任務(wù)信息18         /// </summary>19         public class MoTaskInfo20         {21 22             /// <summary>23             /// 請(qǐng)求方式,目前支持:httpget,httppost24             /// </summary>25             public string Method { get; set; }26 27             /// <summary>28             /// 請(qǐng)求地址29             /// </summary>30             public string Url { get; set; }31 32             /// <summary>33             /// 連接數(shù)34             /// </summary>35             public int LinkNum { get; set; }36 37             /// <summary>38             /// 參數(shù)(post使用)39             /// </summary>40             public string Param { get; set; }41 42             /// <summary>43             /// 執(zhí)行結(jié)果日志記錄路徑(私有>全局)44             /// </summary>45             public string ResultLogPath { get; set; }46         }47         #endregion

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

httpget請(qǐng)求的配置

首先我們需要在根目錄下找到配置文件:PressureTool.json,然后配置成如下get請(qǐng)求設(shè)置:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

{  "ResultLogPath": "",//默認(rèn)不設(shè)置,日志記錄在根目錄
  "MoTaskInfoes": [
    {      "Method": "httpget",      "Url": "https://www.baidu.com/",      "LinkNum": 10,      "Param": "",      "ResultLogPath": ""
    },
    {      "Method": "httpget",      "Url": "https://cloud.baidu.com/",      "LinkNum": 10,      "Param": "",      "ResultLogPath": ""
    }
  ]
}

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

httpget應(yīng)該是最簡(jiǎn)單的請(qǐng)求方式了,如果你需要傳遞什么參數(shù),就直接往您url上追加就行了,get請(qǐng)求方式是用不到Param參數(shù)的:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

 

httppost請(qǐng)求的配置 - 參數(shù)為json

post的配置與get不同的是設(shè)置不同的Method參數(shù)( "Method""httppost_json" ),并且如果你有參數(shù)那么還需要配置Param節(jié)點(diǎn)( "Param""{\"Number\": 1,\"Name\": \"張三\"}" ),參考如下配置:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

{  "ResultLogPath": "", //默認(rèn)不設(shè)置,日志記錄在根目錄
  "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": ""
    }
  ]
}

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

這里為了測(cè)試我寫了一個(gè)簡(jiǎn)單的api接口,分別接收json和xml的參數(shù),測(cè)試api接口代碼如下:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

 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     }

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

我們往測(cè)試api地址 http://localhost:5000/api/Values/PostJson 發(fā)出請(qǐng)求,傳遞學(xué)生基本信息參數(shù),然后通過(guò)api的get接口看看效果:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

這里演示的只請(qǐng)求一次api,如果你想測(cè)試你自己api接口并發(fā)情況,你可以設(shè)置參數(shù): "LinkNum"10 或者跟多:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

 

httppost請(qǐng)求的配置 - 參數(shù)為xml

post方式傳遞xml參數(shù)的配置和json差不多,需要注意的是需要修改Method( "Method""httppost_xml" ),因?yàn)楣ぞ甙蓌ml和json的配置區(qū)分開了,下面來(lái)演示下json和xml分別配置5次請(qǐng)求數(shù)的效果:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

然后通過(guò)api的get接口獲取下效果:

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

好了到這里演示就完了,如果您覺得該工具可以你可以去git源碼:https://github.com/shenniubuxing3/PressureTool ,或者加入 NineskyQQ官方群:428310563 獲取Framework版本的工具。

如果您覺的此文還可以,或是新眼界,新知識(shí),新眉腳等收獲,請(qǐng)打賞下作者的分享,微信號(hào):

平面設(shè)計(jì)培訓(xùn),網(wǎng)頁(yè)設(shè)計(jì)培訓(xùn),美工培訓(xùn),游戲開發(fā),動(dòng)畫培訓(xùn)

git地址: https://github.com/shenniubuxing3    個(gè)人開源插件地址:http://www.lovexins.com:8888/
nuget發(fā)布包:https://www.nuget.org/profiles/shenniubuxing3    服裝店,歡迎來(lái)捧場(chǎng):神牛衣柜3 
圖片收集網(wǎng)站:愛留圖    51cto博客站:http://shenniu003.blog.51cto.com

http://www.cnblogs.com/wangrudong003/p/7235323.html