OpenResty连接Redis和MySQL教程：读取缓存与查询数据库

在使用OpenResty处理请求时，除了读取URL参数和Header，有时还需要从Redis中获取Token、限流计数或路由规则，也可能需要查询MySQL中的配置数据。通过Lua脚本连接Redis和MySQL后，就可以在请求处理阶段完成数据读取和业务判断。

一、连接Redis

首先引入resty.redis模块，创建Redis客户端并设置连接超时时间。

local redis = require "resty.redis"
local red = redis:new()

red:set_timeout(1000)

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

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

ngx.say(res)

上面的代码连接本机6379端口上的Redis，并读取token:demo这个键的值。如果连接失败或读取数据失败，脚本会输出错误信息并结束当前请求。

实际使用时，还可以在读取结果后判断Token是否存在，再根据结果返回不同内容。

二、使用Redis连接池

请求结束后，可以将Redis连接放回连接池，供后续请求继续使用，减少频繁创建连接带来的开销。

local ok, err = red:set_keepalive(10000, 100)
if not ok then
    ngx.log(ngx.ERR, "redis keepalive failed: ", err)
end

其中，10000表示连接空闲超时时间，单位为毫秒；100表示连接池允许保存的最大空闲连接数。

在完成Redis读取操作后再执行连接复用。对于访问量较高的接口，连接池可以减少重复建立TCP连接的开销。

三、连接MySQL

连接MySQL时，需要引入resty.mysql模块，并设置数据库连接参数。

local mysql = require "resty.mysql"

local db, err = mysql:new()
if not db then
    ngx.say("failed to create mysql client: ", err)
    return
end

db:set_timeout(1000)

local ok, err = db:connect {
    host = "127.0.0.1",
    port = 3306,
    database = "test",
    user = "root",
    password = "password"
}

if not ok then
    ngx.say("failed to connect mysql: ", err)
    return
end

local res, err = db:query("select now() as now")
if not res then
    ngx.say("failed to query mysql: ", err)
    return
end

ngx.say(require("cjson").encode(res))

这段代码连接本机MySQL的3306端口，并查询当前数据库时间。查询结果通过cjson编码为JSON格式后返回。

生产环境中不建议直接把数据库账号和密码写在公开脚本中，可以通过受限配置文件或环境变量管理连接信息。同时，SQL语句应尽量使用参数化方式，避免将用户输入直接拼接到查询语句中。