欢迎来到尧图网

客户服务 关于我们

您的位置：首页 > 文旅 > 旅游 > Nginx16-Lua扩展案例

Nginx16-Lua扩展案例

2024/10/26 20:17:19 来源：https://blog.csdn.net/liyou123456789/article/details/143168427  浏览:  次   关键词：Nginx16-Lua扩展案例

零、文章目录

Nginx16-Lua扩展案例

1、ngx_lua案例

（1）需求
  • 请求地址：http://192.168.119.161/getByGender?name=张三&gender=1
  • Nginx接收到请求后，根据gender传入的值
    • 如果gender传入的是1，则在页面上展示张三先生
    • 如果gender传入的是0，则在页面上展示张三女士
    • 如果未传或者传入的不是1和2，则在页面上展示张三。
（2）配置代码实现
  • 在配置文件中/usr/local/openresty/nginx/conf/nginx.conf添加如下配置
location /getByGender {default_type 'text/html';set_by_lua $name "local uri_args = ngx.req.get_uri_args()gender = uri_args['gender']name = uri_args['name']if gender=='1' thenreturn name..'先生'elseif gender=='0' thenreturn name..'女士'elsereturn nameend";header_filter_by_lua "ngx.header.aaa='bbb'";return 200 $name;
}
（3）测试验证
  • 重启Nginx
/usr/local/openresty/nginx/sbin/nginx -s reload
  • 访问地址：http://192.168.119.161/getByGender?name=张三&gender=1

image-20241018185210246

2、ngx_lua操作Redis

（1）概述

  • Redis在系统中经常作为数据缓存、内存数据库使用，在大型系统中扮演着非常重要的作用。在Nginx核心系统中，Redis是常备组件。

  • Nginx支持3种方法访问Redis,分别是HttpRedis模块、HttpRedis2Module、lua-resty-redis库。

    • HttpRedis模块提供的指令少，功能单一，适合做简单缓存，
    • HttpRedis2Module模块比HttpRedis模块操作更灵活，功能更强大。
    • Lua-resty-redis库是OpenResty提供的一个操作Redis的接口库，可根据自己的业务情况做一些逻辑处理，适合做复杂的业务逻辑。所以本次课程将主要以Lua-resty-redis来进行讲解。

  • lua-resty-redis提供了访问Redis的详细API，包括创建对接、连接、操作、数据处理等。这些API基本上与Redis的操作一一对应。

（2）准备Redis环境

  • 环境配置：Centos7.9 192.168.119.163: 6379 Docker安装Redis

  • Docker相关知识请参考Docker详解

  • Docker命令如下

    • docker run -d：docker run 是 Docker 的命令，用于创建一个新的容器。-d 参数告诉 Docker 在后台运行容器。
    • --name redis-container：--name 参数用于为容器指定一个名称，这里我们将其命名为 redis-container。
    • -v /path/to/your/data:/data：-v 参数用于挂载卷，将宿主机的目录挂载到容器内部。/path/to/your/data 是宿主机上的目录，用于持久化 Redis 数据。:/data 表示将宿主机的目录挂载到容器的 /data 目录。
    • -v /path/to/your/redis.conf:/usr/local/etc/redis/redis.conf：/path/to/your/redis.conf 是宿主机上的 Redis 配置文件路径。:/usr/local/etc/redis/redis.conf 表示将宿主机的配置文件挂载到容器的 /usr/local/etc/redis/redis.conf。
    • -p 6379:6379：-p 参数用于端口映射。6379:6379 表示将容器的 6379 端口映射到宿主机的 6379 端口，这样你就可以通过宿主机的端口访问 Redis 服务了。
    • redis：指定要使用的 Docker 镜像名称，这里是 redis。
    • redis-server /usr/local/etc/redis/redis.conf：在容器内运行 redis-server 命令，并指定使用挂载的配置文件。
docker run -d \--name redis-container \-v /path/to/your/data:/data \-v /path/to/your/redis.conf:/usr/local/etc/redis/redis.conf \-p 6379:6379 \redis redis-server /usr/local/etc/redis/redis.conf
  • Redis运行成功进行测试，使用客户端进行连接，客户端百度网盘地址：https://pan.baidu.com/s/1tBdTkKWl241agJgfCUEYGA?pwd=1234

