您好，我是湘王，这是我的51CTO博客。值此新春佳节，我给您拜年啦～祝您在新的一年中所求皆所愿，所行皆坦途，展宏“兔”，有钱“兔”，多喜乐，常安宁！
如前所述，OpenResty是一个基于Nginx与Lua的高性能Web平台，内部集成了大量的Lua库、第三方模块以及大多数依赖。模块化既是OpenResty的特色，也是高性能Lua应用的关键。
在实际开发中，OpenResty已经为开发者提供了很多成熟且开箱即用的「模块」：cjson、redis客户端、mysql客户端等。
lua-resty-redis是为Lua提供的redis客户端，通过它可以完成Redis的操作，默认安装OpenResty时已经自带了该模块，可以在github中搜索「lua-resty-redis」找到它。
现在就通过LUA来操作Redis。
先在虚拟机上安装Redis，然后修改Redis的配置文件：
注释掉bind 127.0.0.1：
# bind 127.0.0.1
将protected-mode设为no：
protected-mode no
注释掉requirepass：
# requirepass 123456
启动redis服务：
systemctl start redis.service
创建redis.lua：
vi /usr/local/openresty/nginx/conf/lua/redis.lua
下面是redis.lua的内容：
-- 引入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
return
end
-- 通过密码访问
-- local res, err = red:auth("123456")
-- if not res then
-- ngx.say("connect to redis error: ", err)
-- return
-- end
-- 保存数据
local res, err = red:set("hello", "hello world")
if not res then
ngx.say("set hello key error: ", err)
local ok, err = red:close()
if not ok then
ngx.say("close redis error: ", err)
end
end
-- 获得数据
local resp, err = red:get("hello")
if not resp then
ngx.say("get hello key error: ", err)
local ok, err = red:close()
if not ok then
ngx.say("close redis error: ", err)
end
end
-- 判空处理
if resp == ngx.null then
resp = ''
end
ngx.say("hello: ", resp)
修改lua.conf：
vi /usr/local/openresty/nginx/conf/lua.conf
其中的内容是：
server {
listen 80;
server_name _;
location /redis {
default_type 'text/html';
lua_code_cache on;
content_by_lua_file conf/lua/redis.lua;
}
}
运行测试：
重启Nginx服务：
/usr/local/openresty/nginx/sbin/nginx -s reload
执行curl命令：
curl 'http://127.0.0.1/redis'
得到结果：
hello: hello world
再次修改修改redis.lua：
-- 初始化管道
red:init_pipeline()
red:set("test1", "hello")
red:set("test2", "world")
red:get("test1")
red:get("test2")
local respTable, err = red:commit_pipeline()
-- 判空处理
if respTable == ngx.null then
respTable = {}
end
-- 结果是按照执行顺序返回的一个table
for i, v in ipairs(respTable) do
ngx.say("result: ", v)
end
运行测试：
重启Nginx服务：
/usr/local/openresty/nginx/sbin/nginx -s reload
执行curl命令：
curl 'http://127.0.0.1/redis'
得到结果：
hello: hello world
result : OK
result : OK
result : hello
result : world
如同Redis那样，OpenResty也封装好了操作mysql的模块。lua-resty-mysql是为Lua提供的mysql客户端，通过它可以完成mysql的操作，默认安装OpenResty时已经自带了该模块，可以在github中搜索「lua-resty-mysql」找到它。
首先创建创建mysql.lua：
vi /usr/local/openresty/nginx/conf/lua/mysql.lua
mysql.lua的内容是：
-- 引入mysql模块
local mysql = require("resty.mysql")
-- 创建实例
local db, err = mysql:new()
if not db then
ngx.say("new mysql error:", err)
return
end
-- 超时时间
db:set_timeout(5000)
-- 建立连接
local props = {
host = "127.0.0.1",
port = 3306,
database = "sys",
user = "root",
password = "123456"
}
local res, err, errno, state = db:connect(props)
if not res then
ngx.say("connect to mysql error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
-- 删除表
local drop_table_sql = "drop table if exists test"
res, err, errno, state = db:query(drop_table_sql)
if not res then
ngx.say("drop table error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
-- 创建表
local create_table_sql = "create table test(id int primary key auto_increment, name varchar(100))"
res, err, errno, state = db:query(create_table_sql)
if not res then
ngx.say("create table error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
-- 插入
local insert_sql = "insert into test (name) values('xiangwang')"
res, err, errno, state = db:query(insert_sql)
if not res then
ngx.say("insert error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
ngx.say("insert rows : ", res.affected_rows, ", id: ", res.insert_id)
-- 更新
local update_sql = "update test set name = 'xiangwang2' where id = " .. res.insert_id
res, err, errno, sqlstate = db:query(update_sql)
if not res then
ngx.say("update error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
ngx.say("update rows : ", res.affected_rows)
-- 查询
local select_sql = "select id, ch from test"
res, err, errno, sqlstate = db:query(select_sql)
if not res then
ngx.say("select error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
for i, row in ipairs(res) do
for name, value in pairs(row) do
ngx.say("select row ", i, " : ", name, " = ", value)
end
end
-- 防注入
-- local param = ngx.req.get_uri_args()["name"] or ''
-- local query_sql = "select id, name from test where name = " .. ngx.quote_sql_str(param)
-- res, err, errno, state = db:query(query_sql)
-- if not res then
-- ngx.say("select error: ", err, ", errno: ", errno, ", state: ", state)
-- return db:close()
-- end
-- for i, row in ipairs(res) do
-- for name, value in pairs(row) do
-- ngx.say("select row ", i, " : ", name, " = ", value)
-- end
-- end
-- 删除
local delete_sql = "delete from test"
res, err, errno, state = db:query(delete_sql)
if not res then
ngx.say("delete error: ", err, ", errno: ", errno, ", state: ", state)
return db:close()
end
ngx.say("delete rows: ", res.affected_rows)
修改lua.conf：
vi /usr/local/openresty/nginx/conf/lua.conf
lua.conf的内容是：
server {
listen 80;
server_name _;
location /mysql {
default_type 'text/html';
lua_code_cache on;
content_by_lua_file conf/lua/mysql.lua;
}
}
重启Nginx服务：
/usr/local/openresty/nginx/sbin/nginx -s reload
执行curl命令：
curl 'http://127.0.0.1/mysql
得到结果：
insert rows: 1, id: 1
update rows : 1
select row 1 : name = xiangwang2
select row 1 : id = 1
delete rows: 1
节日期间，您仍然可以随时咨询技术、产品、运营和管理相关问题，请关注后留言。欢迎骚扰，不胜荣幸～再次祝您兔年吉祥，万事胜意！