台CentOS6.x
192.168.1.210
192.168.1.211
192.168.1.212
网络拓扑
210和211作为应用层web服务器
212作为网络请求分发代理服务器

Step1:安装Linux依赖

1
yum install -y readline-devel pcre-devel openssl-devel gcc

Step2:安装Nginx Openresty

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
wget http://openresty.org/download/ngx_openresty-1.7.7.2.tar.gz  
tar -xzvf ngx_openresty-1.7.7.2.tar.gz  
cd /usr/servers/ngx_openresty-1.7.7.2/

cd bundle/LuaJIT-2.1-20150120/  
make clean && make && make install  
ln -sf luajit-2.1.0-alpha /usr/local/bin/luajit

cd bundle  
wget https://github.com/FRiCKLE/ngx_cache_purge/archive/2.3.tar.gz  
tar -xvf 2.3.tar.gz  

cd bundle  
wget https://github.com/yaoweibin/nginx_upstream_check_module/archive/v0.3.0.tar.gz  
tar -xvf v0.3.0.tar.gz  

cd /usr/servers/ngx_openresty-1.7.7.2  
./configure --prefix=/usr/servers --with-http_realip_module  --with-pcre  --with-luajit --add-module=./bundle/ngx_cache_purge-2.3/ --add-module=./bundle/nginx_upstream_check_module-0.3.0/ -j2  
make && make install

Step3:检查安装并启动

安装完成后有以下目录：

1
2
3
4
5
6
cd /usr/servers/  
ll

/usr/servers/luajit
/usr/servers/lualib
/usr/servers/nginx

检查nginx版本

1
/usr/servers/nginx/sbin/nginx -V

启动nginx:

1
/usr/servers/nginx/sbin/nginx

Step4:Nginx添加LUA配置

使LUA配置按照工程化目录结构进行配置。

1
2
3
mkdir /usr/hello

cp -r /usr/servers/lualib /usr/hello/

打开nginx.conf配置文件

1
vi /usr/servers/nginx/conf/nginx.conf

在http部分添加：

1
2
3
lua_package_path "/usr/hello/lualib/?.lua;;";  
lua_package_cpath "/usr/hello/lualib/?.so;;";  
include /usr/hello/hello.conf;

创建hello的lua配置和脚本

1
2
3
4
5
6
7
8
9
10
11
vi /usr/hello/hello.conf

server {  
    listen       80;  
    server_name  _;  
  
    location /hello/test {  
        default_type 'text/html';   
        content_by_lua_file /usr/hello/lua/test.lua;  
    }  
}

编辑lua脚本:

1
2
3
4
5
mkdir /usr/hello/lua

vi /usr/hello/lua/test.lua

ngx.say("hello world")

Nginx检查配置是否正确

1
2
3
[root@eshop-cache01 hello]# /usr/servers/nginx/sbin/nginx -t  
nginx: the configuration file /usr/servers/nginx/conf/nginx.conf syntax is ok
nginx: configuration file /usr/servers/nginx/conf/nginx.conf test is successful

Nginx重新加载配置生效

1
/usr/servers/nginx/sbin/nginx -s reload

Step5:访问LUA配置的location路径

1
curl http://192.168.1.210/hello/test

返回test.lua中脚本输出的“hello world”。

Step6:分发层Nginx安装LUA脚本实现请求分发

我们作为一个流量分发的nginx，会发送http请求到后端的应用nginx上面去，所以要先引入lua http lib包。

1
2
3
cd /usr/hello/lualib/resty/  
wget https://raw.githubusercontent.com/pintsized/lua-resty-http/master/lib/resty/http_headers.lua  
wget https://raw.githubusercontent.com/pintsized/lua-resty-http/master/lib/resty/http.lua

在分发层Nginx写LUA脚本：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
nano /usr/hello/lua/test.lua

local uri_args = ngx.req.get_uri_args()
local ecourseId = uri_args["ecourseId"]

