mysql을 운영하기 위해 nginx와 lua를 통합하는 방법

구현 아이디어

• nginx에서 직접 블랙리스트를 구성하고 논리 블록을 작성하여 구현합니다.

• 서버(Java)에서 필터를 작성하고 필터에서 균일하게 차단합니다.

• 서버에서 인터셉터를 작성합니다. (Java) 인터셉터에서 균일하게 가로채기

여기에 3가지 구현 아이디어가 있습니다. 구현 솔루션에 관해서는 더 있을 수 있지만 생각해 보면 nginx에서 논리 블록을 작성하는 것은 그렇게 많은 사람들이 아닌 것처럼 보입니다. 코드 수준에서 수행하는 것이 불가능하지는 않지만 이러한 방식으로 높은 동시성을 수반하는 비즈니스 피크 기간에는 필연적으로 백엔드 서비스에 더 큰 압력이 가해질 것입니다. 해결책?

이것은 Lua에 관한 것입니다. 즉, nginx는 게이트웨이 역할을 하고 여전히 프록시 서버 역할을 합니다. nginx는 Lua를 통합할 수 있으므로 Lua는 위 비즈니스 구현의 설계를 완료하는 데 사용됩니다

ngx_lua 모듈 개념;

• ngx_lua 모듈 Lua 인터프리터를 Nginx에 통합하여 Taobao 기술팀에서 개발했습니다.

• Lua 스크립트는 비즈니스 로직을 구현하는 데 사용할 수 있습니다. Lua는 작고 빠르며 내장된 코루틴을 가지고 있기 때문에 크게 향상됩니다. 높은 동시성 서비스 성능을 보장하면서 비즈니스 로직 구현 비용 절감

• OpenRestry

• OpenResty는 수많은 정교한 Lua 라이브러리를 통합하는 Nginx 및 Lua 기반의 고성능 웹 플랫폼입니다. 타사 모듈 및 대부분의 종속성 사용 초고동시성과 높은 확장성을 처리할 수 있는 동적 웹 애플리케이션, 웹 서비스 및 동적 게이트웨이를 쉽게 구축하는 데 사용됩니다.

• OpenResty는 내부적으로 Nginx와 Lua를 통합했습니다.

Simple 예를 들어 OpenRestry를 직접 설치하여 사용하면 Nginx와 Lua를 동시에 사용하는 효과를 얻을 수 있으며 동시에 OpenRestry를 기반으로 다른 작업도 수행할 수 있습니다. mysql, redis, kafka 등과 같은 미들웨어를 사용하여 비즈니스 아키텍처를 더욱 유연하게 설계합니다.

OpenRestry 설치 단계

1. OpenRestry

wget https://openresty.org/download/openresty-1.15.8.2.tar.gz

2를 다운로드합니다. 구성을 수행하려면 OpenResty 디렉토리에 들어가세요

이 단계는 nginx 소스 코드 설치와 다소 유사합니다. 환경 변수 구성의 경우 여기서 기본 변수를 사용하세요.

tar -zxf openresty-1.15.8.2.tar.gz

4. make && make install

5. nginx를 구성하기 위해 OpenResty 디렉토리에 들어갑니다

nginx 디렉토리에 들어가 보면 설치 후 nginx 자체의 구성과 거의 동일하다는 것을 알 수 있습니다. nginx.conf 구성 파일을 찾아 다음 내용을 추가합니다.

./configure

6. nginx 및 Test를 시작합니다

nginx의 sbin 디렉터리에 들어가서 nginx를 시작합니다

시작이 완료된 후, 브라우저로 서버에 접속하면 nginx 서비스 자체가 시작된 것을 확인할 수 있습니다

설정된 Lua 주소에 접속한 후 정상적으로 접속이 가능한 것으로 확인되는데, 이는 OpenResty 모듈이 접속되었음을 나타냅니다.

ngx_lua 공통 지침

Lua를 사용하여 Nginx 스크립트를 작성하는 기본 구성 요소는 아래 A에서 사용자 Lua 코드를 실행할 시기와 결과를 사용하는 방법을 지정하는 데 사용됩니다. 일반적으로 사용되는 명령어에 대한 간략한 설명

1. init_by_lua*

이 명령어는 Nginx가 구성을 다시 로드할 때마다 실행되며 시간이 많이 걸리는 작업 모듈 로딩을 완료하거나 일부 전역 구성을 초기화하는 데 사용됩니다

2. init_worker_by_lua*

이 명령은 하트비트 확인, 예약된 풀 서버 구성 등과 같은 일부 예약된 작업을 시작하는 데 사용됩니다.

3. set_by_lua*

이 명령만 사용해야 합니다. 변수에 값을 할당하는 명령입니다. 이 명령은 한 번에 하나의 값만 반환할 수 있으며 결과 값은 Nginx

4에서 지정된 변수에 제공됩니다. rewrite_by_lua*

는 내부 URL을 수행하는 데 사용됩니다. 의사 정적 URL 재작성과 같은 일반적인 재작성 또는 외부 리디렉션, 이 단계는 재작성 처리 단계가 끝날 때 기본적으로 실행됩니다(nginx의 자체 재작성 기능과 유사)

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的相关代码即可

