使用BeetleX.NetBenchmark压测TCP,HTTP和Websocket服务
NetBenchmark
是针对网络服务压测订制的开源组件,组件提供TCP
,HTTP
和Websocket
的压力测试基础功能;为了更好的符合业务需求组件不提供UI配置信息源的方式(毕竟这种方式只能作有限制测试),而是由使用者来自己制定相应的逻辑代码来进行具体的业务测试。组件基于netstandard2.0
,除了可以在.NET CORE
上运行外还可以在.NET FX
接下来介绍一下组的使用。
引用组件
https://www.nuget.org/packages/BeetleX.NetBenchmark/
Github: https://github.com/IKende/NetBenchmark
TCP测试
组件通过Benchmark.Tcp
方法来构建一个TCP
测压实例,方法如下:
public static Runner Tcp<Packet, Token>(string host, int port, int connections, Func<BeetleX.Clients.AwaiterClient, Token, Task> handler) where Packet : BeetleX.Clients.IClientPacket, new() where Token : new()
方法带两个泛参
-
Packet
协议分析器,实现
BeetleX.Clients.IClientPacket
. -
Token
测试关联对象,可以根据业务制定相关对象数据状态属性。
参数
-
host
主机地址
-
port
服务端口
-
connectins
并发测试的连接数
-
handler
测试方法
Func<BeetleX.Clients.AwaiterClient, Token, Task>
,每次调用的测试逻辑。
构建TCP测试实例
class Program { static void Main(string[] args) { var data = StringPacket.RamdomString(512); var runer = Benchmark.Tcp<StringPacket, Program>("192.168.2.19", 9090, 200, async (tcp, token) => { tcp.Send(data); await tcp.Receive(); } ); runer.Run(); runer.Print(); } }
以上定义了一个基于StringPacket
自定义协议测试,它是以4字节头大小来描述消息长的字符协议解释器。tcp.Send
是向服务器发送一个消息,而await tcp.Receive
则等待服务器响应。
测试结果
可以通过runer.Print()
方法实时把结果输出控制台,信息里包括:正确,错误和相关网络并发情况,在最下面输出不同延时响应的百分比。
HTTP测试
组件通过Benchmark.Http
方法来构建一个HTTP
测压实例,方法如下:
public static Runner Http<Token>(Uri host, int connections, Func<IHttpHandler, Token, Task> handler) where Token : new()
方法带一个泛参
-
Token
测试关联对象,可以根据业务制定相关对象数据状态属性。
参数
-
host
测试的服务地址
-
connections
并发测试的连接数
-
handler
测试方法
Func<IHttpHandler, Token, Task>
,每次调用的测试逻辑。
IHttpHandler
提供了一些简单的http
调用方法
Task Get(string url, Dictionary<string, string> queryString = null); Task Get(string url, Dictionary<string, string> queryString, Dictionary<string, string> header = null); Task Post(string url, Dictionary<string, string> queryString, Dictionary<string, string> heaer, Dictionary<string, string> data); Task Post(string url, Dictionary<string, string> data); Task PostJson(string url, Dictionary<string, string> queryString, Dictionary<string, string> heaer, object data); Task PostJson(string url,object data);
构建HTTP测试实例
class Program { static void Main(string[] args) { var runer = Benchmark.Http<Program>(new Uri("http://192.168.2.19:5000"), 100, async (http, token) => { await http.Get("/api/values"); await http.PostJson("/api/values", "beetlex.io"); }); runer.Run(); runer.Print(); } }
测试结果
websocket测试
组件通过Benchmark.Websocketxxx
方法来构建一个websocket
测压实例,方式有三种分别是DataFrame
,Text
和Json
,方法如下:
public static Runner Websocket<Token>(Uri host, int connections, Func<WSClient, Token, Task> handler) where Token : new() public static Runner WebsocketText<Token>(Uri host, int connections, Func<TextClient, Token, Task> handler) where Token : new() public static Runner WebsocketJson<Token>(Uri host, int connections, Func<JsonClient, Token, Task> handler) where Token : new()
构建Websocket测试实例
class Program { static void Main(string[] args) { var runer = Benchmark.WebsocketJson<Program>(new Uri("ws://192.168.2.19:8080"), 100, async (ws, token) => { ws.TimeOut = 1000 * 5; ws.Send(new { url = "/json" }); var result = await ws.Receive(); }); runer.Run(); runer.Print(); } }
测试结果
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
使用Apache 的 commons-csv 实现 CSV 文件导出
1. CSV 简介 CSV全称是:Comma Separated Values (逗号分隔值)或者 Character Separated Values(字符分隔值)。其文件以纯文本形式存储表格数据(数字和文本)。CSV文件由任意数目的记录组成,记录间以某种换行符分隔;每条记录由字段组成,字段间的分隔符是其它字符或字符串,最常见的是逗号或制表符。每一行记录位于一个单独的行上,用回车换行符CRLF(也就是\r\n)分割。 对于excel来说默认使用 ,进行分割数据。 每一行记录最后一个字段后不能跟逗号 每一行一条记录 列为空需要指定 "" 用回车换行符CRLF(\r\n)分割每条记录 纯文本,使用某个字符集,比如ASCII、Unicode、EBCDIC或GB2312 2. 实现 CSV 文件导出 采用 Apache 开源的 commons-csv 包,详细内容参考 官网 2.1 使用 2.1.1 引入依赖 <dependency> <groupId>org.apache.commons</groupId> <artifactId>commo...
- 下一篇
logback日志级别动态切换的四种方案
生产环境中经常有需要动态修改日志级别。 现在就介绍几种方案 方案一:开启logback的自动扫描更新 配置如下 <?xml version="1.0" encoding="UTF-8"?> <configuration scan="true" scanPeriod="60 seconds" debug="false"> <!-- configuration标签 scan属性代表logback框架会定时检测改配置文件是否有发生改动,如果有则更新为最新配置--> 然后就将修改的配置文件拷贝到app.jar的同级目录下config/logback.xml 方案二:自定义api 代码如下 /** * log api * @author lipeng */ @RequestMapping("/api/log") @RestController public class LogbackController { private Logger log = LoggerFactory.getLogger(LogbackController.class); /** * ...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,CentOS8安装Elasticsearch6.8.6
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- Linux系统CentOS6、CentOS7手动修改IP地址
- CentOS7安装Docker,走上虚拟化容器引擎之路
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS7设置SWAP分区,小内存服务器的救世主