如何通过OpenResty Lua高效访问Redis，实现高并发下的毫秒级快速响应？

本文共计716个文字，预计阅读时间需要3分钟。

配置依赖：1、安装OpenResty的lua-redis插件：https://github.com/openresty/lua-resty-redis，下载后导入对应插件：lua_package_path /opt/openresty/lualib/kafka/?lua;?.lua;; lua_need_request_body on。2、使用lua访问：

配置依赖：

1、OpenResty的lua访问redis的插件：github.com/openresty/lua-resty-redis

下载后，导入对应的插件：

lua_package_path "/opt/openresty/lualib/kafka/?.lua;;";
lua_need_request_body on;

2、使用lua访问redis：

server {
location /test {
content_by_lua_block {
local redis = require "resty.redis"
local red = redis:new()

red:set_timeout(1000) -- 1 sec

-- or connect to a unix domain socket file listened
-- by a redis server:
-- local ok, err = red:connect("unix:/path/to/redis.sock")

local ok, err = red:connect("127.0.0.1", 6379)
if not ok then
ngx.say("failed to connect: ", err)
return
end

ok, err = red:set("dog", "an animal")
if not ok then
ngx.say("failed to set dog: ", err)
return
end

ngx.say("set result: ", ok)

local res, err = red:get("dog")
if not res then
ngx.say("failed to get dog: ", err)
return
end

if res == ngx.null then
ngx.say("dog not found.")
return
end

ngx.say("dog: ", res)

red:init_pipeline()
red:set("cat", "Marry")
red:set("horse", "Bob")
red:get("cat")
red:get("horse")
local results, err = red:commit_pipeline()
if not results then
ngx.say("failed to commit the pipelined requests: ", err)
return
end

for i, res in ipairs(results) do
if type(res) == "table" then
if res[1] == false then
ngx.say("failed to run command ", i, ": ", res[2])
else
-- process the table value
end
else
-- process the scalar value
end
end

-- put it into the connection pool of size 100,
-- with 10 seconds max idle time
local ok, err = red:set_keepalive(10000, 100)
if not ok then
ngx.say("failed to set keepalive: ", err)
return
end

-- or just close the connection right away:
-- local ok, err = red:close()
-- if not ok then
-- ngx.say("failed to close: ", err)
-- return
-- end
}
}
}

3、使用redis连接池

local ok, err = red:set_keepalive(60000, 20)

4、需要密码的redis的访问：使用 auth 方法

local ok, err = red.connect(red, "127.0.0.1", "6379")
if not ok then
return
end

local res, err = red:auth("password")
if not res then
return
end

5、redis的操作，不需要单独封装方法，lua-resty-redis 支持自动生成对应的lua方法

具体配置方法是：redis.lua 中，common_cmds 的array，在这里添加需要使用的方法

例如：需要使用redis hsah的hincrby，那么就在common_cmds 添加hincrby，在lua中直接使用就可以，red:hincrby(key, field, 1)

6、项目中的使用场景

（1）前端http查询一些数据，直接在nginx中通过lua访问redis拿到，直接返回到前端，减少服务器的压力；redis中数据通过服务器进行主动更新

（2）点击次数和页面打开次数分析：在点击和页面打开之间，加上了请求到达nginx的统计，当请求到达nginx时，通过lua将访问的页面次数写入redis中，然后通过点击次数、nginx获得的请求次数、页面打开次数进行具体业务的分析