image-20241019152739799

（3）配置代码实现
  • 在配置文件中/usr/local/openresty/nginx/conf/nginx.conf添加如下配置
location /redis {default_type "text/html";content_by_lua_block{local redis = require "resty.redis" -- 引入Redislocal redisObj = redis:new()  --创建Redis对象redisObj:set_timeout(1000) --设置超时数据为1slocal ok,err = redisObj:connect("192.168.119.163",6379) --设置redis连接信息if not ok then --判断是否连接成功ngx.say("failed to connection redis",err)returnendok,err = redisObj:set("username","TOM")--存入数据if not ok then --判断是否存入成功ngx.say("failed to set username",err)returnendlocal res,err = redisObj:get("username") --从redis中获取数据ngx.say(res)	--将数据写会消息体中redisObj:close()}
}
（4）配置代码说明

  • （1）redis = require “resty.redis”

  • （2）new

    • 语法: redis,err = redis:new()，创建一个Redis对象。

  • （3）connect

    • 语法:ok,err=redis:connect(host,port[,options_table]),设置连接Redis的连接信息。

    • ok:连接成功返回 1，连接失败返回nil

    • err:返回对应的错误信息

  • （4）set_timeout

    • 语法: redis:set_timeout(time) ，设置请求操作Redis的超时时间。

  • （5）close

    • 语法: ok,err = redis:close(),关闭当前连接，成功返回1，失败返回nil和错误信息。

  • （6）redis命令对应的方法

    • 在lua-resty-redis中，所有的Redis命令都有自己的方法，方法名字和命令名字相同，只是全部为小写。
（5）测试验证
  • 重启Nginx
/usr/local/openresty/nginx/sbin/nginx -s reload
  • 访问地址：http://192.168.119.161/redis

image-20241019155838837

image-20241019155854120

3、ngx_lua操作Mysql

（1）概述

  • MySQL是一个使用广泛的关系型数据库。MYSQL相关知识请参考MYSQL详解。

  • 在ngx_lua中，MySQL有两种访问模式

    • 用ngx_lua模块和lua-resty-mysql模块：这两个模块是安装OpenResty时默认安装的。

    • 使用drizzle_nginx_module(HttpDrizzleModule)模块：需要单独安装，这个库现不在OpenResty中。

  • lua-resty-mysql是OpenResty开发的模块，使用灵活、功能强大，适合复杂的业务场景，同时支持存储过程的访问。我们以lua-resty-mysql为例进行讲解。

（2）准备MySQL环境
  • 环境配置：Centos7.9 192.168.119.163: 3306 Docker安装MySQL。账号：root 密码：123456
  • Docker相关知识请参考Docker详解
  • Docker命令如下
    • docker run：Docker 的命令，用于创建并启动一个新的容器。
    • -d：后台运行容器。使用 -d 参数可以让容器在后台运行，而不是在当前终端占用前台。
    • --name mysql：为新创建的容器指定一个名称，这里名称为 mysql。如果不指定，Docker 会默认生成一个名称。
    • -p 3306:3306：端口映射参数，格式为 <宿主机端口>:<容器端口>。这里将容器的 3306 端口映射到宿主机的 3306 端口，使得宿主机可以通过 3306 端口访问 MySQL 服务。
    • -e MYSQL_ROOT_PASSWORD=123456：设置环境变量。这里设置的环境变量是 MYSQL_ROOT_PASSWORD，其值为 123456，即 MySQL 的 root 用户的密码。这是 Docker 容器启动时需要的配置信息之一。
    • -v /path/to/mysql/data:/var/lib/mysql：挂载数据卷参数，格式为 <宿主机目录>:<容器目录>。这里将宿主机的 /path/to/mysql/data 目录挂载到容器的 /var/lib/mysql 目录。这样，MySQL 的数据文件就会被持久化存储在宿主机的指定目录中，而不是容器内部，从而实现数据的持久化。
    • mysql:latest：指定要使用的 Docker 镜像。这里使用的是 mysql 镜像的最新版本（latest 标签）。