local host = {"192.168.1.210", "192.168.1.211"}
local hash = ngx.crc32_long(ecourseId)
hash = (hash % 2) + 1
backend = "http://"..host[hash]

local paras = "";
local request_args_tab = ngx.req.get_uri_args()
for k, v in pairs(request_args_tab) do
    paras=paras..k.."="..v.."&"
end

local requestPath = ngx.var.uri
requestPath = requestPath.."?"..paras

local http = require("resty.http")
local httpc = http.new()

local resp, err = httpc:request_uri(backend, {
    method = "GET",
    path = requestPath
})

if not resp then
    ngx.say("request error :", err)
    return
end

ngx.say(resp.body)

httpc:close()

Nginx重新加载配置生效

1
/usr/servers/nginx/sbin/nginx -s reload

测试请求分发,在浏览器地址栏输入

http://192.168.1.212/hello/test?ecourseId=1
http://192.168.1.212/hello/test?ecourseId=2
http://192.168.1.212/hello/test?ecourseId=3
http://192.168.1.212/hello/test?ecourseId=4
查看返回的结果，请求被分发到应用层web服务器节点了。根据ecourseId与应用层web服务节点数取模，找到对应的应用层服务器节点。

Step7:按照相同的方法部署另外两台机器的Nginx

安装过程，略…
应用层Nginx添加http请求功能包即可。

1
2
3
cd /usr/hello/lualib/resty/  
wget https://raw.githubusercontent.com/pintsized/lua-resty-http/master/lib/resty/http_headers.lua  
wget https://raw.githubusercontent.com/pintsized/lua-resty-http/master/lib/resty/http.lua

补充：LUA脚本获取Nginx Http请求的相关参数说明

1.获取当前请求的url相关信息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
function test()
-- 这个变量等于包含一些客户端请求参数的原始URI，它无法修改，请查看$uri更改或重写URI。
local request_uri = ngx.var.request_uri
 log(tools.gbk_to_u8("获取当前请求的url==") .. tools.u8_to_gbk(cjson.encode(request_uri)) )

 -- HTTP方法（如http，https）。按需使用，例：
 local scheme = ngx.var.scheme server_addr
 log(tools.gbk_to_u8("获取当前请求的url scheme==") .. tools.u8_to_gbk(cjson.encode(scheme)) )

 -- 服务器地址，在完成一次系统调用后可以确定这个值，如果要绕开系统调用，则必须在listen中指定地址并且使用bind参数。
 local server_addr = ngx.var.server_addruri 
 log(tools.gbk_to_u8("获取当前请求的url server_addr==") .. tools.u8_to_gbk(cjson.encode(server_addr)) )

-- 请求中的当前URI(不带请求参数，参数位于$args)，可以不同于浏览器传递的$request_uri的值，它可以通过内部重定向，或者使用index指令进行修改。
 local uri = ngx.var.uri 
 log(tools.gbk_to_u8("获取当前请求的url uri==") .. tools.u8_to_gbk(cjson.encode(uri)) )

 -- 服务器名称
 local server_name  = ngx.var.server_name  
 log(tools.gbk_to_u8("获取当前请求的url server_name ==") .. tools.u8_to_gbk(cjson.encode(server_name )) 

 -- 请求到达服务器的端口号。
local server_port  = ngx.var.server_name  
 log(tools.gbk_to_u8("获取当前请求的url server_port ==") .. tools.u8_to_gbk(cjson.encode(server_port )) 
end


test()

2.获取发送请求端过来的url相关信息

1
2
3
4
5
6
7
-- 获取远程的IP地址。
local remote_addr  = ngx.var.remote_addr 
 log(m_uuid,tools.gbk_to_u8("获取发送请求过来的远程请求remote_addr ==") .. tools.u8_to_gbk(cjson.encode(remote_addr )) )

 -- 获取远程的端口号
 local remote_port  = ngx.var.remote_port  
 log(m_uuid,tools.gbk_to_u8("获取发送请求过来的远程请求remote_port ==") .. tools.u8_to_gbk(cjson.encode(remote_port )) )