分布式--OpenResty+lua+Redis
分布式--OpenResty+lua+Redis
前面我们已经使用了nginx，它拥有丰富的模块供我们使用，由于nginx是由c语言编写而成的，所以以前编写模块就必须使用c/c++，后来，有人将lua解释器继承到了nginx中，内建了ngx_lua模块，至此，nginx支持了lua
一、OpenResty
OpenResty是基于nginx开源版本的一个扩展版本，集成了大量的lua库
1. 添加repo
cd /etc/yum.repos.d/
wget https://openresty.org/package/centos/openresty.repo2. 安装openresty
yum install openresty3. 启动openresty
openresty默认安装路径为/usr/local/openresty/，其中有个nginx目录，关于openresty的启动和配置都和以前nginx相同
cd /usr/local/openresty/nginx/conf修改openresty的http模块配置，新增server模块，使用content_by_lua执行一段lua代码：
server{
listen 8080;
location /{
default_type text/html;
content_by_lua 'ngx.say("hello openresty")';
}
}启动openresty：
cd /usr/local/openresty/nginx/sbin/
./nginx -p /usr/local/openresty/nginx/浏览器访问8080端口：
二、http访问Redis
上面完成了nginx执行lua语句，接下来来看nginx如何访问Redis
Redis环境搭建可以看之前的文章：分布式--Redis的安装与数据类型的使用
1. 获取Redis数据
下面是通过nginx获取Redis中key对应的value
1.1 启动Redis
启动一个默认6379端口的Redis即可，下面还有我之前搭建的Redis集群：
1.2 修改nginx配置
worker_processes 1;
events {
worker_connections 1024;
}
http {
include mime.types;
default_type application/octet-stream;
sendfile on;
keepalive_timeout 65;
server {
listen 80;
server_name localhost;
location / {
default_type text/plain;
# 设置获取redis中key为m的值
set $redis_key "m";
redis_pass 127.0.0.1:6379;
# 如果发生404，就交由@fetch处理
error_page 404 = @fetch;
}
location @fetch {
root html;
}
}
}nginx重新加载配置：
./nginx -p /usr/local/openresty/nginx/ -c /usr/local/openresty/nginx/conf/nginx-http.conf -s reload1.3 通过http访问
curl http://localhost/1.html结果：
redis客户端设置m的键值对：
再次访问：
2. 设置Redis数据
上面方式1，只是获取了Redis的数据，那么如何设置Redis键值对呢？如果nginx支持redis的指令就好了，实际上nginx是支持的
2.1 修改nginx配置
可以使用redis2_query后面跟上redis的指令，来设置值，同样也能使用redis指令获取值：
worker_processes 1;
events {
worker_connections 1024;
}
http {
include mime.types;
default_type application/octet-stream;
sendfile on;
keepalive_timeout 65;
server {
listen 80;
server_name localhost;
location /get {
# 设置个变量
set_unescape_uri $key "n";
redis2_query get $key;
redis_pass 127.0.0.1:6379;
# 如果发生404，就交由@fetch处理
error_page 404 = @fetch;
}
location /set {
# 设置个变量
set_unescape_uri $key "n";
redis2_query set $key "hello2";
redis2_pass 127.0.0.1:6379;
}
location @fetch {
root html;
}
}
}nginx重启：
./nginx -s stop
./nginx -p /usr/local/openresty/nginx/ -c /usr/local/openresty/nginx/conf/nginx-http2.conf2.2 访问测试
curl http://localhost/get
curl http://localhost/set结果：
三、lua结合Nginx、Redis
官方介绍：https://github.com/openresty/lua-resty-redis
首先，OpenResty集成lua后，有三种调用lua的方式：
方式语法 | 描述 |
|---|---|
content_by_lua | 最开始我们已经使用过了，它支持执行一条lua代码 |
content_by_lua_file | 该语句支持执行一个lua脚本文件，也是用的最多的 |
content_by_lua_block | 该语句支持执行一个lua代码块，针对一些简单场景使用 |
下面来使用lua与Redis进行交互
1. lua操作Redis数据
lua操作Redis，步骤是引入Redis模块，连接Redis，然后再操作
1.1 编写lua脚本
创建个目录存放lua脚本：
mkdir lua
vi control_redis.lua内容为：
-- 引入redis模块
local redis = require("resty.redis")
-- 创建个redis对象
local red = redis:new()
-- 1. 连接redis
-- 多参数返回
local ok,err = red:connect("127.0.0.1",6379)
if not ok then
ngx.say("connect failed:",err)
return
end
-- 2. 设置redis的键值对
ok,err = red:set("luaKey","luaValue")
if not ok then
ngx.say("set faild:",err)
return
end
-- 3. 读取redis的键值对
ret = red:get("luaKey")
ngx.say("read luaKey value:",ret)
return1.2 修改nginx配置
使用content_by_lua_file指定lua脚本的绝对路径：
worker_processes 1;
events {
worker_connections 1024;
}
http {
include mime.types;
default_type application/octet-stream;
sendfile on;
keepalive_timeout 65;
server {
listen 8090;
server_name localhost;
location / {
default_type text/html;
content_by_lua_file /usr/local/openresty/nginx/lua/control_redis.lua;
}
}
}重启nginx：
./nginx -s stop
./nginx -p /usr/local/openresty/nginx/ -c /usr/local/openresty/nginx/conf/nginx-lua.conf1.3 测试
2. lua获取nginx中http的get请求参数
2.1 编写lua脚本
vi http_get.lua使用ngx.req.get_uri_args()获取，内容为：
-- 返回的是一个table类型
local args = ngx.req.get_uri_args()
for k,v in pairs(args) do
ngx.say("key:"..k.."value:"..v)
end2.2 修改nginx配置
新增端口监听：
server {
listen 8091;
server_name localhost;
location /get {
default_type text/html;
content_by_lua_file /usr/local/openresty/nginx/lua/http_get.lua;
}
}重新加载配置文件：
./nginx -p /usr/local/openresty/nginx/ -c /usr/local/openresty/nginx/conf/nginx-lua.conf -s reload2.3 测试
http://192.168.42.4:8091/get?name=张三&age=19
3. lua获取nginx中http的post请求参数
post请求有两种：body键值对和body请求体。后者对应现在流行的json格式
3.1 编写lua脚本
post请求参数的获取都需要先调用ngx.req.read_body()方法
键值对：
vi http_post_kv.lua使用ngx.req.get_post_args()获取，内容为：
-- 先读取下
ngx.req.read_body()
-- 再获取
local params = ngx.req.get_post_args()
for k,v in pairs(params) do
ngx.say("key:"..k.." value:"..v)
end请求体：
vi http_post_body.lua使用ngx.req.get_body_data()获取，内容为：
-- 先读取下
ngx.req.read_body()
-- 再获取请求体
local body = ngx.req.get_body_data();
ngx.say(body)3.2 修改nginx配置
server {
listen 8092;
server_name localhost;
location /post_kv {
default_type text/html;
content_by_lua_file /usr/local/openresty/nginx/lua/http_post_kv.lua;
}
location /post_body {
default_type text/html;
content_by_lua_file /usr/local/openresty/nginx/lua/http_post_body.lua;
}
}重新加载nginx配置：
./nginx -p /usr/local/openresty/nginx/ -c /usr/local/openresty/nginx/conf/nginx-lua.conf -s reload3.3 测试
键值对：
请求体：
4. lua获取nginx中http的请求头
4.1 编写lua脚本
vi http_headers.lua请求头通过ngx.req.get_headers()获取，内容为：
local headers = ngx.req.get_headers()
for k,v in pairs(headers) do
ngx.say("key:"..k.." value:"..v)
end4.2 修改nginx配置
server {
listen 8093;
server_name localhost;
location /headers {
default_type text/html;
content_by_lua_file /usr/local/openresty/nginx/lua/http_headers.lua;
}
}重新加载配置文件：
./nginx -p /usr/local/openresty/nginx/ -c /usr/local/openresty/nginx/conf/nginx-lua.conf -s reload4.3 测试
以上就是openresty+lua+redis的基本使用