location /getByGender {
          default_type 'text/html';
          set_by_lua $param "

                local uri_args = ngx.req.get_uri_args()
                local gender = uri_args['gender']
                local name = uri_args['name']
                if gender =='1' then
                       return name..':先生'
                elseif gender=='0' then
                       return name..':女士'
                else
                       return name
                end
          ";
          charset utf-8;
          return 200 $param;
 }

然后启动nginx做一下测试

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

这时候无任何返回信息

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

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

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

lua操作redis

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

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

lua-resty-redis环境准备

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

2、测试下redis客户端

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

lua-resty-redis常用API

1、lua中导入redis依赖

redis = require "resty.redis"

2、new，创建一个Redis对象

redis,err = redis:new()

3、创建redis连接

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

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

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

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

redis:set_timeout(time)

5、close，关闭连接

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

• 失败返回nil和错误信息；

ok,err = redis:close()

补充说明：

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

具体实现效果展示

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

location /redis {
    default_type "text/html";
    content_by_lua_block {
        local redis = require "resty.redis"     -- 引入 Redis
        local redisObj = redis:new()            --创建Redis对象
        redisObj:set_timeout(3000)              --设置超时数据为3s
        local ok,err = redisObj:connect("IP",6379)    --设置redis连接信息
        if not ok then                          --判断是否连接成功
            ngx.say("failed to connection redis",err)
            return
        end
        ok,err = redisObj:set("username","TOM")     --存入 数据
        if not ok then                              --判断是否存入成功
            ngx.say("failed to set username",err)
            return
        end
        local res,err = redisObj:get("username")    --从 redis中获取数据
        ngx.say(res) --将数据写会消息体中
        redisObj:close()
    }
}

重启nginx，进行测试，直接在浏览器访问一下如下地址，可以看到数据成功写入到redis

ngx_lua操作Mysql

MySQL是一个使用广泛的关系型数据库。在ngx_lua中，MySQL有两种访问模式,分别是

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

• 使用drizzle_nginx_module(HttpDrizzleModule)模块：需要单独

安装，这个库现不在OpenResty中

lua-resty-mysql

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

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

1、准备好mysql服务

2、提前创建一张表

CREATE TABLE `users` (
  `id` int(10) NOT NULL AUTO_INCREMENT,
  `username` varchar(255) DEFAULT NULL,
  `birthday` date DEFAULT NULL,
  `salary` double(10,2) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

并提前准备几条数据

INSERT INTO `mydb`.`users` (`id`, `username`, `birthday`, `salary`) VALUES ('1', 'xiaowang', '1991-03-15', '9000.00');
INSERT INTO `mydb`.`users` (`id`, `username`, `birthday`, `salary`) VALUES ('2', 'xiaoma', '1992-07-15', '8000.00');

lua-resty-mysql API说明

1、引入"resty.mysql"模块

local mysql = require "resty.mysql"

2、创建MySQL连接对象

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

db,err = mysql:new()

3、创建连接对象

ok,err=db:connect(options)

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

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

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

• user:登录的用户名

• password:登录密码

• database:使用的数据库名

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

包括connect方法

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} 
}

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

{ 
	insert_id = 0, 
	server_status=2, 
	warning_count=1, 
	affected_rows=2, 
	message=nil 
}

返回值说明：

• res:操作的结果集

• err:错误信息

• errcode:MySQL的错误码，比如1064

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

具体操作案例

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

location /mysql {
     content_by_lua_block{
		default_type "text/html";
        local mysql = require "resty.mysql" 
        local db = mysql:new() 
        local ok,err = db:connect{ 
            host="127.0.0.1", 
            port=3306,
            user="root", 
            password="123456", 
            database="mydb"
        } 
            db:set_timeout(3000) 
            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()
    } 
}

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

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

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

使用步骤

步骤一：引入cjson

local cjson = require “cjson”

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

cjson.encode(res)

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

location /mysql-cjson {
		default_type "text/html";
     content_by_lua_block{
     	local cjson = require "cjson"
        local mysql = require "resty.mysql" 
        local db = mysql:new() 
        local ok,err = db:connect{ 
            host="127.0.0.1", 
            port=3306,
            user="root", 
            password="123456", 
            database="mydb"
        } 
            db:set_timeout(3000) 
            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) do
                ngx.say(v.id..","..v.username..","..v.birthday..",".. v.salary)
            end
            db:close()
    } 
}

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

增删改操作

location /mysql-cjson {
		default_type "text/html";
     content_by_lua_block{
     	local cjson = require "cjson"
        local mysql = require "resty.mysql" 

        local db = mysql:new() 

        local ok,err = db:connect{ 
            host="127.0.0.1", 
            port=3306,
            user="root", 
            password="123456", 
            database="mydb"
        } 
            db:set_timeout(3000) 
            -- 查询操作
            db:send_query("select * from users where id=1") 
			-- 插入数据
			--local res,err,errcode,sqlstate = db:query("insert into users(id,username,birthday,salary) values(3,'lifei','1995-10-17',3000)")
			-- 修改数据
			--local res,err,errcode,sqlstate = db:query("update users set username='lisi' where id = 1")
			-- 删除数据
			--local res,err,errcode,sqlstate = db:query("delete from users where id = 2")
            db:close()
    } 
}

위 내용은 mysql을 운영하기 위해 nginx와 lua를 통합하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!