lua-resty-redis subscribe 行为与redis本身行为不一致

ilskdw · 2014-04-01T13:24:26+00:00

Hello! On Mon, Mar 31, 2014 at 10:05 PM, CMGS wrote: > 而且还有个问题，subscribe不支持&...

lua-resty-redis subscribe 行为与redis本身行为不一致

ilskdw

redis中，subscribe和unsubscribe是支持多key同时订阅（取消订阅）的

如， SUBSCRIBE DOG CAT

这个时候发布者可以对其中某个Key Publish，返回值类似于

1) message

2) dog

3) abcdefg

在lua-resty-redis中，尝试使用多key传入发现并不能订阅

redis版本2.8.8

最小化测试代码

local server = require "resty.websocket.server"

local redis = require "resty.redis"

local ws, err = server:new {

timeout = 6000000,

max_payload_len = 65535

}

local red2 = redis:new()

red2:set_timeout(6000000)

red2:connect("127.0.0.1", 6379)

local keys = {"dog", "cat"}

local res, err = red2:subscribe(keys)

if not res then

ngx.log(ngx.ERR, err)

end

ngx.log(ngx.INFO, "waiting for reply")

local res, err = red2:read_reply()

if not res then

ngx.log(ngx.ERR, err)

end

print(res[3])

local res, err = ws:send_close()

ngx.log(ngx.INFO, "closing")

if not res then

ngx.log(ngx.ERR, err)

end

res, err = red2:unsubscribe(keys)

if not res then

ngx.log(ngx.ERR, err)

end

red2:set_keepalive(2000, 100)

ngx.exit(444)

值得注意的是，subscribe的行为并未报错

但这个时候我在redis-cli使用PUBLISH cat "abcdefg"的时候，明显可以观察到read_reply并未返回。而redis这边给出的pub返回值也是0，意味着并未有人sub过cat这个key。

所以这是个bug嘛？

doujiang24

这个不是 bug

red:subscribe("dog", "cat") 一次订阅多个 key 得这么用

你传进去的 keys 是 table 值，被 tostring 为字符串 table*** 了，所以没有报错

ps：订阅模式下，redis 不再是一般的一请求一应答模式，但是 lua-resty-redis 目前只是每次调用读取一个结果

尤其在订阅多个 key 的时候会更加明显，建议阅读下源码，在上层再做一次封装

在 2014年4月1日下午1:24，Kelvin Peng <il...@gmail.com>写道：

redis中，subscribe和unsubscribe是支持多key同时订阅（取消订阅）的
如， SUBSCRIBE DOG CAT

这个时候发布者可以对其中某个Key Publish，返回值类似于

1) message
2) dog
3) abcdefg

在lua-resty-redis中，尝试使用多key传入发现并不能订阅
redis版本2.8.8

最小化测试代码
local server = require "resty.websocket.server"

local redis = require "resty.redis"

local ws, err = server:new {
timeout = 6000000,
max_payload_len = 65535
}

local red2 = redis:new()

red2:set_timeout(6000000)
red2:connect("127.0.0.1", 6379)

local keys = {"dog", "cat"}

local res, err = red2:subscribe(keys)

if not res then
ngx.log(ngx.ERR, err)
end

ngx.log(ngx.INFO, "waiting for reply")
local res, err = red2:read_reply()
if not res then

ngx.log(ngx.ERR, err)
end

print(res[3])

local res, err = ws:send_close()
ngx.log(ngx.INFO, "closing")
if not res then

ngx.log(ngx.ERR, err)
end
res, err = red2:unsubscribe(keys)
if not res then
ngx.log(ngx.ERR, err)
end
red2:set_keepalive(2000, 100)
ngx.exit(444)

值得注意的是，subscribe的行为并未报错
但这个时候我在redis-cli使用PUBLISH cat "abcdefg"的时候，明显可以观察到read_reply并未返回。而redis这边给出的pub返回值也是0，意味着并未有人sub过cat这个key。

所以这是个bug嘛？

--

ilskdw

了解了~~我重构了这部分搞定~

2014-04-01 22:26 GMT+08:00 DeJiang Zhu <douj...@gmail.com>:

这个不是 bug

red:subscribe("dog", "cat") 一次订阅多个 key 得这么用

你传进去的 keys 是 table 值，被 tostring 为字符串 table*** 了，所以没有报错

ps：订阅模式下，redis 不再是一般的一请求一应答模式，但是 lua-resty-redis 目前只是每次调用读取一个结果

尤其在订阅多个 key 的时候会更加明显，建议阅读下源码，在上层再做一次封装

在 2014年4月1日下午1:24，Kelvin Peng <il...@gmail.com>写道：

redis中，subscribe和unsubscribe是支持多key同时订阅（取消订阅）的
如， SUBSCRIBE DOG CAT

这个时候发布者可以对其中某个Key Publish，返回值类似于

1) message
2) dog
3) abcdefg

在lua-resty-redis中，尝试使用多key传入发现并不能订阅
redis版本2.8.8

最小化测试代码
local server = require "resty.websocket.server"

local redis = require "resty.redis"

local ws, err = server:new {
timeout = 6000000,
max_payload_len = 65535
}

local red2 = redis:new()

red2:set_timeout(6000000)
red2:connect("127.0.0.1", 6379)

local keys = {"dog", "cat"}

local res, err = red2:subscribe(keys)

if not res then
ngx.log(ngx.ERR, err)
end

ngx.log(ngx.INFO, "waiting for reply")
local res, err = red2:read_reply()
if not res then

ngx.log(ngx.ERR, err)
end

print(res[3])

local res, err = ws:send_close()
ngx.log(ngx.INFO, "closing")
if not res then

ngx.log(ngx.ERR, err)
end
res, err = red2:unsubscribe(keys)
if not res then
ngx.log(ngx.ERR, err)
end
red2:set_keepalive(2000, 100)
ngx.exit(444)

值得注意的是，subscribe的行为并未报错
但这个时候我在redis-cli使用PUBLISH cat "abcdefg"的时候，明显可以观察到read_reply并未返回。而redis这边给出的pub返回值也是0，意味着并未有人sub过cat这个key。

所以这是个bug嘛？

--

--

-CMGS

A simple coder.

Love travel, sports especially outdoor sports and computer technology.

Have a dream that one day can tour around.