??在 Spring Cloud 微服務(wù)架構(gòu)體系中，所有請求的前門的網(wǎng)關(guān) Zuul 承擔(dān)著請求轉(zhuǎn)發(fā)的主要功能，對后端服務(wù)起著舉足輕重的作用。當(dāng)業(yè)務(wù)體量猛增之后得益于 Spring Cloud 的橫向擴展能力，往往加節(jié)點、加機器就可以使得系統(tǒng)支撐性獲得大大提升，但是僅僅加服務(wù)而不加網(wǎng)關(guān)是會有性能瓶頸的，實踐經(jīng)驗得出的結(jié)論是單一 Zuul 的處理能力十分有限，因此擴張節(jié)點往往是服務(wù)連帶 Zuul 一起擴張，然后再在請求上層加一層軟負載，通常是使用 Nginx（Nginx 均分請求到 Zuul 負載層，“完美”地解決了問題），如下圖：
??上圖的這種方式在實際運行中存在兩個缺點：
在后端 Zuul 運行一段時間之后，其中一臺 Zuul 掛掉了，前端請求的服務(wù)會有一部分掛掉。原因很簡單，Nginx 和后端 Zuul 沒有關(guān)聯(lián)性，Zuul 宕掉以后，Nginx 還是會把請求分發(fā)過來。
新加機器、對 Zuul 做新的橫向擴展，就需要去更改 Nginx 的配置，對新擴展的 Zuul 進行配置。
解決方案：
??OpenResty 整合了 Nginx 與 Lua，實現(xiàn)了可伸縮的 Web 平臺，內(nèi)部集成了大量精良的 Luα 庫、第三方模塊以及多數(shù)的依賴項。能夠非?？旖莸卮罱ㄌ幚沓卟l(fā)、擴展性極高的動態(tài) Web 應(yīng)用、Web 服務(wù)和動態(tài)網(wǎng)關(guān)。我們可以使用 Luα 腳本模塊與注冊中心構(gòu)建一個服務(wù)動態(tài)增減的機制，通過 Lua 獲取注冊中心狀態(tài)為 UP 的服務(wù)，動態(tài)地加入到 Nginx 的均衡列表中去。
??Spring Cloud 中國社區(qū)針對上面說的這種場景開源了相關(guān)的 Lua 插件源碼（Github 地址）
1、環(huán)境
yum -y install readline-devel pcre-devel openssl-devel gcc
2、下載解壓OpenResty包
wget https://openresty.org/download/openresty-1.13.6.1.tar.gz
tar -zxvf openresty-1.13.6.1.tar.gz
3、下載ngx_cache_purge模塊，該模塊用于清理nginx緩存
cd openresty-1.13.6.1/bundle
wget http://labs.frickle.com/files/ngx_cache_purge-2.3.tar.gz
tar -zxvf ngx_cache_purge-2.3.tar.gz
4、下載nginx_upstream_check_module模塊，該模塊用于upstream健康檢查
wget https://github.com/yaoweibin/nginx_upstream_check_module/archive/v0.3.0.tar.gz
tar -zxvf v0.3.0.tar.gz
5、OpenResty配置增加
cd openresty-1.13.6.1
./configure --prefix=/usr/local/openresty --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
6、編譯安裝
make
make install
7、OpenResty沒有http模塊，需要單獨安裝
cd /usr/local/openresty/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
8、項目腳本拷貝到這里
copy dynamic_eureka_balancer.lua into this dir
9、Nginx配置文件
vim /usr/local/openresty/nginx/conf/nginx.conf
http {
#sharing cache area
lua_shared_dict dynamic_eureka_balancer 128m;
init_worker_by_lua_block {
-- 引入 Lua 插件文件
local file = require "resty.dynamic_eureka_balancer"
local balancer = file:new({dict_name="dynamic_eureka_balancer"})
-- Eureka server list
balancer.set_eureka_service_url({"127.0.0.1:8888", "127.0.0.1:9999"})
-- The service name that needs to be monitored
balancer.watch_service({"zuul", "client"})
}
upstream springcloud_cn {
server 127.0.0.1:666; # Required, because empty upstream block is rejected by nginx (nginx+ can use 'zone' instead)
balancer_by_lua_block {
--The zuul name that needs to be monitored
local service_name = "zuul"
local file = require "resty.dynamic_eureka_balancer"
local balancer = file:new({dict_name="dynamic_eureka_balancer"})
--balancer.ip_hash(service_name) --IP Hash LB
balancer.round_robin(service_name) --Round Robin LB
}
}
server {
listen 80;
server_name localhost;
location / {
proxy_pass http://springcloud_cn/;
proxy_set_header Host $http_host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header X-Forwarded-Proto $scheme;
}
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
}
??實現(xiàn)原理是使用 Lua 腳本定時根據(jù)配置的服務(wù)名與 Eureka 地址，去拉取該服務(wù)的信息，在 Eureka 里面提供 /eureka/apps/{serviceId} 端點，返回服務(wù)的注冊信息，所以我們只需要取用狀態(tài)為 UP 的服務(wù)，將它的地址加入 Nginx 負載列表即可。此項目使得 Nginx 與 Zuul 之間擁有一個動態(tài)感知能力，不用手動配置 Nginx 負載與 Zuul 負載，這樣對于應(yīng)用彈性擴展是極其友好的。
重慶分公司
重慶分公司
