一、lua中redis的配置依赖:
1、OpenResty的lua访问redis的插件:https://github.com/openresty/lua-resty-redis
二、下载后,导入对应的插件:
lua_package_path "/opt/openresty/lualib/kafka/?.lua;;";
lua_need_request_body on;三、lua代码
2、使用lua访问redis:
server {
location /test { content_by_lua_block { local redis = require "resty.redis" local red = redis:new()red:set_timeout(1000)
-- 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 endok, err = red:set("dog", "an animal")
if not ok then ngx.say("failed to set dog: ", err) return endngx.say("set result: ", ok)
local res, err = red:get("dog")
if not res then ngx.say("failed to get dog: ", err) return endif res == ngx.null then
ngx.say("dog not found.") return endngx.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 endfor 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 endlocal res, err = red:auth("password")
if not res then return end5、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获得的请求次数、页面打开次数进行具体业务的分析