关于ngx.req.socket

melon198502 · 2013-02-06T09:40:34+00:00

2013/2/6 agentzh <age...@gmail.com> Hello! 2013/2/5 Chunlin Zhang <zhang...@gmail.com>: >> >> 在前面挂...

关于ngx.req.socket

melon198502

请问通过ngx.req.socket获取的socket是个和ngx.print响应输出时所用的套接字是一样的吗？
因为我在调用receive函数接收数据的时候，第一次调用超时之后再次调用就会产生返回closed连接已关闭，然后连接就关闭了，查看nginx日志输出了如下内容：
2013/02/06 09:27:24 [error] 7875#0: *1 lua tcp socket read timed out, client: 127.0.0.1, server: localhost, request: "GET /lua HTTP/1.1", host: "localhost"
2013/02/06 09:27:25 [error] 7875#0: *1 attempt to receive data on a closed socket: u:0000000040427BA8, c:0000000000000000, ft:2 eof:0, client: 127.0.0.1, server: localhost, request: "GET /lua HTTP/1.1", host: "localhost"
但是我用curl测试时并有手动断开连接，莫非是第一次超时之后，套接字关闭了？因为我只调用一次receive超时后，然后ngx.print还能输出响应到客户端，连接依然保持，有些不解
我的测试代码：
location /lua {
            content_by_lua '
                ngx.header.content_type = "text/plain";
                ngx.say("PONG");
                ngx.flush(true);
                local sock,err = ngx.req.socket();
                ngx.say("err", err);
                ngx.flush(true);
                sock:settimeout(5000);
                while 1 do
                    ngx.say("PONG");
                    ngx.flush(true);
                    local line, err, partial = sock:receive(100)
                    temp = 1
                    ---[[
                    if not line then
                        if err == "closed" then
                            ngx.say("err:", err)
                            ngx.flush(true)
                            --ngx.log(ngx.ERR, err)
                            break
                        elseif err == "timeout" then
                            ngx.say("err:", err)
                            ngx.flush(true)
                            --ngx.log(ngx.ERR, err)
                        else
                            ngx.log(ngx.ERR, err)
                            break
                        end
                    end
                    ngx.sleep(1)
                end
            ';
        }
我这么做的初衷是保持一个长连接，通过调用receive判断客户端已断开连接然后结束协程释放资源

agentzh

Hello!

2013/2/5  melon198502:
> 请问通过ngx.req.socket获取的socket是个和ngx.print响应输出时所用的套接字是一样的吗？

在 C 级别上是一个 socket :)

> 因为我在调用receive函数接收数据的时候，第一次调用超时之后再次调用就会产生返回closed连接已关闭，然后连接就关闭了，查看nginx日志输出了如下内容：
> 2013/02/06 09:27:24 [error] 7875#0: *1 lua tcp socket read timed out,
> client: 127.0.0.1, server: localhost, request: "GET /lua HTTP/1.1", host:
> "localhost"
> 2013/02/06 09:27:25 [error] 7875#0: *1 attempt to receive data on a closed
> socket: u:0000000040427BA8, c:0000000000000000, ft:2 eof:0, client:
> 127.0.0.1, server: localhost, request: "GET /lua HTTP/1.1", host:
> "localhost"
> 但是我用curl测试时并有手动断开连接，莫非是第一次超时之后，套接字关闭了？因为我只调用一次receive超时后，然后ngx.print还能输出响应到客户端，连接依然保持，有些不解

按照目前的实现，当下游 cosocket 读取超时的时候，ngx_lua 并不会自动关闭下游连接，而只是在 Lua
级别上返回错误，并将当前的 cosocket 对象置为 closed 状态。用户需要自己调用 ngx.exit(444)
来显式地关闭下游连接。

> 我这么做的初衷是保持一个长连接，通过调用receive判断客户端已断开连接然后结束
> 协程释放资源

通过 receive 判断客户端断开连接？或许你可以看一下 lua_check_client_abort 指令：

    http://wiki.nginx.org/HttpLuaModule#lua_check_client_abort

以及 ngx.on_abort() 函数：

    http://wiki.nginx.org/HttpLuaModule#ngx.on_abort

Best regards,
-agentzh

melon198502

多谢回复:)