docker run -d \--name mysql-container \-e MYSQL_ROOT_PASSWORD=123456 \-v /path/to/mysql/data:/var/lib/mysql \-p 3306:3306 \mysql:latest
  • Mysql运行成功进行测试，使用Navicat进行连接，Navicat百度网盘下载连接（科学安装方法请自行百度）：https://pan.baidu.com/s/1xg5dJcaqv6cTw_opWJG9AQ?pwd=8888

image-20241021113005390

  • 创建数据库，创建表，插入数据
create database nginx_db;use nginx_db;create table users(id int primary key auto_increment,username varchar(30),birthday date,salary double
);insert into users(id,username,birthday,salary) values(null,"TOM","1988-11-11",10000.0);
insert into users(id,username,birthday,salary) values(null,"JERRY","1989-11-11",20000.0);
insert into users(id,username,birthday,salary) values(null,"ROWS","1990-11-11",30000.0);
insert into users(id,username,birthday,salary) values(null,"LUCY","1991-11-11",40000.0);
insert into users(id,username,birthday,salary) values(null,"JACK","1992-11-11",50000.0);
（3）配置代码实现
  • 在配置文件中/usr/local/openresty/nginx/conf/nginx.conf添加如下配置
location /mysql {content_by_lua_block{local mysql = require "resty.mysql"local db = mysql:new()local ok,err = db:connect{host="192.168.119.163",port=3306,user="root",password="123456",database="nginx_db"}db:set_timeout(1000)db:send_query("select * from users where id =1")local res,err,errcode,sqlstate = db:read_result()ngx.say(res[1].id..","..res[1].username..","..res[1].birthday..","..res[1].salary)db:close()}
}
（4）配置代码说明

  • （1）引入"resty.mysql"模块：local mysql = require “resty.mysql”

  • （2）new：

    • 创建一个MySQL连接对象，遇到错误时，db为nil，err为错误描述信息

    • 语法: db,err = mysql:new()

  • （3）connect

    • 尝试连接到一个MySQL服务器

    • 语法:ok,err=db:connect(options)，options是一个参数的Lua表结构，里面包含数据库连接的相关信息。

    • host:服务器主机名或IP地址

    • port:服务器监听端口，默认为3306

    • user:登录的用户名

    • password:登录密码

    • database:使用的数据库名

  • （4）set_timeout

    • 设置子请求的超时时间(ms)，包括connect方法
    • 语法:db:set_timeout(time)

  • （5）close

    • 关闭当前MySQL连接并返回状态。如果成功，则返回1；如果出现任何错误，则将返回nil和错误描述。
    • 语法:db:close()

  • （6）send_query

    • 异步向远程MySQL发送一个查询。如果成功则返回成功发送的字节数；如果错误，则返回nil和错误描述
    • 语法:bytes,err=db:send_query(sql)

  • （7）read_result

    • 从MySQL服务器返回结果中读取一行数据。res返回一个描述OK包或结果集包的Lua表
    • 语法:
      • res, err, errcode, sqlstate = db:read_result()
        • res：操作的结果集
        • err：错误信息
        • errcode：MySQL的错误码，比如1064
        • sqlstate：返回由5个字符组成的标准SQL错误码，比如42000
      • res, err, errcode, sqlstate = db:read_result(rows)
        • rows：指定返回结果集的最大值，默认为4
/// 如果是查询，则返回一个容纳多行的数组。每行是一个数据列的key-value对，如下
{{id=1,username="TOM",birthday="1988-11-11",salary=10000.0},{id=2,username="JERRY",birthday="1989-11-11",salary=20000.0}
}///如果是增删改，则返回类上如下数据
{insert_id = 0,server_status=2,warning_count=1,affected_rows=2,message=nil
}
（5）处理查询结果
  • 通过上述的案例学习，read_result()得到的结果res都是table类型，要想在页面上展示，就必须知道table的具体数据结构才能进行遍历获取。处理起来比较麻烦。
  • 接下来我们介绍一种简单方式cjson，使用它就可以将table类型的数据转换成json字符串，把json字符串展示在页面上即可。
