个性
- 应用连接池
- 连贯只须要一次认证
装置
opm install openresty/lua-resty-redis代码 redis.lua
-- redis客户端 local redis = require("resty/redis")local config = { host = "127.0.0.1", port = 6379, password = "", db_index = 0, max_idle_time = 30000, database = 0, pool_size = 100, timeout = 5000,}local _M = {}function _M.new() local instance = { host = config.host or "127.0.0.1", port = config.port or 6379, password = config.password or "", timeout = config.timeout or 5000, database = config.database or 0, max_idle_time = config.max_idle_time or 60000, pool_size = config.pool_size or 100 } setmetatable(instance, {__index = _M}) return instanceendfunction _M:exec(func) local red = redis:new() -- 为后续操作设置超时（以毫秒为单位）爱护，包含connect办法。 red:set_timeout(self.timeout) -- 建设连贯 local ok, err = red:connect(self.host, self.port) if not ok then ngx.log(ngx.ERR, "Redis: ", "Cannot connect, host: " .. self.host .. ", port: " .. self.port) return nil, err end if self.password ~= "" then -- 如果连贯来自于连接池中，get_reused_times() 永远返回一个非零的值 -- 只有新的连贯才会进行受权 local count, err = red:get_reused_times() if count == 0 then ok, err = red:auth(self.password) if not ok then red:close() return ok, err end end end if self.database ~= 0 then red:select(self.database) end -- 执行业务逻辑 local res, err = func(red) -- 将连贯放回连接池 local ok, err = red:set_keepalive(self.max_idle_time, self.pool_size) if not ok then red:close() end return res, errendreturn _M理论应用
local redis = require("redis")local red = redis.new()local v, err = red:exec(function(red) return red:get("wechat:login_key")end)-- print(v, type(v), err, type(err))-- v 不存在时是UserData类型if not v or v == ngx.null then -- 解决key不存在状况end-- 解决存在状况参考文章
https://segmentfault.com/a/11...
https://github.com/openresty/...
https://xiaorui.cc/archives/4784
https://cloud.tencent.com/dev...