1. 连接需授权的redis
server {location /redis1 {content_by_lua_block {local redis = require "resty.redis"local red = redis:new()-- 1秒red:set_timeout(1000) local ok, err = red:connect("127.0.0.1", 6379)if not ok thenngx.say("failed to connect: ", err)returnend-- 请注意这里 auth 的调用过程local countcount, err = red:get_reused_times()-- 如果当前连接不是从内建连接池中获取的，该方法总是返回 0 ，也就是说，该连接还没有被使用过if 0 == count thenok, err = red:auth("password")if not ok thenngx.say("failed to auth: ", err)returnendelseif err thenngx.say("failed to get reused times: ", err)returnendok, err = red:set("doge", "doge coin")if not ok thenngx.say("failed to set dog: ", err)returnendngx.say("set result: ", ok)-- 连接池大小是100个，并且设置最大的空闲时间是 10 秒local ok, err = red:set_keepalive(10000, 100)if not ok thenngx.say("failed to set keepalive: ", err)returnend}}
}
2. pipeline 压缩请求数量
server {location /withpipeline {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 thenngx.say("failed to connect: ", err)returnendred:init_pipeline()red:set("cat", "CaiCai")red:set("dog", "doge coin")red:get("cat")red:get("dog")local results, err = red:commit_pipeline()if not results thenngx.say("failed to commit the pipelined requests: ", err)returnendfor i, res in ipairs(results) doif type(res) == "table" thenif not res[1] thenngx.say("failed to run command ", i, ": ", res[2])else-- process the table valueendelse-- process the scalar valueendend-- put it into the connection pool of size 100,-- with 10 seconds max idle timelocal ok, err = red:set_keepalive(10000, 100)if not ok thenngx.say("failed to set keepalive: ", err)returnend}}
}
OpenResty最佳实践作者:曾经某个后台应用，逐个处理大约 100 万条记录需要几十分钟，经过 pileline 压缩请求数量后，最后时间缩小到 20 秒左右
)
