About redis:subscribe about lua-resty-redis HOT 4 CLOSED

input: 
    subscribe channel:first channel:second
response:
    1) "subscribe"
    2) "channel:first"
    3) (integer) 1
    1) "subscribe"
    2) "channel:second"
    3) (integer) 2

    1) "subscribe"
    2) "channel:second"
    3) (integer) 2

local redis = require "resty.redis"
local cjson = require "cjson"

local user_uid = ngx.var.user_uid
local user_channel = "channel:user:"..user_uid

local server = require "resty.websocket.server"
local wb, err = server:new{
    timeout = 5000,
    max_payload_len = 65535
}
if not wb then
    ngx.log(ngx.ERR, "failed to new websocket: ", err)
    return ngx.exit(444)
end

local function subscribe (ws)

    local sub = redis:new()
    sub:connect("127.0.0.1", 6379)
    local res, err = sub:subscribe(user_channel)
    if not res then
        ngx.say("failed to subscribe: ", err)
        return
    end

    while true do
        local bytes, err = sub:read_reply()
        if bytes then
            local _json = cjson.decode(bytes[3])
            if _json.type == 'subscribe' then
                -- for k, v in pairs(_json.data) do
                local res, err = sub:subscribe('channel:first', 'channel:second')
                if err then
                    ws:send_text("{'type': 'ws_response', 'data': 0}")
                    ws:send_text(err)
                end
                -- end
            elseif _json.type == 'unsubscribe' then
                sub:unsubscribe()
                break
            else
                ws:send_text(bytes[3])
            end
        else
            ngx.log(ngx.ERR, "no data")
        end
    end
end

ngx.thread.spawn(subscribe, wb)

local pub = redis:new()
pub:connect("127.0.0.1", 6379)

while true do 
    local data, typ, err = wb:recv_frame()
    if wb.fatal then
        return ngx.exit(444)
    end
    if not data then
        local bytes, err = wb:send_ping()
        if not bytes then
            return ngx.exit(444)
        end

    elseif typ == "close" then
        break
    elseif typ == "ping" then
        local bytes, err = wb:send_pong()
        if not bytes then
            return ngx.exit(444)
        end
    elseif typ == "pong" then
        ngx.log(ngx.INFO, "client ponged")

    elseif typ == "text" then
        pub:publish(user_channel, data)
    end
end
wb:send_close()

2015/08/30 14:49:45 [error] 1606#0: *519 lua user thread aborted: runtime error: /Users/ones/ones/hua_sheng/lua/ws_notify.lua:39: attempt to index local '_json' (a number value)
stack traceback:
coroutine 0:
    /Users/ones/ones/hua_sheng/lua/ws_notify.lua: in function </Users/ones/ones/hua_sheng/lua/ws_notify.lua:25>
coroutine 1:
    [C]: in function 'receive'
    /usr/local/openresty/lualib/resty/websocket/protocol.lua:48: in function '_recv_frame'
    /usr/local/openresty/lualib/resty/websocket/server.lua:149: in function 'recv_frame'
    /Users/ones/ones/hua_sheng/lua/ws_notify.lua:65: in function </Users/ones/ones/hua_sheng/lua/ws_notify.lua:1>, client: 127.0.0.1, server: , request: "GET /ws/notify/31 HTTP/1.1", host: "127.0.0.1"

input: 
    subscribe channel:first channel:second
response:
    1) "subscribe"
    2) "channel:first"
    3) (integer) 1
    1) "subscribe"
    2) "channel:second"
    3) (integer) 2

input:
    subscribe('channel:first', 'channel:second')
response:
    1) "subscribe"
    2) "channel:first"
    3) (integer) 1