[openresty] 请教ngx.socket.tcp的receive字节问题

miaohonghit

hi all

我用James Hurst 的库

lua-resty-http

因为我的源站是一个http1.0的服务器(没有) , 数据是一个无穷的流式flv流，我需要循环读512K的chunk数据并用share_dict缓存。上次跟James Hurst交流，让他的库支持了没有content_length的情形，他打了一个patch: https://github.com/pintsized/lua-resty-http/commit/45a5e9f80afe67c1fd7bd377ac2d5a836802dfe3

但是我发现一个问题,如下，读取了max_chunk_size数据后依然继续读取，无穷无尽。我看了官网的receive 没有什么特别的地方。请教春哥为什么不能发挥chunk数据，而是无穷无尽的读呢？谢谢

ngx.log(ngx.ERR, max_chunk_size)

local str, err, partial = sock:receive(max_chunk_size)

ngx.print(str)

if not content_length and max_chunk_size then

-- We have no length, but wish to stream.
-- HTTP 1.0 with no length will close connection, so read chunks to the end.
local str, err, partial = sock:receive(max_chunk_size)

ngx.print(str)

那就只读取一个chunk数据

--

Best Regards,
Harold Miao

agentzh

Hello!

2014-03-06 1:17 GMT-08:00 Harold.Miao :
> 但是我发现一个问题,如下， sock:receive(max_chunk_size)
> 读取了max_chunk_size数据后依然继续读取，无穷无尽。

是你自己的 Lua 无限循环一直在读取吧？

你希望下游写出的速度来控制上游读取的速度？如果是那样的话，你应该在 ngx.print() 调用之后加上 ngx.flush(true)
这一行。我记得我和你说过这个。

Regards,
-agentzh