-- POST 请求，演示如何添加

-- HTTP method, body, header

wrk.method = "POST"

wrk.body   = "foo=bar&baz=quux"

wrk.headers["Content-Type"] = "application/x-www-form-urlencoded"

wrk = {

    scheme  = "http",

    host    = "localhost",

    port    = nil,

    method  = "GET",

    path    = "/",

    headers = {},

    body    = nil,

    thread  = <userdata>

}

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，终止线程

latency.min              -- minimum value seen

latency.max              -- maximum value seen

latency.mean             -- average value seen

latency.stdev            -- standard deviation

latency:percentile(99.0) -- 99th percentile value

latency(i)               -- raw value and count

summary = {

  duration = N,  -- run duration in microseconds

  requests = N,  -- total completed requests

  bytes    = N,  -- total bytes received

  errors   = {

    connect = N, -- total socket connection errors

    read    = N, -- total socket read errors

    write   = N, -- total socket write errors

    status  = N, -- total HTTP status codes > 399

    timeout = N  -- total request timeouts

  }

}

-- example script that demonstrates use of setup() to pass

-- data to and from the threads

local counter = 1

local threads = {}

function setup(thread)

-- 给每个线程设置一个 id 参数

   thread:set("id", counter)

-- 将线程添加到 table 中

   table.insert(threads, thread)

   counter = counter + 1

end

function init(args)

-- 初始化两个参数，每个线程都有独立的 requests、responses 参数

   requests  = 0

   responses = 0

-- 打印线程被创建的消息，打印完后，线程正式启动运行

   local msg = "thread %d created"

   print(msg:format(id))

end

function request()

-- 每发起一次请求 +1

   requests = requests + 1

   return wrk.request()

end

function response(status, headers, body)

-- 每得到一次请求的响应 +1

   responses = responses + 1

end

function done(summary, latency, requests)

-- 循环线程 table

   for index, thread in ipairs(threads) do

      local id        = thread:get("id")

      local requests  = thread:get("requests")

      local responses = thread:get("responses")

      local msg = "thread %d made %d requests and got %d responses"

-- 打印每个线程发起了多少个请求，得到了多少次响应

      print(msg:format(id, requests, responses))

   end

end

wrk -d3s -c20 -t5 -s test.lua https://*****/get