上篇博文我們已經(jīng)基于OpenResty搭建了Nginx+Lua的運(yùn)行環(huán)境，并且編寫了工程小Demo，本博文將基于上篇博文的環(huán)境來(lái)繼續(xù)實(shí)現(xiàn)Nginx+Lua是實(shí)現(xiàn)定向請(qǐng)求分發(fā)
參考之前的博文
- SpringBoot+Redis+MemCache+Nginx+Lua實(shí)現(xiàn)三級(jí)緩存架構(gòu)（一）——三級(jí)緩存架構(gòu)體系
- SpringBoot+Redis+MemCache+Nginx+Lua實(shí)現(xiàn)三級(jí)緩存架構(gòu)（二）——Nginx環(huán)境安裝和整合Lua
請(qǐng)求定向?qū)崿F(xiàn)的原理
在實(shí)現(xiàn)定向請(qǐng)求分發(fā)的功能之間，我們先了解下具體的實(shí)現(xiàn)的原理和邏輯
業(yè)務(wù)邏輯如下：
- 分發(fā)層獲取請(qǐng)求的關(guān)鍵字段，比如id
- 對(duì)id進(jìn)行hash
- hash值對(duì)應(yīng)用服務(wù)器數(shù)量進(jìn)行取模，獲取到啟動(dòng)的其中的一個(gè)應(yīng)用服務(wù)器
- 利用http發(fā)送請(qǐng)求到應(yīng)用層
- 獲取返回后的結(jié)果
環(huán)境完善
上一篇博文中，我們已經(jīng)在一個(gè)服務(wù)器上搭建了環(huán)境，接下來(lái)我們需要再準(zhǔn)備兩個(gè)環(huán)境，總共是三個(gè)環(huán)境:
| 服務(wù)器 | 用途 |
|---|---|
| 192.168.56.105 | 分發(fā)層 |
| 192.168.56.106 | 應(yīng)用層 |
| 192.168.56.107 | 應(yīng)用層 |
按照SpringBoot+Redis+MemCache+Nginx+Lua實(shí)現(xiàn)三級(jí)緩存架構(gòu)（二）——Nginx環(huán)境安裝和整合Lua的方法來(lái)搭建余下的兩個(gè)環(huán)境，并且測(cè)試是否聯(lián)通
代碼開(kāi)發(fā)
現(xiàn)在開(kāi)始編寫lua的代碼，由于我們分發(fā)層需要使用http來(lái)請(qǐng)求其他的Nginx服務(wù)，所以我們需要先將http的依賴加載起來(lái)
## 在lualib下的resty下面來(lái)加載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
下面我們開(kāi)始開(kāi)發(fā)，在分發(fā)層的 /home/work/conf/lua/requestDirect.lua中編寫如下的代碼
-- 獲取請(qǐng)求的url地址
local uri_args = ngx.req.get_uri_args()
-- 獲取請(qǐng)求中的參數(shù)id的值
local id = uri_args["id"]
-- 目前我們準(zhǔn)備了兩個(gè)應(yīng)用的nginx服務(wù)，所以我們獲取應(yīng)用層的ip為對(duì)象
local hosts = {"192.168.56.106","192.168.56.107"}
-- 對(duì)id記性hash
local hash = ngx.crc32_long(id)
-- hash值對(duì)應(yīng)用層服務(wù)器的數(shù)量取模+1
hash = (hash % 2) + 1
-- 拼接需要訪問(wèn)應(yīng)用層的url地址 http://192.168.56.107
backend = "http://"..hosts[hash]
-- 獲取url地址中的參數(shù) requestPath 這個(gè)路徑是訪問(wèn)應(yīng)用層的
-- 在本文搭建的過(guò)程中 ，主要是應(yīng)用層中的 /home/work/conf/nginx.conf
-- 中的訪問(wèn)地址
local requestPath = uri_args["requestPath"]
-- 拼接url地址后面的請(qǐng)求參數(shù) http://192.168.56.107/lua?id=1
requestPath = "/"..requestPath.."?id="..id
-- 加載http
local http = require("resty.http")
-- 創(chuàng)建http的客戶端
local httpc = http.new()
-- 執(zhí)行url請(qǐng)求
local resp, err = httpc:request_uri(backend,{
method = "GET",
path = requestPath
})
-- 如果失敗，則返回前臺(tái)失敗的消息
if not resp then
ngx.say("request error:", err)
return
end
-- 如果請(qǐng)求成功，打印請(qǐng)求內(nèi)容
ngx.say(resp.body)
-- http客戶端關(guān)閉
httpc:close()
代碼開(kāi)發(fā)完成之后， 我們重新加載下
## 編譯
nginx -t
## 重新加載
nginx -s reload
在瀏覽器上請(qǐng)求:
# 請(qǐng)求一 requestPath的路徑目前只能是lua，為了請(qǐng)求到
## 應(yīng)用Nginx層的lua訪問(wèn)
http://192.168.56.105/lua?requestPath=lua&id=1
http://192.168.56.105/lua?requestPath=lua&id=2
可以變更id的值，看看請(qǐng)求返回的值有很什么變化
如果在執(zhí)行的過(guò)程中，出現(xiàn)錯(cuò)誤了，可以查看nginx的日志記錄
## 查看 nginx的錯(cuò)誤日志
tail -1000f /usr/local/openresty/nginx/logs/error.log
至此我們就全部完成了定向請(qǐng)求分發(fā)的功能，下一篇博文，我們結(jié)合后臺(tái)框架來(lái)整合nginx和redis以及tomcat堆緩存的交互，完成三級(jí)緩存架構(gòu)的功能
