lua-resty-http方面的问题

pengzhixi68 · 2015-07-28T10:40:03+00:00

嗯，我过几天放到github上去在 2015年7月28日星期二 UTC+8...

lua-resty-http方面的问题

pengzhixi68

当我用connect链接一个外网服务器后我可以间隔一段时间发送一个请求么？我看了里面有request_pipeline 但是我这些请求是需要隔段时间（这个时间间隔不确定）发一次，我能不能connect之后到了能发请求的时候就调用一次httpc:request？还是说我每次发请求都需要重新connect呢？

agentzh

Hello!

2015-07-28 10:40 GMT+08:00  pengzhixi68:
> 当我用connect链接一个外网服务器后 我可以间隔一段时间发送一个请求么？我看了里面有request_pipeline
> 但是我这些请求是需要隔段时间（这个时间间隔不确定）发一次，我能不能connect之后
> 到了能发请求的时候就调用一次httpc:request？还是说我每次发请求都需要重新connect呢？
>

可以在 init_worker_by_lua 里通过 ngx.timer.at 创建反复触发的定时器。

另外，注意，connect() 方法总是会先从连接池里找空闲连接，找不到才会去真正重连。

Regards,
-agentzh

pengzhixi68

章大大可能我的业务场景要求我不能在 init_worker_by_lua里面创建timer,我的业务场景大概是这样的，客户通过post以及uri中的op和context参数上传操作类型和任务列表，比如操作是publish 而任务列表就是一组url和对应的路径，这个操作要求我们链接这组url的服务器下载文件然后放到本地的文件系统中对应的文件路径。当客户上传任务，我们接收之后才需要定时向他们提供的另外一个url反馈我们处理的状态。按照大大提供的思路，那是不是接收任务之后我就可以用ngx.timer.at创建定时任务，在这个定时任务里面链接客户提供的url以及反馈任务处理状态呢？

在 2015年7月28日星期二 UTC+8下午1:30:57，agentzh写道：

Hello!

2015-07-28 10:40 GMT+08:00 pengzhixi68:
> 当我用connect链接一个外网服务器后我可以间隔一段时间发送一个请求么？我看了里面有request_pipeline
> 但是我这些请求是需要隔段时间（这个时间间隔不确定）发一次，我能不能connect之后
> 到了能发请求的时候就调用一次httpc:request？还是说我每次发请求都需要重新connect呢？
>

可以在 init_worker_by_lua 里通过 ngx.timer.at 创建反复触发的定时器。

另外，注意，connect() 方法总是会先从连接池里找空闲连接，找不到才会去真正重连。

Regards,
-agentzh

agentzh

Hello!

2015-07-28 14:19 GMT+08:00  pengzhixi68:
> 章大大 可能我的业务场景要求我不能在
> init_worker_by_lua里面创建timer,我的业务场景大概是这样的，客户通过post以及uri中的op和context参数上传操作类型和任务列表，比如操作是publish
> 而任务列表就是一组url和对应的路径，这个操作要求我们链接这组url的服务器下载文件然后放到本地的文件系统中对应的文件路径。当客户上传任务，我们接收之后才需要定时向他们提供的另外一个url反馈我们处理的状态。按照大大提供的思路，那是不是接收任务之后我就可以用ngx.timer.at创建定时任务，在这个定时任务里面链接客户提供的url以及反馈任务处理状态呢？
>

我的玩法可以用于你这个场景。你可以通过一个或一组共享的 Lua table 来作为你的任务队列。在 init_worker_by_lua
中创建的 worker 唯一的 timer 序列可以根据任务队列来执行任务，如果队列为空，则什么也不做。不同的 URL
可以共享一个或一组任务队列。你的玩法容易导致定时器的数量爆炸，其实不同类型的任务可以通过队列共享同一个 timer.

Regards,
-agentzh

pengzhixi68

章大大也就是说当我需要让回调函数发送状态数据那么我就把状态数据放到这个共享的lua table里面，如果不想回调发送那么就把table里面的数据清空就是了对吧？还想问下，这个共享的table是每个worker进程都有的吧。另外就是因为发送这些状态数据都需要链接客户给我提供的url来发送，那么是否链接也是看共享的lua table是否有数据来判断了吧？

在 2015年7月28日星期二 UTC+8下午5:00:24，agentzh写道：

Hello!

2015-07-28 14:19 GMT+08:00 pengzhixi68:
> 章大大可能我的业务场景要求我不能在
> init_worker_by_lua里面创建timer,我的业务场景大概是这样的，客户通过post以及uri中的op和context参数上传操作类型和任务列表，比如操作是publish
> 而任务列表就是一组url和对应的路径，这个操作要求我们链接这组url的服务器下载文件然后放到本地的文件系统中对应的文件路径。当客户上传任务，我们接收之后才需要定时向他们提供的另外一个url反馈我们处理的状态。按照大大提供的思路，那是不是接收任务之后我就可以用ngx.timer.at创建定时任务，在这个定时任务里面链接客户提供的url以及反馈任务处理状态呢？
>

我的玩法可以用于你这个场景。你可以通过一个或一组共享的 Lua table 来作为你的任务队列。在 init_worker_by_lua
中创建的 worker 唯一的 timer 序列可以根据任务队列来执行任务，如果队列为空，则什么也不做。不同的 URL
可以共享一个或一组任务队列。你的玩法容易导致定时器的数量爆炸，其实不同类型的任务可以通过队列共享同一个 timer.

Regards,
-agentzh

agentzh

Hello!

2015-07-28 17:33 GMT+08:00  pengzhixi68:
> 章大大 也就是说 当我需要让回调函数发送状态数据那么我就把状态数据放到这个共享的lua table里面，如果不想回调发送
> 那么就把table里面的数据清空就是了对吧？

不想发送，直接不把任务放进队列里不就完事了？

> 还想问下，这个共享的table是每个worker进程都有的吧。

见 https://github.com/openresty/lua-nginx-module#data-sharing-within-an-nginx-worker

> 另外就是因为发送这些状态数据都需要链接客户给我提供的url来发送，那么是否链接也是看共享的lua
> table是否有数据来判断了吧？
>

当然，这属于你的任务描述的一部分，随便你怎么决定了。

Regards,
-agentzh

pengzhixi68

谢谢大大我去研究下你给的链接

在 2015年7月28日星期二 UTC+8下午5:52:50，agentzh写道：

Hello!

2015-07-28 17:33 GMT+08:00 pengzhixi68:
> 章大大也就是说当我需要让回调函数发送状态数据那么我就把状态数据放到这个共享的lua table里面，如果不想回调发送
> 那么就把table里面的数据清空就是了对吧？

不想发送，直接不把任务放进队列里不就完事了？

> 还想问下，这个共享的table是每个worker进程都有的吧。

见 https://github.com/openresty/lua-nginx-module#data-sharing-within-an-nginx-worker

> 另外就是因为发送这些状态数据都需要链接客户给我提供的url来发送，那么是否链接也是看共享的lua
> table是否有数据来判断了吧？
>

当然，这属于你的任务描述的一部分，随便你怎么决定了。

Regards,
-agentzh