# 步骤一：引入cjson
local cjson = require "cjson"# 步骤二：调用cjson的encode方法进行类型转换
cjson.encode(res)
  • 在配置文件中/usr/local/openresty/nginx/conf/nginx.conf添加如下配置
location /mysql1 {content_by_lua_block{local mysql = require "resty.mysql"local cjson = require "cjson"local db = mysql:new()local ok,err = db:connect{host="192.168.119.163",port=3306,user="root",password="123456",database="nginx_db"}db:set_timeout(1000)--db:send_query("select * from users where id = 2")db:send_query("select * from users")local res,err,errcode,sqlstate = db:read_result()ngx.say(cjson.encode(res))for i,v in ipairs(res) dongx.say(v.id..","..v.username..","..v.birthday..","..v.salary)enddb:close()}
}
（4）实现数据增删改
  • 本方法是send_query和read_result组合的快捷方法。
res, err, errcode, sqlstate = db:query(sql[,rows])
  • 在配置文件中/usr/local/openresty/nginx/conf/nginx.conf添加如下配置
location /mysql2 {content_by_lua_block{local mysql = require "resty.mysql"local db = mysql:new()local ok,err = db:connect{host="192.168.119.163",port=3306,user="root",password="123456",database="nginx_db",max_packet_size=1024,compact_arrays=false}db:set_timeout(1000)local res,err,errcode,sqlstate = db:query("select * from users")--local res,err,errcode,sqlstate = db:query("insert into users(id,username,birthday,salary) values(null,'zhangsan','2020-11-11',32222.0)")--local res,err,errcode,sqlstate = db:query("update users set username='lisi' where id = 6")--local res,err,errcode,sqlstate = db:query("delete from users where id = 6")db:close()}
}

4、综合案例-Redis缓存预热

（1）需求
  • 使用ngx_lua模块完成Redis缓存预热
    • 浏览器输入如下地址：http://191.168.119.163/mysqltoredis?username=TOM
    • 从表中查询出符合条件的记录，此时获取的结果为table类型
    • 使用cjson将table数据转换成json字符串
    • 将查询的结果数据存入Redis中
（2）功能实现
  • 在配置文件中/usr/local/openresty/nginx/conf/nginx.conf添加如下配置
init_by_lua_block{redis = require "resty.redis"mysql = require "resty.mysql"cjson = require "cjson"
}
location /mysqltoredis {default_type "text/html";content_by_lua_block{--获取请求的参数usernamelocal param = ngx.req.get_uri_args()["username"]--建立mysql数据库的连接local db = mysql:new()local ok,err = db:connect{host="192.168.119.163",port=3306,user="root",password="123456",database="nginx_db"}if not ok thenngx.say("failed connect to mysql:",err)returnend--设置连接超时时间db:set_timeout(1000)--查询数据local sql = "";if not param thensql="select * from users"elsesql="select * from users where username=".."'"..param.."'"endlocal res,err,errcode,sqlstate=db:query(sql)if not res thenngx.say("failed to query from mysql:",err)returnend--连接redislocal rd = redis:new()ok,err = rd:connect("192.168.119.163",6379)if not ok thenngx.say("failed to connect to redis:",err)returnendrd:set_timeout(1000)--循环遍历数据for i,v in ipairs(res) dord:set("user_"..v.username,cjson.encode(v))endngx.say("success")rd:close()db:close()}			}

版权声明:

本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。

我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com

相关资讯

热文排行

最新新闻

推荐新闻

热搜词

分支限界法（Branch and Bound）详细解读 什么是DICOM文件？——认识DICOM：医学影像与信息管理的标准化利器 JavaWeb——Maven（8/8）：依赖管理-生命周期（生命周期的阶段、五个阶段的职责、运行指定生命周期，演示） 苍穹外卖 将菜品缓存到Redis C++源码生成·第三章·命令行参数 Vite：依赖预构建