Re: [openresty] receiveuntil(): synchronous api?

yuansheng_2f16 · 2015-12-22T13:07:04+00:00

Hello! 2016-06-08 12:25 GMT-07:00 黄川: > 还是想深入理解一下现在luajit garb...

Re: [openresty] receiveuntil(): synchronous api?

yuansheng_2f16

cosocket 是不能跨会话存在的。

ngx.socket.tcp

... ...

通过该 API 函数创建的 cosocket 对象，与创造它的 Lua 环境拥有相同的生命周期。所以永远不要把 cosocket 对象传递给其他 Lua 环境（包括 ngx.timer 回调函数），并且永远不要在两个不同的 Nginx 请求之间共享 cosocket 对象。

中文 wiki ：https://github.com/iresty/nginx-lua-module-zh-wiki/blob/master/doc/ngxsockettcp.md

On Tue, Dec 22, 2015 at 12:02 PM, 黄川 <chu...@gmail.com> wrote:

对于从 socket，我试图在init_worker_by_lua中用recieveutil读response，在content_by_lua里每request send data，但一直有bad request error。我看到春哥提到 “cosocket objects can only be used by the request creating them”，所以我就让init_worker_by_lua 产生的thread(通过timer)去handle所有读写，但是send的时候还是有 bad request as below.
[error] 5761#0: lua entry thread aborted: runtime error: .../bundle/lua-bid-proxy/lib/resty/bid_proxy/dispatcher.lua:82>, context: ngx.timer

请问如何正确处理dispatcher对于一个cosocket的读写？谢谢！

nginx.conf:
init_worker_by_lua_block {
local dp = require "resty.proxy.dispatcher"

dp.spawn_sender() -- spawn a sender thread with ngx.timer.at()
dp.spawn_receiver() -- spawn a receiver thread with ngx.timer.at()
}

dispatcher.lua
local function receive()
if not conn_initted then
_M.sock, err = tcp()
_M.sock:connect("127.0.0.1", "10000")
conn_initted = true
end

local read_stream = _M.sock:receiveuntil("_END")
local data, err, partial = read_stream()

sem:post()

-- timer(0, reader)
end

function _M.spawn_receiver()
timer(0, receive)
end

function send(premature)
if _M.buf ~= nil then
local bytes, err = _M.sock:send(_M.buf)
end

timer(1, send)
end

function _M.spawn_sender()
timer(0, send)
end

--

Membhis

My github: https://github.com/membphis

Our Book: OpenResty Best Practices

chuang39

谢谢回复！

我想建一个dispatcher专门负责和upstream cosocket通信，春哥建议用init_worker_by_lua创建线程。cosocket不能直接在init_worker_by_lua中用，也不能在新的环境中用，那我只能在里面用timer建个新的线程，然后这个线程中用死循环不断去pipeline写然后pipeline读，好像没办法读写并行了？

On Monday, December 21, 2015 at 9:07:06 PM UTC-8, YuanSheng Wang wrote:

cosocket 是不能跨会话存在的。

ngx.socket.tcp
... ...
通过该 API 函数创建的 cosocket 对象，与创造它的 Lua 环境拥有相同的生命周期。所以永远不要把 cosocket 对象传递给其他 Lua 环境（包括 ngx.timer 回调函数），并且永远不要在两个不同的 Nginx 请求之间共享 cosocket 对象。

中文 wiki ：https://github.com/iresty/nginx-lua-module-zh-wiki/blob/master/doc/ngxsockettcp.md

On Tue, Dec 22, 2015 at 12:02 PM, 黄川 <chua...@gmail.com> wrote:
对于从 socket，我试图在init_worker_by_lua中用recieveutil读response，在content_by_lua里每request send data，但一直有bad request error。我看到春哥提到 “cosocket objects can only be used by the request creating them”，所以我就让init_worker_by_lua 产生的thread(通过timer)去handle所有读写，但是send的时候还是有 bad request as below.
[error] 5761#0: lua entry thread aborted: runtime error: .../bundle/lua-bid-proxy/lib/resty/bid_proxy/dispatcher.lua:82>, context: ngx.timer

请问如何正确处理dispatcher对于一个cosocket的读写？谢谢！

nginx.conf:
init_worker_by_lua_block {
local dp = require "resty.proxy.dispatcher"

dp.spawn_sender() -- spawn a sender thread with ngx.timer.at()
dp.spawn_receiver() -- spawn a receiver thread with ngx.timer.at()
}

dispatcher.lua
local function receive()
if not conn_initted then
_M.sock, err = tcp()
_M.sock:connect("127.0.0.1", "10000")
conn_initted = true
end

local read_stream = _M.sock:receiveuntil("_END")
local data, err, partial = read_stream()

sem:post()

-- timer(0, reader)
end

function _M.spawn_receiver()
timer(0, receive)
end

function send(premature)
if _M.buf ~= nil then
local bytes, err = _M.sock:send(_M.buf)
end

timer(1, send)
end

function _M.spawn_sender()
timer(0, send)
end

--

--

Membhis
My github: https://github.com/membphis
Our Book: OpenResty Best Practices

agentzh

Hello!

2015-12-21 21:25 GMT-08:00 黄川:
> 我想建一个dispatcher专门负责和upstream
> cosocket通信，春哥建议用init_worker_by_lua创建线程。cosocket不能直接在init_worker_by_lua中用，也不能在新的环境中用，那我只能在里面用timer建个新的线程，然后这个线程中用死循环不断去pipeline写然后pipeline读，好像没办法读写并行了？
>

同时搞两个轻线程分别负责两个方向上的数据流不就完事了？

Regards,
-agentzh

chenweidelphi

我理解你这是个控制链路，本身无需高并发的，可以独立写一个进程和后端通讯，然后通过给nginx写location 控制入口去控制。