通用的redis订阅接口, nginx+lua+redis

nginx.conf

        location =/subscribe {
            send_timeout 365h;
            content_by_lua "
            local redis = require \"resty.redis\"
            local red = redis:new()
            red:connect(\"127.0.0.1\", 6379)
            red:subscribe(ngx.var.arg_key)
            local res, err = red:read_reply()
            if res then 
                ngx.say(res)
            else
                ngx.status = 500
            end
            red:close()
            ";
        }