ngx.socket.tcp()关于连接池的问题?

382482175

hello:

在lua-resty-redis库中：

location /test {

content_by_lua_block {

local ok,err

local red,err=redis:new()

red:set_timeout(1000)

ok,err=red:connect("127.0.0.1",6379)

red:set("dog","animal")

ok,err=red:set_keepalive(10000,100)

}

这里有几个问题请求下：

1 看了下red:new，是调用ngx.socket.tcp()生成了一个cosocket对象

2 red:set_keepalive 在这个cosocket对象上执行了 keepalive的操作

我的疑惑是：

1 一条连接和cosocket不是绑定的么？cosocket的底层实现是不是socket fd呀？

2 再来一次请求的话，又要生成新的red:new，cosocket实例，那么如何还可以复用连接了？

可能是之前没接触过连接池这个东西，在我的印象里，一条tcp连接是和两个（peer）socket相关的，不清楚连接池这里是如何实现的，望科普。。。

382482175

我自己尝试理解一下这里的关系：

1 其实在新建cosocket实例时候，并没有创建内核的socket描述符，而是等到connect的时候才会去创建和关联一个socket

2 在成功执行了connect后的cosocket实例上，调用setkeepalive操作，这样不会把其关联的socket关闭掉，而是保持这个socket。

3 当再次执行cosocket创建，connect时，这时候会去查找之前是否有与相同对端连接的socket未被释放，这个时候当前的cosocke会复用这个socket。

没有看源码，只是我的猜想，不知道对不对。

话说这个cosocket的实现必须要看看源码才能玩转ngx_lua。。。。

在 2017年3月13日星期一 UTC+8下午4:53:39，wwaz wwaz写道：

hello:

在lua-resty-redis库中：

location /test {

content_by_lua_block {

local ok,err
local red,err=redis:new()
red:set_timeout(1000)
ok,err=red:connect("127.0.0.1",6379)

red:set("dog","animal")

ok,err=red:set_keepalive(10000,100)

}
}

这里有几个问题请求下：

1 看了下red:new，是调用ngx.socket.tcp()生成了一个cosocket对象
2 red:set_keepalive 在这个cosocket对象上执行了 keepalive的操作

我的疑惑是：
1 一条连接和cosocket不是绑定的么？cosocket的底层实现是不是socket fd呀？
2 再来一次请求的话，又要生成新的red:new，cosocket实例，那么如何还可以复用连接了？

可能是之前没接触过连接池这个东西，在我的印象里，一条tcp连接是和两个（peer）socket相关的，不清楚连接池这里是如何实现的，望科普。。。

qleex001

1. red:new()实际上返回一个新创建的table，之后的connect，setkeepalive都是通过附加的元表操作的，这一步没有创建socket。当执行red:connect()的时候，会先查找连接池中是否有空前的连接存在，有的话取出，没有的话新建连接。

2. cosocket和底层的socket id没有特殊的绑定关系，只是每个底层的socket在同一时间只能被一个cosocket使用。

3. cosocket完成需要的操作后，TCP连接还在，可以把TCP连接放回连接池，供下一个cosocket使用。

在 2017年3月13日星期一 UTC+8下午4:53:39，wwaz wwaz写道：

hello:

在lua-resty-redis库中：

location /test {

content_by_lua_block {

local ok,err
local red,err=redis:new()
red:set_timeout(1000)
ok,err=red:connect("127.0.0.1",6379)

red:set("dog","animal")

ok,err=red:set_keepalive(10000,100)

}
}

这里有几个问题请求下：

1 看了下red:new，是调用ngx.socket.tcp()生成了一个cosocket对象
2 red:set_keepalive 在这个cosocket对象上执行了 keepalive的操作

我的疑惑是：
1 一条连接和cosocket不是绑定的么？cosocket的底层实现是不是socket fd呀？
2 再来一次请求的话，又要生成新的red:new，cosocket实例，那么如何还可以复用连接了？

可能是之前没接触过连接池这个东西，在我的印象里，一条tcp连接是和两个（peer）socket相关的，不清楚连接池这里是如何实现的，望科普。。。

382482175

感谢回复～～

在 2017年3月14日星期二 UTC+8上午9:55:51，FQ Liu写道：

1. red:new()实际上返回一个新创建的table，之后的connect，setkeepalive都是通过附加的元表操作的，这一步没有创建socket。当执行red:connect()的时候，会先查找连接池中是否有空前的连接存在，有的话取出，没有的话新建连接。

创建连接的话，内核总是要创建socket fd的吧，没有socket fd的tcp连接我目前还不了解过， “会去查找连接池中是否有空闲连接” 这里的连接指的是什么呢？另外什么叫做空闲的连接呢？

（这里的连接池和nginx内部实现的connection连接池不一样的吧，nginx内部的connection连接池是为了worker间负载均衡和快速分配资源的作用而存在的）

2. cosocket和底层的socket id没有特殊的绑定关系，只是每个底层的socket在同一时间只能被一个cosocket使用。

3. cosocket完成需要的操作后，TCP连接还在，可以把TCP连接放回连接池，供下一个cosocket使用。

在 2017年3月13日星期一 UTC+8下午4:53:39，wwaz wwaz写道：
hello:

在lua-resty-redis库中：

location /test {

content_by_lua_block {

local ok,err
local red,err=redis:new()
red:set_timeout(1000)
ok,err=red:connect("127.0.0.1",6379)

red:set("dog","animal")

ok,err=red:set_keepalive(10000,100)

}
}

这里有几个问题请求下：

1 看了下red:new，是调用ngx.socket.tcp()生成了一个cosocket对象
2 red:set_keepalive 在这个cosocket对象上执行了 keepalive的操作

我的疑惑是：
1 一条连接和cosocket不是绑定的么？cosocket的底层实现是不是socket fd呀？
2 再来一次请求的话，又要生成新的red:new，cosocket实例，那么如何还可以复用连接了？

可能是之前没接触过连接池这个东西，在我的印象里，一条tcp连接是和两个（peer）socket相关的，不清楚连接池这里是如何实现的，望科普。。。

doujiang24

Hello

在 2017年3月13日下午4:53，wwaz wwaz <3824...@qq.com>写道：

1 一条连接和cosocket不是绑定的么？cosocket的底层实现是不是socket fd呀？

并不绑定

ngx.socket.tcp() 试试一个 OpenResty 层面的对象

只有 connect 的时候，才会真的有系统调用，也就是真的建立连接

你可以使用如下用例体验一把 :)

local sock = ngx.socket.tcp()

sock:connect(host_1, port_1)

sock:connect(host_2, port_2)

2 再来一次请求的话，又要生成新的red:new，cosocket实例，那么如何还可以复用连接了？

set_keepalive 是将 OpenResty 层面的 sock 对象与 connection 接触关联的过程

此时 connection 会进入连接池，而上层的 sock 是不影响的

可能是之前没接触过连接池这个东西，在我的印象里，一条tcp连接是和两个（peer）socket相关的，不清楚连接池这里是如何实现的，望科普。。。

--