OpenResty + Lua 访问Redis

  • Post author:
  • Post category:其他


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

下载后,导入对应的插件:lua_package_path “D:/work/openresty-1.13.6.1-win32/lua-resty-redis/lib/resty/?.lua;;”;

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获得的请求次数、页面打开次数进行具体业务的分析


转载于:https://my.oschina.net/u/2347047/blog/1843368