在 2013年2月6日星期三UTC+8上午9时56分44秒，agentzh写道：

Hello!

2013/2/5 melon198502:
> 请问通过ngx.req.socket获取的socket是个和ngx.print响应输出时所用的套接字是一样的吗？

在 C 级别上是一个 socket :)

> 因为我在调用receive函数接收数据的时候，第一次调用超时之后再次调用就会产生返回closed连接已关闭，然后连接就关闭了，查看nginx日志输出了如下内容：
> 2013/02/06 09:27:24 [error] 7875#0: *1 lua tcp socket read timed out,
> client: 127.0.0.1, server: localhost, request: "GET /lua HTTP/1.1", host:
> "localhost"
> 2013/02/06 09:27:25 [error] 7875#0: *1 attempt to receive data on a closed
> socket: u:0000000040427BA8, c:0000000000000000, ft:2 eof:0, client:
> 127.0.0.1, server: localhost, request: "GET /lua HTTP/1.1", host:
> "localhost"
> 但是我用curl测试时并有手动断开连接，莫非是第一次超时之后，套接字关闭了？因为我只调用一次receive超时后，然后ngx.print还能输出响应到客户端，连接依然保持，有些不解

按照目前的实现，当下游 cosocket 读取超时的时候，ngx_lua 并不会自动关闭下游连接，而只是在 Lua
级别上返回错误，并将当前的 cosocket 对象置为 closed 状态。用户需要自己调用 ngx.exit(444)
来显式地关闭下游连接。

一次超时就要置为closed状态？这样的话是不是如果想重试就不太可能了，只能事重头再来了？

> 我这么做的初衷是保持一个长连接，通过调用receive判断客户端已断开连接然后结束
> 协程释放资源

通过 receive 判断客户端断开连接？或许你可以看一下 lua_check_client_abort 指令：

http://wiki.nginx.org/HttpLuaModule#lua_check_client_abort

以及 ngx.on_abort() 函数：

http://wiki.nginx.org/HttpLuaModule#ngx.on_abort

这个我有试过，只是突然想到了用receive的这种方式好像应该也可以实现，感觉发现客户端连接断掉能更及时一些，而且不用做太多配置:)

Best regards,
-agentzh

agentzh

Hello!

2013/2/5  melon198502:
>> 按照目前的实现，当下游 cosocket 读取超时的时候，ngx_lua 并不会自动关闭下游连接，而只是在 Lua
>> 级别上返回错误，并将当前的 cosocket 对象置为 closed 状态。用户需要自己调用 ngx.exit(444)
>> 来显式地关闭下游连接。
>
>
> 一次超时就要置为closed状态？这样的话是不是如果想重试就不太可能了，只能事重头再来了？

在最新的 ngx_lua 0.8.8 中，cosocket 的读取超时错误不再会让当前的 cosocket 对象自动进入 closed
状态。无论是下游连接，还是上游连接。

Best regards,
-agentzh

melon198502

太好了！春哥辛苦了，这两天我就给升级试试

在 2013年9月9日星期一UTC+8上午7时26分05秒，agentzh写道：

Hello!

2013/2/5 melon198502:
>> 按照目前的实现，当下游 cosocket 读取超时的时候，ngx_lua 并不会自动关闭下游连接，而只是在 Lua
>> 级别上返回错误，并将当前的 cosocket 对象置为 closed 状态。用户需要自己调用 ngx.exit(444)
>> 来显式地关闭下游连接。
>
>
> 一次超时就要置为closed状态？这样的话是不是如果想重试就不太可能了，只能事重头再来了？

在最新的 ngx_lua 0.8.8 中，cosocket 的读取超时错误不再会让当前的 cosocket 对象自动进入 closed
状态。无论是下游连接，还是上游连接。

Best regards,
-agentzh