Hello! 2014-09-06 23:05 GMT-07:00 付海清: > 目前系统通过ngx.socket.tcp()和一个非常费时的计算平台交互。 > > 我想让用户触发计算事件后,response马上返回。 等计算完成后,通过消息通知用户。 > > openresty怎么实现这种完全异步的回调机制呢? 谢谢! > 建议配合使用专门的队列服务,比如 beanstalkd 和 rabbitmq 这样的东西,来进行设计。这样也方便扩展到多机集群。 Regards, -agentzh
多谢春哥,决定结合 resty-beanstakd 使用 beanstakd来设计这块.在 2014年9月8日星期一UTC+8上午5时45分22秒,agentzh写道:Hello! 2014-09-06 23:05 GMT-07:00 付海清: > 目前系统通过ngx.socket.tcp()和一个非常费时的计算平台交互。 > > 我想让用户触发计算事件后,response马上返回。 等计算完成后,通过消息通知用户。 > > openresty怎么实现这种完全异步的回调机制呢? 谢谢! > 建议配合使用专门的队列服务,比如 beanstalkd 和 rabbitmq 这样的东西,来进行设计。这样也方便扩展到多机集群。 Regards, -agentzh --
欢迎使用 lua-resty-beanstalkd 模块,有问题请反馈。另外友情提醒下:尽量不要在 http 里面去消费消息,由后端来处理消息。--smallfish http://chenxiaoyu.org 2014-09-10 13:43 GMT+08:00 付海清 <fuh...@gmail.com>:多谢春哥,决定结合 resty-beanstakd 使用 beanstakd来设计这块.在 2014年9月8日星期一UTC+8上午5时45分22秒,agentzh写道:Hello! 2014-09-06 23:05 GMT-07:00 付海清: > 目前系统通过ngx.socket.tcp()和一个非常费时的计算平台交互。 > > 我想让用户触发计算事件后,response马上返回。 等计算完成后,通过消息通知用户。 > > openresty怎么实现这种完全异步的回调机制呢? 谢谢! > 建议配合使用专门的队列服务,比如 beanstalkd 和 rabbitmq 这样的东西,来进行设计。这样也方便扩展到多机集群。 Regards, -agentzh --