自從微服務和雲計算興起後,誕生了無數優秀的微服務架構,給開發部署帶來了巨大的便利,敏捷開發得到了最佳的實踐場景。然而微服務模式帶來便利和高性能的同時不可避免會帶來服務數量的膨脹,處理鏈路複雜化,底層架構和微服務框架差別化,所以服務治理問題成爲了新的痛點,爲了解決以上場景,service mesh 概念誕生。node
service mesh (服務網格)經過在微服務網絡中加入一些與業務服務解耦的服務實例,充當消息轉發的角色,本質是在應用層加入一個通訊管理層來管理網絡中微服務的服務互通、服務發現、服務治理、鏈路追蹤、健康監控等問題。使用服務網格後,在業務層面基本不用改動的狀況下,之前複雜系統中須要考慮的跨團隊服務設計,語言選擇,異架構通訊,鏈路管理,服務治理,服務上雲等難題都能在一個統一的基礎設施框架中獲得解決。python
那麼具體是怎麼作到的呢?服務網格經過增長一個代理服務,與原有微服務並行跑在一個基礎設施上,這裏的基礎設施能夠是物理機或者容器。這個代理服務主要有兩個功能:linux
(1) 請求代理,全部本來直接發給微服務的請求都會被代理實例攔截,代理程序再將請求轉發給真正的微服務處理,原有微服務發起的全部請求也將先轉發給這個代理,由代理向外部的微服務網絡發起請求。git
(2) 組成可見的微服務網絡節點,這個代理須要經過某種方式向微服務網絡世界暴露本身,好比向某個分佈式服務中心註冊,表明業務服務實例參與到服務網絡中,執行復雜的服務治理策略、調用鏈追蹤、路由控制等功能。github
下圖中的 proxy 表明服務網格實例,server 表明微服務實例,這是服務網格的主要模式 sidecar,能夠看到,每一個微服務實例都有單獨的服務網格實例爲它服務,能夠理解爲在車道上並排奔跑的兩個微服務,server 處理業務請求,負責業務層面的工做,proxy 服務攔截進出 server 的流量,負責微服務通訊和治理層面的問題。web
本文主要結合 Apache 項目 servicecomb-mesher 來介紹服務網格的實現,其餘項目不作展開介紹。算法
圖1 服務網格鳥瞰圖docker
Servicecomb-mesher 是 Apache servicecomb 的服務網格項目。使用 go 語言基於 go-chassis 開源框架實現,go-chassis 框架以插件的形式支持負載均衡、流量控制、調用鏈追蹤、熔斷降級、服務治理、動態配置管理等微服務能力。mesher目前支持sidecar和edgeservice兩種運行模式。支持服務間使用http、grpc協議通訊,有良好的可擴展性,用戶可自行擴展本身的協議。mesher以調用鏈的形式處理請求,能夠根據配置自由裁剪處理函數。在控制面mesher自然可以接入apache servicecomb微服務體系。並對當前主流的service-mesh具備兼容性,支持kubernetes,可接入Istio。apache
圖2 mesher交互模型圖bootstrap
咱們以 sidecar 模式運行 mesher,經過一個具體的 http 協議通訊爲例介紹 mesher 作了什麼工做。
(1) 咱們啓動一個真正的 http server 做爲業務服務,這裏對 http server 的實現語言,服務框架沒有任何限制;
(2) 啓動 mesher,mesher會根據配置信息啓動兩個 http 服務,分別監聽在本地迴環和本地 ip 上(如127.0.0.1:30101 和 192.168.88.64:30101)。mesher 經過127.0.0.1:30101 處理內部業務服務對外部的請求流量;監聽在 192.168.88.64:30101 的服務用於處理外部對內部業務服務的請求流量;
(3) 如圖,client 做爲一個請求發起方,client 的請求經過代理轉發到與它綁定的 mesher(127.0.0.1:30102);
(4) mesher(127.0.0.1:30102)接收到請求後,使用 LocalRequestHandler 處理請求,首先準備 consumer 調用鏈,獲取並解析 client 調用的服務名和端口,建立 Invocation,以後經過 consumer 調用鏈進行處理,最後創建一個 rest-client 對外部的目的服務(192.168.88.64:30101)發起調用;
(5) 監聽在 192.168.88.64:30101 的 mesher 接收到請求後,調用 RemoteRequestHandler 處理請求,首先將請求轉爲 Invocation,準備 provider 調用鏈,解析地址,將目的地址替換爲業務服務的地址,而後調用處理鏈處理請求,最終向內部真正的業務 server 發起 http 調用;
監聽在 127.0.0.1:30101 的 mesher 做爲 consumer,使用處理請求,consumerChain 調用鏈默認包含以下處理器(handler):
chassisHandler.Router,chassisHandler.RatelimiterConsumer
chassisHandler.BizkeeperConsumer
chassisHandler.Loadbalance
chassisHandler.Transport
監聽在 192.168.88.64:30101 的 mesher 做爲 provider 處理請求,providerChain 調用鏈默認包含以下處理器(handler):
chassisHandler.RatelimiterProvider
chassisHandler.Transport
圖3 mesher通訊模型圖
經過以上分析能夠看到,mesher 實際上在應用層做爲一個代理,攔截並代替業務服務發起和接收請求,mesher 和業務服務各司其職,業務服務只要保證業務功能正常,mesher 負責服務治理層面,構建可靠的通訊鏈路。咱們只要保證 mesher 與業務的互通以及 mesher 與外部其餘 mesher 之間的通訊就能夠保證提供服務,那麼這裏 mesher 是如何作到的呢?這個問題就涉及到 go-chassis 開源框架的服務發現和控制面管理功能。mesher 使用 go-chassis 底座的 register 包將本身註冊到服務中心實例,這裏咱們使用 Apache 的 servicecomb-servicecenter,它是一個接收微服務註冊並進行管理的服務中心,全部鏈接到 servicecenter 的服務均可以經過服務中心向其餘服務暴露本身,並經過微服務名獲取到其餘服務實例的 ip 和 port。mesher 的控制面功能支持斷路器、負載均衡、頻率限制、錯誤注入等,能夠接入istio或者使用archaius以讀取配置的方式。
瞭解了 mesher 的原理後,咱們經過一個具體的用例幫助用戶快速入門 mesher 的 sidecar 模式。但願幫助用戶經過該例子,可以快速上手使用 mesher 服務,深刻了解 mesher 的工做模式和原理,並掌握如何經過 mesher 的幫助改造已有的 http 服務,接入 servicecomb 微服務體系,得到負載均衡、流控、服務治理、調用鏈追蹤等微服務能力。具體案例配置和代碼能夠經過 github 下載:
https://github.com/apache/servicecomb-mesher/tree/master/examples/quick_start
圖4 mesher案例部署圖
一、httpserver_calculator:基於python語言實現的http體質指數服務,可替換爲任何語言開發的http服務;
二、httpserver_webapp:基於 nodejs 語言實現的web服務,用於在瀏覽器上展現可視化結果;
三、mesher_webapp:經過 sidecar 模式爲httpserver_webapp 提供服務的 mesher 實例;
四、mesher_calculator:經過 sidecar 模式爲httpserver_calculator 提供服務的 mesher 實例;
五、servicecenter:服務中心,接收 mesher 服務的註冊,提供服務發現、路由查詢、服務監控功能;
流程詳情:
瀏覽器[192.168.88.78]對 httpserver_webapp 服務發起 http 調用 http://192.168.88.64:4597/calculator/bmi。
httpserver_webapp 服務接收請求,併發起對地址 http://calculator/bmi 的 http 調用,由於設置了代理http://127.0.0.1:30101,httpserver_webapp 發起的請求將被轉發到 mesher_webapp 服務。
mesher_webapp 根據請求的服務名(microservice.yaml 配置的服務名 calculator)從服務中心 servicecenter 得到該服務名的地址,轉發到 mesher_calculator。
mesher_calculator 服務根據設置好的specific地址,轉發到本身綁定的體質指數calculator服務(httpserver_calculator)進行處理。
httpserver_calculator 會根據用戶身高和體重進行計算,並返回本身的服務標識展現在界面上。流程圖以下所示:
圖5 mesher案例流程圖圖
一、編譯 mesher :下載地址(https://github.com/apache/servicecomb-mesher)
按README.md編譯項目獲得可執行文件mesher(linux),windows(mesher.exe);
二、建立 mesher_webapp 用於爲 httpserver_webapp 服務:
在 mesher 目錄下執行下列linux命令建立 mesher_webapp,此處除了可執行文件,還須要拷貝conf
mkdir /usr/local/src/mesher_webapp
更改 conf 中配置文件,microservice.yaml 中的服務 name,從 hellomesher 改成 webapp;更改 chassis.yaml 中監聽的服務地址,從本地迴環(127.0.0.1)地址改成內網 ip(linux下經過 ifconfig 查看,如192.168.88.64):
listenAddress: 127.0.0.1:40101 -> listenAddress: 192.168.88.64:40101
三、建立mesher_calculator
mkdir /usr/local/src/mesher_calculator
更改conf中配置文件,分別更改microservice.yaml中的服務name爲體質指數微服務名calculator;
更改mesher_calculator配置chassis.yaml監聽的地址和端口:
listenAddress: 127.0.0.1:40101 -> listenAddress: 192.168.88.64:40107
四、 啓動mesher服務,分別進入mesher_webapp和mesher_calculator,啓動服務,其中須要設置mesher_calculator的SPECIFIC_ADDR地址,該地址用於創建mesher和http服務邏輯上的綁定關係;
cd /usr/local/src/mesher_calculator
五、 啓動httpserver_webapp服務:
cd /usr/local/src/httpserver_webapp
六、 httpserver_calculator 做爲體質指數計算服務,須要安裝python2.7,依賴BaseHTTPServer包:
cd /usr/local/src/httpserver_calculator
圖6 servicecenter服務監控圖
一、瀏覽器打開頁面 http://192.168.88.64:30103 (若是打不開須要開啓服務中心 service-center 的 front 服務,參考http://servicecomb.apache.org/cn/users/setup-environment/#%E8%BF%90%E8%A1%8Cservice-center
查看服務,其中地址 service-center 服務啓動的地址,看到如圖界面。
webapp 表明 mesher_webapp 服務,這裏展現的是 microservice.yaml 中配置的服務名;calculator 表明 mesher_calculator 服務,這裏展現的是 microservice.yaml 中配置的服務名。大寫的 SERVICECENTER 是服務中心。
圖7 servicecenter服務監控圖
二、瀏覽器打開 http://192.168.88.64:4597,能夠看到以下界面,爲 webapp 呈現的靜態頁面:
圖8 bmi調用結果展現界面圖
三、輸入參數(180、70)點擊 submit,觀察結果:
圖9 bmi調用結果圖
圖10 mesher 負載均衡案例部署圖
啓動一個新的 mesher_calculator 和 httpserver_calculator 實例用於負載均衡測試,可使用例子目錄test_balance下的服務:
一、修改 mesher_calculator 配置文件 microservice.yaml 中的服務 name 爲 calculator;
更改配置 chassis.yaml 監聽的地址和端口避免衝突:
listenAddress: 127.0.0.1:40101 -> listenAddress: 192.168.88.64:40102
二、啓動 mesher_calculator,須要設置 mesher_calculator 的 SPECIFIC_ADDR 地址,該地址用於創建 mesher 和 http 服務邏輯上的綁定關係;
export SPECIFIC_ADDR=127.0.0.1:4537
三、默認狀況下會使用 roundbin(輪詢)負載均衡算法,另外還支持 Random 和 SessionStickiness 負載均衡算法。咱們修改 mesher_webapp 的配置文件 chassis.yaml,將負載均衡方法配置爲 Random:
loadbalance:
四、開啓 httpserver_calculator 服務新實例,監聽4537端口。
五、此時點擊 Submit 按鈕就能夠看到以下兩個界面中的 BMI Instance ID 隨機出現;
圖11 bmi調用結果圖
一、添加流量控制配置,重啓服務,更改 mesher_calculator配置文件 chassis.yaml,其中流量控制包含下列選項:
flowcontrol:
該頻率限制標識每秒接受的請求爲0,即不提供服務。
二、驗證,點擊 Submit 按鈕,此時能看到因爲流控受限而請求被拒的界面,請求已經沒法到達 httpserver_calculator。
圖13 流量控制展現圖
2.6.3.1 灰度發佈
一、更新版本號:分別更改兩個 mesher_calculator 實例的配置文件 microservice.yaml,更新 version 字段分別爲1.1.1和1.1.2,重啓 mesher 服務,能夠看到服務版本號發生了變動。如圖中所示:
圖14 服務監控圖
二、配置路由信息,更改 mesher_webapp 的配置文件 router.yaml,按實例版本更新權重信息,並重啓服務:
servicecomb:
三、驗證,此時大量點擊 Submit 按鈕就能夠看到 BMI Instance ID 按配置的比例交替出現。
一、更改斷流器配置,更改 mesher_webapp 的配置文件 chassis.yaml,設置其中的斷流器配置爲:
isolation:
二、關閉 test_balance 目錄下的服務實例。
三、驗證,傳入負數參數,響應超時,mesher_webapp 斷流器生效,圖16中三個子圖分別是:
(1) mesher_webapp 日誌截圖,代表斷流器啓用。
(2) 傳入負數參數觸發斷流器時的返回值。
(3) 表示斷流器生效後對全部請求都按配置返回 nil。
圖16 服務熔斷展現圖
四、根據配置參數 sleepWindowInMilliseconds,過10秒後服務自動恢復。
一、mesher main 文件中添加對zipkin庫依賴:
_ "github.com/go-chassis/go-chassis-plugins/tracing/zipkin"
二、啓發器 bootstrap.go 中添加默認處理函數,如圖17中箭頭所示:
圖17 handlerchain調用圖
三、從新編譯,分別替換 **mesher_webapp **和 **mesher_calculator **的可執行文件,啓動 mesher 服務。
四、 使用 Docker 運行 Zipkin 分佈式追蹤服務,連接:
http://servicecomb.apache.org/cn/docs/quick-start-advance/distributed-tracing/
docker run -d -p 9411:9411 openzipkin/zipkin
五、屢次點擊 Submit 按鈕發起服務調用。
六、打開 http://192.168.88.64:9411 可查看分佈式追蹤結果如圖18,能夠經過 host 地址判斷調用路徑:
圖18 分佈式追蹤結果圖
關注微服務,關注雲原生