如何用WRK发送含长尾关键词的-lua脚本POST请求？

本文共计952个文字，预计阅读时间需要4分钟。

plaintextHTTP请求配置：- 接口URL: /gateway/services- 请求方法: POST- 请求体: { phone: 19012000335, code: 1569 }

HTTP_prot = {

"/gateway/services",

"/gateway/services",

}

--接口类型

HTTP_type = {

"POST",

"POST",

}

--参数

HTTP_body = {

‘{"phone": "19012000335"}‘,

‘{"phone": "19012000335","code": "1569"}‘,

-- 双中括号里面不转译

}

-----------如果有多个接口，名称、类型、参数必须按照相同的顺序。

math.randomseed(os.time())

function changeData(tal,order)

local body = string.format()

end

local reqIndex =0

numLink = 0 --记录连接数

numHTTP = 1 --记录第几个接口

numData = "19012"

lenthHTTP = 0

respError = 0 --变量，用于记录错误请求的数量

local threads = {}

--测试开始 执行一次

function setup(thread)

-- thread:set("id", counter)

table.insert(threads, thread)

reqIndex = reqIndex +1;

thread:set("index", reqIndex);

end

--每个线程执行一次

init = function()

local r = {}

local path = "" -- 局部变量（不加local 是全局变量）

local method = "GET" -- 默认接口类型是GET

-- header 头

-- wrk.headers["Hash"]= "85280aa135bbd0108dd6aa424565a"

-- wrk.headers["Token"]= ""

for i, v in ipairs(HTTP_prot) do -- 键从1 开始 非 0

path = v -- 接口路径

method = HTTP_type[i] -- method 获得接口类型

-----根据接口类型，判断进入那个判断-------

if method == "POST" then --判断接口类型为“POST”

--POST 参数json格式

wrk.headers["content-type"]= "application/json"

--POST Token参数

wrk.body = HTTP_body[i] --获得参数

end

if method == "GET" and HTTP_body[i] ~= "" then --判断接口类型为“GET”，并且参数不为空

path = v .. "?" ..HTTP_body[i]

end

-- io.write(method, "---", HTTP_body[i], "----", path, "\n") -- 打印请求方式（1个线程会打印一次），参数，路径（不含域名）

r[i] = wrk.format(method, path)

end

req = table.concat(r)

end

--每个请求执行一次在请求开始之前

request = function()

return req

end

--测试结果，每个链接返回都会执行一次

response = function(status, headers, body)

--判断返回结果是否正确，如果返回结果错误则打印返回结果，进入LOG.txt文件

if(not string.find(body,‘"code":0‘)) then

respError = respError + 1

file = io.open("LOG.txt","a")

file:write(body.."\n")

file:flush()

end

end

-- 测试最终结果，在测试结束执行

done = function(summary, latency, requests)

local x4 = 0

for index, thread in ipairs(threads) do

x4 = x4 + thread:get("respError")

end

local durations = summary.duration / 1000000 --执行时间,单位-秒

local errors = summary.errors.status --http status(状态)不是200,300开头的

local requests = summary.requests --总的请求数

local valid = requests - x4 --有效请求数 = 总的请求数 - 错误请求数

local connect = summary.errors.connect

local read1 = summary.errors.read

local write1 = summary.errors.write

local timeout = summary.errors.timeout

local errorRate = (x4/requests)*100

errorRate = string.format("%.1f",errorRate)

io.write("+++++++++++++++++++++++++++++++++++++\n")

io.write(" 测试持续时间: "..string.format("%.2f",durations).."s".."\n")

io.write(" 平均响应时间: "..string.format("%.2f",latency.mean / 1000).."ms".."\n")

io.write(" 最小响应时间: "..(latency.min / 1000).."ms".."\n")

io.write(" 最大响应时间: "..(latency.max / 1000).."ms".."\n")

io.write(" 全部请求数量: "..summary.requests.."\n")

io.write(" 错误请求数量: "..x4.."\n")

io.write(" 有效请求数量: "..valid.."\n" )

io.write(" 错误率: "..errorRate.."%\n")

io.write(" 每秒查询率: "..string.format("%.2f",valid / durations).."\n" )

io.write("+++++++++++++++++++++++++++++++++++++\n")

end