本篇和大家分享的是一个 并发请求工具,并发往往代表的就是压力,对于一些订单量比较多的公司这种情况很普遍,也因此出现了很多应对并发的解决方案如:分布式,队列,数据库锁等;
对于没有遇到过或者不可能线上来处理并发问题的我们来说,需要模拟这种环境,不错这就是写并发请求工具的目的:
. 对于 api 接口做并发请求
. NetCore 来写的能跨平台运行
. 允许配置多个目标地址,进行同时并发请求
. 支持 Get,Post 请求方式(post 参数支持:xml,json 格式)
工具的全部代码都开源至:https://github.com/shenniubuxing3/PressureTool(不妨标个 *),下面将举例演示如何使用;工具设计的原理主要采用 Task,通过配置目标地址,请求数量来拆分成多个 Task,以此完成并行的请求:
由上图可以看出,该工具主要有 3 层树形结构,最底层是真实发出对目标 url 地址的请求,使用的 Task,Task 对于多核 CPU 来说效果更显著;在讲解例子前咋们先来看看配置文件对应的实体类:
- #region配置信息
- public class MoToolConf {
- /// <summary>
- /// 执行结果日志记录路径(全局,默认程序根目录)
- /// </summary>
- public string ResultLogPath {
- get;
- set;
- }
- /// <summary>
- /// 多个任务
- /// </summary>
- public List MoTaskInfoes {
- get;
- set;
- }
- }
- /// <summary>
- /// 任务信息
- /// </summary>
- public class MoTaskInfo {
- /// <summary>
- /// 请求方式,目前支持:httpget,httppost
- /// </summary>
- public string Method {
- get;
- set;
- }
- /// <summary>
- /// 请求地址
- /// </summary>
- public string Url {
- get;
- set;
- }
- /// <summary>
- /// 连接数
- /// </summary>
- public int LinkNum {
- get;
- set;
- }
- /// <summary>
- /// 参数(post使用)
- /// </summary>
- public string Param {
- get;
- set;
- }
- /// <summary>
- /// 执行结果日志记录路径(私有>全局)
- /// </summary>
- public string ResultLogPath {
- get;
- set;
- }
- }#endregion
首先我们需要在根目录下找到配置文件: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 参数的:
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 接口代码如下:
- [Route("api/[controller]/[action]")] public class ValuesController: Controller {
- public static List _students = new List();
- // GET api/values
- [HttpGet] public async Task Get() {
- return new MoBaseResponse {
- Data = _students
- };
- }
- // GET api/values/5
- [HttpGet("{id}")] public string Get(int id) {
- return "value";
- }
- // POST api/values
- [HttpPost] public MoBaseResponse PostJson([FromBody] MoStudent student) {
- var response = new MoBaseResponse() {
- Msg = "添加失败"
- };
- if (student == null) {
- return response;
- }
- _students.Add(student);
- response.Msg = "添加成功";
- response.Status = 1;
- return response;
- }
- [HttpPost] public async Task PostXml() {
- var response = new MoBaseResponse() {
- Msg = "添加失败"
- };
- var strReq = string.Empty;
- using(var stream = Request.Body) {
- using(var reader = new StreamReader(stream)) {
- strReq = await reader.ReadToEndAsync();
- }
- }
- if (string.IsNullOrWhiteSpace(strReq)) {
- return response;
- }
- var match = Regex.Match(strReq, "<Number>(?<number>[^<]+)</Number>[^<]*<Name>(?<name>[^<]+)</Name>");
- if (match == null || match.Groups.Count <= 0) {
- return response;
- }
- var student = new MoStudent();
- student.Number = Convert.ToInt32(match.Groups["number"].Value);
- student.Name = match.Groups["name"].Value;
- _students.Add(student);
- response.Msg = "添加成功";
- response.Status = 1;
- return response;
- }
- }
- public class MoBaseResponse {
- public int Status {
- get;
- set;
- }
- public string Msg {
- get;
- set;
- }
- public object Data {
- get;
- set;
- }
- }
- public class MoStudent {
- public int Number {
- get;
- set;
- }
- public string Name {
- get;
- set;
- }
- }
我们往测试 api 地址 http://localhost:5000/api/Values/PostJson 发出请求,传递学生基本信息参数,然后通过 api 的 get 接口看看效果:
这里演示的只请求一次 api,如果你想测试你自己 api 接口并发情况,你可以设置参数: "LinkNum": 10 或者跟多:
post 方式传递 xml 参数的配置和 json 差不多,需要注意的是需要修改 Method( "Method": "httppost_xml" ),因为工具吧 xml 和 json 的配置区分开了,下面来演示下 json 和 xml 分别配置 5 次请求数的效果:
然后通过 api 的 get 接口获取下效果:
好了到这里演示就完了,如果您觉得该工具可以你可以去 git 源码:https://github.com/shenniubuxing3/PressureTool,或者加入 NineskyQQ 官方群:428310563 获取 Framework 版本的工具。
来源: http://www.cnblogs.com/wangrudong003/p/7235323.html