lua-resty-redis 如何使用 Pub/Sub（发布/订阅）

richard.chen

大家好！

lua-resty-redis 中如何使用 redis 的Pub/Sub（发布/订阅）功能？请有经验哥们介绍一下，谢谢！

Richard Chen

smallfish.xy

可以参考：https://github.com/agentzh/lua-resty-redis#read_reply 文档

贴一段简单的测试代码：

      location /redis-sub {
            content_by_lua '
                local cjson = require "cjson"
                local redis = require "resty.redis"
                local red   = redis:new()
                red:connect("127.0.0.1", 6379)

                local res, err = red:subscribe("dog")
                ngx.say(cjson.encode(res))

                res, err = red:read_reply()
                ngx.say(cjson.encode(res))
            ';
        }

用curl访问一下：
$ curl http://localhost:8080/redis-sub

这里省略一些判断错误的逻辑，在客户端里：
$ redis-cli
redis 127.0.0.1:6379> PUBLISH dog aaaa

就会看到curl返回输出了。

smallfish http://chenxiaoyu.org

On Fri, Nov 29, 2013 at 6:27 PM, Chen Richard <richa...@zkteco.com> wrote:

大家好！

lua-resty-redis 中如何使用 redis 的Pub/Sub（发布/订阅）功能？请有经验哥们介绍一下，谢谢！

Richard Chen

--

richard.chen

很好使，多谢了！

Richard Chen 陈书楷

ZKSoftware Inc. 中控科技

http://www.zkteco.com

Tel 电话联系：
+86-10-51292999/51297088 - 1015(Beijing 北京)
+86-755-83512543/53/63/73/83 - 1038(Shenzhen 深圳工厂)

2013/11/29 smallfish <small...@gmail.com>

可以参考：https://github.com/agentzh/lua-resty-redis#read_reply 文档

贴一段简单的测试代码：

      location /redis-sub {
            content_by_lua '
                local cjson = require "cjson"
                local redis = require "resty.redis"
                local red   = redis:new()
                red:connect("127.0.0.1", 6379)

                local res, err = red:subscribe("dog")
                ngx.say(cjson.encode(res))

                res, err = red:read_reply()
                ngx.say(cjson.encode(res))
            ';
        }

用curl访问一下：
$ curl http://localhost:8080/redis-sub

这里省略一些判断错误的逻辑，在客户端里：
$ redis-cli
redis 127.0.0.1:6379> PUBLISH dog aaaa

就会看到curl返回输出了。

--
smallfish http://chenxiaoyu.org

On Fri, Nov 29, 2013 at 6:27 PM, Chen Richard <richa...@zkteco.com> wrote:

大家好！

lua-resty-redis 中如何使用 redis 的Pub/Sub（发布/订阅）功能？请有经验哥们介绍一下，谢谢！

Richard Chen

--
class="HOEnZb">

--