上篇博文我们已经基于OpenResty搭建了Nginx+Lua的运行环境,并且编写了工程小Demo,本博文将基于上篇博文的环境来继续实现Nginx+Lua是实现定向请求分发
参考之前的博文
- SpringBoot+Redis+MemCache+Nginx+Lua实现三级缓存架构(一)——三级缓存架构体系
- SpringBoot+Redis+MemCache+Nginx+Lua实现三级缓存架构(二)——Nginx环境安装和整合Lua
请求定向实现的原理
在实现定向请求分发的功能之间,我们先了解下具体的实现的原理和逻辑
业务逻辑如下:
- 分发层获取请求的关键字段,比如id
- 对id进行hash
- hash值对应用服务器数量进行取模,获取到启动的其中的一个应用服务器
- 利用http发送请求到应用层
- 获取返回后的结果
环境完善
上一篇博文中,我们已经在一个服务器上搭建了环境,接下来我们需要再准备两个环境,总共是三个环境:
服务器 | 用途 |
---|---|
192.168.56.105 | 分发层 |
192.168.56.106 | 应用层 |
192.168.56.107 | 应用层 |
按照SpringBoot+Redis+MemCache+Nginx+Lua实现三级缓存架构(二)——Nginx环境安装和整合Lua的方法来搭建余下的两个环境,并且测试是否联通
代码开发
现在开始编写lua的代码,由于我们分发层需要使用http来请求其他的Nginx服务,所以我们需要先将http的依赖加载起来
## 在lualib下的resty下面来加载http的依赖
cd /home/work/lualib/resty
## 下载http_headers.lua
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
下面我们开始开发,在分发层的 /home/work/conf/lua/requestDirect.lua
中编写如下的代码
-- 获取请求的url地址
local uri_args = ngx.req.get_uri_args()
-- 获取请求中的参数id的值
local id = uri_args["id"]
-- 目前我们准备了两个应用的nginx服务,所以我们获取应用层的ip为对象
local hosts = {"192.168.56.106","192.168.56.107"}
-- 对id记性hash
local hash = ngx.crc32_long(id)
-- hash值对应用层服务器的数量取模+1
hash = (hash % 2) + 1
-- 拼接需要访问应用层的url地址 http://192.168.56.107
backend = "http://"..hosts[hash]
-- 获取url地址中的参数 requestPath 这个路径是访问应用层的
-- 在本文搭建的过程中 ,主要是应用层中的 /home/work/conf/nginx.conf
-- 中的访问地址
local requestPath = uri_args["requestPath"]
-- 拼接url地址后面的请求参数 http://192.168.56.107/lua?id=1
requestPath = "/"..requestPath.."?id="..id
-- 加载http
local http = require("resty.http")
-- 创建http的客户端
local httpc = http.new()
-- 执行url请求
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)
-- http客户端关闭
httpc:close()
代码开发完成之后, 我们重新加载下
## 编译
nginx -t
## 重新加载
nginx -s reload
在浏览器上请求:
# 请求一 requestPath的路径目前只能是lua,为了请求到
## 应用Nginx层的lua访问
http://192.168.56.105/lua?requestPath=lua&id=1
http://192.168.56.105/lua?requestPath=lua&id=2
可以变更id的值,看看请求返回的值有很什么变化
如果在执行的过程中,出现错误了,可以查看nginx的日志记录
## 查看 nginx的错误日志
tail -1000f /usr/local/openresty/nginx/logs/error.log
至此我们就全部完成了定向请求分发的功能,下一篇博文,我们结合后台框架来整合nginx和redis以及tomcat堆缓存的交互,完成三级缓存架构的功能