tar-zxfopenresty-1.15.8.2.tar.gz

3、进入OpenResty目录执行配置

这一步有点类似于nginx的源码安装，进行相关的环境变量的配置，这里直接使用默认的就好；

5、进入OpenResty的目录配置nginx

进入nginx目录，可以看到里面的目录和nginx自身安装完毕后的配置几乎一样

进入conf，找到nginx.conf配置文件，添加如下内容：

content_by_lua'ngx.say("<h2>hello,openRestrylua</h2>")';

}

6、启动nginx并测试

进入nginx的sbin目录下启动nginx

启动完成后，浏览器访问下服务器即可，可以看到nginx本身服务已启动

访问已经配置的Lua地址后，可以发现可以正常访问，这表明OpenResty模块已经成功安装

使用Lua编写Nginx脚本的基本构建块是指令，指令用于指定何时运行用户Lua代码以及如何使用结果，下面针对一些常用的指令做简单的说明

1、init_by_lua*

该指令在每次Nginx重新加载配置时执行，用来完成一些耗时操作模块加载，或初始化一些全局配置

2、init_worker_by_lua*

该指令用于启动一些定时任务，如心跳检查、定时拉取服务器配置等

3、set_by_lua*

该指令只要用来给变量赋值，这个指令一次只能返回一个值，并将结果值给Nginx中指定变量

4、rewrite_by_lua*

用于执行内部URL重写或者外部重定向，典型的如伪静态化URL重写，本阶段在rewrite处理阶段的最后默认执行（和nginx自身的rewrite功能有类似的地方）

5、access_by_lua*

该指令用于访问控制，例如，只允许内网IP访问

6、content_by_lua*

该指令是使用最多的指令，大部分任务是在这个阶段完成的，其他过程往往为这个阶段准备数据，正式处理往往都在本阶段执行

7、header_filter_by_lua*

用于设置应答消息的头部信息

8、body_filter_by_lua*

该指令对响应数据进行过滤，如截断、替换

9、log_by_lua*

该指令用于log请求处理阶段，用Lua代码处理日志，但并不替换原有log处理

10、balancer_by_lua*

该指令主要作用是用来实现上游服务器的负载均衡器算法

11、ssl_certificate_by_*

该指令作用在Nginx和下游服务开始一个SSL握手操作时将允许本配置项的Lua代码

接下来针对上面提到的各种指令，来做一个简单的需求

nginx接收到请求后，根据参数中gender传入的值，如果gender传入的是1则在页面上展示“先生”，如果gender传入的是0，则在页面上展示“女士”

注意：使用指令编写的基本步骤是，在nginx.conf模块中，自定义localtion块中编写lua的相关代码即可

localuri_args=ngx.req.get_uri_args()

localgender=uri_args['gender']

localname=uri_args['name']

}

然后启动nginx做一下测试

1）访问服务，不携带任何参数

2）访问服务，携带name参数

3）访问服务，携带name和gender参数

更多的指令可以参照此类方式编写，但是前提需要掌握一点lua的基本语法

Redis在系统中经常作为数据缓存、内存数据库使用，在各类互联网项目中扮演着非常重要的作用；

Lua-resty-redis库是OpenResty提供的一个操作Redis的接口库，可根据自己的业务情况做一些逻辑处理，适合做复杂的业务逻辑。所以下面将以Lua-resty-redis来进行说明。

1、提前安装好redis并启动服务

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

1、lua中导入redis依赖

redis=require"resty.redis"

2、new，创建一个Redis对象

redis,err=redis:new()

3、创建redis连接

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

ok,err=redis:connect(host,port[,options_table])

4、设置请求操作Redis的超时时间

redis:set_timeout(time)

5、close，关闭连接

关闭当前连接，成功返回1；

补充说明：

在lua-resty-redis中，所有的Redis命令都有自己的方法；方法名字和命令名字相同，只是全部为小写；

具体实现效果展示

在nginx.conf模块下，添加如下的location内容

localredis=require"resty.redis"--引入Redis

localredisObj=redis:new()--创建Redis对象

redisObj:set_timeout(3000)--设置超时数据为3s

localok,err=redisObj:connect("IP",6379)--设置redis连接信息

ifnotokthen--判断是否连接成功

ngx.say("failedtoconnectionredis",err)

ok,err=redisObj:set("username","TOM")--存入数据

ifnotokthen--判断是否存入成功

