关于在openresty协程中调用socket的问题

wgm.china · 2013-11-30T04:55:05+00:00

很好使，多谢了！Richard Chen 陈书楷ZKSoftware Inc. 中控科技http://w...

关于在openresty协程中调用socket的问题

wgm.china

春哥：

你好！

最近在一个项目中需要在openresty的协程中调用lua-resty-http,我写了一个样例不知道是否合适，在大并发下是否存在问题，请帮我看看我的用法是否正确？

function webservice(url,body)

	local res = {}

	local http = require "resty.http"  --这一段引用是否正确？我很疑惑。

	local hc = http:new()

		res.ok, res.code, res.headers, res.status, res.body  = hc:request {

	                url = "" style="color: #7a7a7a">url,

	               --- proxy = "http://127.0.0.1:8888",

	               timeout = 1000,

	               method = "POST", -- POST or GET

	              -- add post content-type and cookie

	               headers = {["Content-Type"] = "application/soap+xml; charset=utf-8" },

	               body = body

}

	return res

end

function ws ()

	local co = coroutine.create(function(url,body)

		return webservice(url,body)

	end)

	table.insert(threads,co)

end

ws()

local status,res = coroutine.resume(threads[i],url,body)
……………

agentzh

Hello!

2013/11/29 wgm:
> 最近在一个项目中需要在openresty的协程中调用lua-resty-http,我写了一个样例不知道是否合适，在大并发下是否存在问题，

最好是通过 ab 或者 weighttp 这样的工具摸拟大并发流量进行实际压力测试 :)

> 请帮我看看我的用法是否正确？
>
> function webservice(url,body)
> local res = {}
> local http = require "resty.http"  --这一段引用是否正确？我很疑惑。

这一行 require 语句最好放在最外层作用域去。

>
> ws()
> local status,res = coroutine.resume(threads[i],url,body)
>

值得提醒的是，coroutine API 还是串行的。coroutine.* API 的意义在于方便地实现一些迭代器。

所以如果你需要并发多个后端 HTTP 请求，应当改用 ngx.thread API:

  https://github.com/chaoslawful/lua-nginx-module#ngxthreadspawn

Regards,
-agentzh

wgm.china

谢谢春哥，我修改看看

在 2013-11-30，上午6:00，"Yichun Zhang (agentzh)" <age...@gmail.com> 写道：

coroutine