wrk效能測試(詳解)
阿新 • • 發佈:2020-01-07
一、簡介
wrk 是一款針對 Http 協議的基準測試工具,它能夠在單機多核 CPU 的條件下,使用系統自帶的高效能 I/O 機制,如 epoll,kqueue 等,通過多執行緒和事件模式,對目標機器產生大量的負載。
優勢:
- 輕量級效能測試工具
- 安裝簡單
- 學習曲線基本為0,幾分鐘就學會使用了
- 基於系統自帶的高效能I/O機制,如epoll,kqueue,利用非同步的事件驅動框架,通過很少的執行緒就可以壓出很大的併發量
劣勢:
- wrk 目前僅支援單機壓測,後續也不太可能支援多機器對目標機壓測,因為它本身的定位,並不是用來取代 JMeter, LoadRunner 等專業的測試工具。
二、格式及用法
Usage: wrk <options> <url> Options: -c, --connections <N> Connections to keep open -d, --duration <T> Duration of test -t, --threads <N> Number of threads to use -s, --script <S> Load Lua script file -H, --header <H> Add header to request --latency Print latency statistics --timeout <T> Socket/request timeout -v, --version Print version details Numeric arguments may include a SI unit (1k, 1M, 1G) Time arguments may include a time unit (2s, 2m, 2h)
翻譯成中文:
使用方法: wrk <選項> <被測HTTP服務的URL> Options: -c, --connections <N> 跟伺服器建立並保持的TCP連線數量 -d, --duration <T> 壓測時間 -t, --threads <N> 使用多少個執行緒進行壓測 -s, --script <S> 指定Lua指令碼路徑 -H, --header <H> 為每一個HTTP請求新增HTTP頭 --latency 在壓測結束後,列印延遲統計資訊 --timeout <T> 超時時間 -v, --version 列印正在使用的wrk的詳細版本信 <N>代表數字引數,支援國際單位 (1k, 1M, 1G) <T>代表時間引數,支援時間單位 (2s, 2m, 2h)
三、簡單壓測及結果分析
做一個簡單的壓測,分析下結果:
wrk -t8 -c200 -d30s --latency "http://www.bing.com"
輸出:
Running 30s test @ http://www.bing.com 8 threads and 200 connections Thread Stats Avg Stdev Max +/- Stdev Latency 46.67ms 215.38ms 1.67s 95.59% Req/Sec 7.91k 1.15k 10.26k 70.77%
Latency Distribution 50% 2.93ms 75% 3.78ms 90% 4.73ms 99% 1.35s 1790465 requests in 30.01s, 684.08MB read Requests/sec: 59658.29 Transfer/sec: 22.79MB
以上是使用8個執行緒200個連線,對bing首頁進行了30秒的壓測,並要求在壓測結果中輸出響應延遲資訊。
以下是解釋壓測結果:
Running 30s test @ http://www.bing.com (壓測時間30s) 8 threads and 200 connections (共8個測試執行緒,200個連線) Thread Stats Avg Stdev Max +/- Stdev (平均值) (標準差)(最大值)(正負一個標準差所佔比例) Latency 46.67ms 215.38ms 1.67s 95.59% (延遲) Req/Sec 7.91k 1.15k 10.26k 70.77% (處理中的請求數) Latency Distribution (延遲分佈) 50% 2.93ms 75% 3.78ms 90% 4.73ms 99% 1.35s (99分位的延遲) 1790465 requests in 30.01s, 684.08MB read (30.01秒內共處理完成了1790465個請求,讀取了684.08MB資料) Requests/sec: 59658.29 (平均每秒處理完成59658.29個請求) Transfer/sec: 22.79MB (平均每秒讀取資料22.79MB)
四、使用lua指令碼進行壓測
1、lua宣告週期
共有三個階段,啟動階段,執行階段,結束階段。wrk支援在這三個階段對壓測進行個性化。
啟動階段
function setup(thread)
在指令碼檔案中實現setup方法,wrk就會在測試執行緒已經初始化但還沒有啟動的時候呼叫該方法。wrk會為每一個測試執行緒呼叫一次setup方法,並傳入代表測試執行緒的物件thread作為引數。setup方法中可操作該thread物件,獲取資訊、儲存資訊、甚至關閉該執行緒。
thread.addr - get or set the thread's server address thread:get(name) - get the value of a global in the thread's env thread:set(name, value) - set the value of a global in the thread's env thread:stop() - stop the thread
執行階段
function init(args) --由測試執行緒呼叫,只會在進入執行階段時,呼叫一次。支援從啟動wrk的命令中,獲取命令列引數; function delay() --在每次傳送request之前呼叫,如果需要delay,那麼delay相應時間; function request() --用來生成請求;每一次請求都會呼叫該方法,所以注意不要在該方法中做耗時的操作; function response(status, headers, body) --在每次收到一個響應時呼叫;為提升效能,如果沒有定義該方法,那麼wrk不會解析headers和body;
結束階段
function done(summary, latency, requests) --在整個測試過程中只會呼叫一次,可從引數給定的物件中,獲取壓測結果,生成定製化的測試報告。
2、自定義指令碼中可訪問的變數和方法:
變數:wrk
wrk = { scheme = "http", host = "localhost", port = nil, method = "GET", path = "/", headers = {}, body = nil, thread = <userdata>, }
方法:wrk.fomat wrk.lookup wrk.connect
function wrk.format(method, path, headers, body) --根據引數和全域性變數wrk,生成一個HTTP rquest string。 function wrk.lookup(host, service) --給定host和service(port/well known service name),返回所有可用的伺服器地址資訊。 function wrk.connect(addr) --測試與給定的伺服器地址資訊是否可以成功建立連線
3、lua指令碼壓測例項
壓測命令:wrk -t8 -c200 -d30s --latency -s test.lua http://www.bing.com
test.lua是用lua寫的壓測指令碼,如下是壓測指令碼的例項:
使用post方法壓測
wrk.method = "POST" wrk.headers["S-COOKIE2"]="a=2&b=Input&c=10.0&d=20191114***" wrk.body = "recent_seven=20191127_32;20191128_111" wrk.headers["Host"]="api.shouji.**.com"
function response(status,headers,body) if status ~= 200 then print(body) -- wrk.thread:stop() end end
傳送json
request = function() local headers = { } headers['Content-Type'] = "application/json" body = { mobile={"1533899828"}, params={code=math.random(1000,9999)} } local cjson = require("cjson") body_str = cjson.encode(body) return wrk.format('POST', nil, headers, body_str) end
wrk讀取檔案,實現隨機header-cookie
idArr = {} falg = 0 wrk.method = "POST" wrk.body = "a=1" function init(args) for line in io.lines("integral/cookies.txt") do print(line) idArr[falg] = line falg = falg+1 end falg = 0 end --wrk.method = "POST" --wrk.body = "a=1" --wrk.path = "/v1/points/reading" request = function() parms = idArr[math.random(0,4)] 隨機傳遞檔案中的引數 --parms = idArr[falg%(table.getn(idArr)+1)] 迴圈傳遞檔案中的引數 wrk.headers["S-COOKIE2"] = parms falg = falg+1 return wrk.format() end
wrk建立陣列並初始化,拼接隨機引數
idArr = {}; function init(args) idArr[1] = "1"; idArr[2] = "2"; idArr[3] = "3"; idArr[4] = "4"; end request = function() parms = idArr[math.random(1,4)] path = "/v1/points/reading?id="..parms return wrk.format("GET",path) end