ngx.say("failedtosetusername",err)

localres,err=redisObj:get("username")--从redis中获取数据

}

安装，这个库现不在OpenResty中

lua-resty-mysql

lua-resty-mysql是OpenResty开发的模块，使用灵活、功能强大，适合复杂的业务场景，同时支持存储过程访问；

lua-resty-mysql实现数据库查询

`id`int(10)NOTNULLAUTO_INCREMENT,

`username`varchar(255)DEFAULTNULL,

`birthday`dateDEFAULTNULL,

`salary`double(10,2)DEFAULTNULL,

)ENGINE=InnoDBDEFAULTCHARSET=utf8;

并提前准备几条数据

INSERTINTO`mydb`.`users`(`id`,`username`,`birthday`,`salary`)VALUES('1','xiaowang','1991-03-15','9000.00');

INSERTINTO`mydb`.`users`(`id`,`username`,`birthday`,`salary`)VALUES('2','xiaoma','1992-07-15','8000.00');

lua-resty-mysqlAPI说明

1、引入"resty.mysql"模块

localmysql=require"resty.mysql"

2、创建MySQL连接对象

遇到错误时，db为nil，err为错误描述信息

db,err=mysql:new()

3、创建连接对象

ok,err=db:connect(options)

options是一个参数的Lua表结构，里面包含数据库连接的相关信息

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

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

4、设置子请求的超时时间(ms)

db:set_timeout(time)

5、关闭当前MySQL连接并返回状态

如果成功，则返回1；如果出现任何错误，则将返回nil和错误描述

db:close()

6、异步向远程MySQL发送一个查询

如果成功则返回成功发送的字节数；如果错误，则返回nil和错误描述

bytes,err=db:send_query(sql)

7、从MySQL服务器返回结果中读取一行数据

res返回一个描述OK包或结果集包的Lua表

rows指定返回结果集的最大值，默认为4

如果是查询，则返回一个容纳多行的数组。每行是一个数据列的key-value对

res,err,errcode,sqlstate=db:read_result()res,err,errcode,sqlstate=db:read_result(rows)

返回结果类似下面这样

{id=1,username="TOM",birthday="1988-11-11",salary=10000.0},{id=2,username="JERRY",birthday="1989-11-11",salary=20000.0}

}

如果是增删改，则返回类似如下数据

}

返回值说明：

errcode:MySQL的错误码，比如1064

sqlstate:返回由5个字符组成的标准SQL错误码，比如42000

具体操作案例

将下面的内容添加到server块，然后重启nginx

default_type"text/html";

localmysql=require"resty.mysql"

db:send_query("select*fromuserswhereid=1")

localres,err,errcode,sqlstate=db:read_result()

ngx.say(res[1].id..","..res[1].username..","..res[1].birthday..","..res[1].salary)

}

可以看到，通过访问mysql这个路径，成功查询到数据库中ID为1的这条数据

使用cjson对查询结果进行格式化

从上面的返回结果来看，这种形式的返回数据在解析的时候其实并不是很友好，于是可以使用lua-cjson处理查询结果

使用步骤

localcjson=require“cjson”

步骤二：调用cjson的encode方法进行类型转换

下面对上面程序模块做简单的改造

default_type"text/html";

localcjson=require"cjson"

localmysql=require"resty.mysql"

db:send_query("select*fromusers")

localres,err,errcode,sqlstate=db:read_result()

ngx.say(cjson.encode(res))

ngx.say(v.id..","..v.username..","..v.birthday..","..v.salary)

}

然后再次进行测试，这时候就以json的格式对数据进行了展现

增删改操作

default_type"text/html";

localcjson=require"cjson"

localmysql=require"resty.mysql"

db:send_query("select*fromuserswhereid=1")

--localres,err,errcode,sqlstate=db:query("insertintousers(id,username,birthday,salary)values(3,'lifei','1995-10-17',3000)")

--localres,err,errcode,sqlstate=db:query("updateuserssetusername='lisi'whereid=1")

--localres,err,errcode,sqlstate=db:query("deletefromuserswhereid=2")

}

以上就是nginx怎么集成lua操作mysql的详细内容，更多请关注主机测评网其它相关文章！

本文来源：国外服务器--nginx怎么集成lua操作mysql（nginx执行lua脚本）

本文地址：https://www.idcbaba.com/guowai/4523.html

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 1919100645@qq.com 举报，一经查实，本站将立刻删除。

标签：