一、服務註冊中心介紹 分散式服務框架部署在多台不同的機器上。例如服務A是訂單相關的處理服務,服務B是訂單的客戶的相關信息服務。此時有個需求需要在服務A中獲取訂單客戶的信息。如下圖: 此時就面臨以下幾個問題: 1、集群A中的服務調用者如何發現集群B中的服務提供者。 2、集群A中的服務調用者如何選擇集群 ...
一、服務註冊中心介紹
分散式服務框架部署在多台不同的機器上。例如服務A是訂單相關的處理服務,服務B是訂單的客戶的相關信息服務。此時有個需求需要在服務A中獲取訂單客戶的信息。如下圖:
此時就面臨以下幾個問題:
1、集群A中的服務調用者如何發現集群B中的服務提供者。
2、集群A中的服務調用者如何選擇集群B中的某一臺服務提供者去調用。
3、集群B中某台機器下線,集群A怎麼避免下次調用不在使用這台掉線的機器?
4、集群B提供的某個服務如何獲知集群A中哪些機器正在消費該服務?
以上問題就需要通過註冊中心來解決。
首先在服務啟動的時候,將服務提供者信息主動上報到服務註冊中心進行服務註冊。服務調用者啟動的時候,將服務提供或者信息從註冊中心下拉倒服務調用者本機緩存。當需要調用服務時,從本地緩存列表中找到服務提供者的地址列表,基於某種負載均衡策略(隨機、輪詢等)選擇一臺伺服器發起遠程調用。ZooKeeper就是實現這些功能的分散式協調服務。
二、ZooKeeper介紹
ZooKeeper是由雅虎開發並開源的分散式協調服務。ZooKeeper提供了統一命名服務、配置管理、分散式鎖等基礎服務,基於這些基礎服務,我們可以實現集群管理、軟負載、發佈/訂閱、命名服務等功能。
ZooKeeper維護著一種像文件系統的一種結構樹。如下圖:
圖中每個都是一個節點(ZNode),節點可以包含數據,也可以沒有,每個節點都有自己的許可權。如上圖,127.0.0.1:5000提供服務 GetGustomer。127.0.0.1:5002提供Order和GetOrder服務。服務發現就是將服務提供者信息主動上報到服務註冊中心進行服務註冊,如將其提供的服務和對應的IP和埠註冊到ZooKeeper中,服務調用者啟動的時候,將ZooKeeper註冊中心信息下拉倒服務調用者本機緩存,到需要用到到某個服務時,通過某種演算法,去選擇其中一個IP+埠,然後調用。
2.1 Api概述
reate/path data
創建一個名為/path的znode節點,並包含數據data。
delete/path
刪除名為/path的znode。 如果設置為true,我們就可以通過我們創建ZooKeeper句柄時所設置的Watcher對象得到事件,同時另一個版本的方法提供了以Watcher對象為入參,通過這個傳入的對象來接收變更的事件
exists/path
檢查是否存在名為/path的節點。
setData/path data
設置名為/path的znode的數據為data。
getData/path
返回名為/path節點的數據信息。
getChildren/path
返回所有/path節點的所有子節點列表。
需要註意的是,ZooKeeper並不允許局部寫入或讀取znode節點的數據。當設置一個znode節點的數據或讀取時,znode節點的內容會被整個替換或全部讀取進來。
2.2 節點類型
當新建znode時,還需要指定該節點的類型,不同的類型決定了znode節點的行為方式。節點類型分為4種:持久性、臨時性、持久有序、臨時有序節點。
持久節點:可以通過持久類型的znode為應用保存一些數據,即使znode的創建者不再屬於應用系統時,數據也可以保存下來而不丟失。持久的znode,如/path,只能通過調用delete來進行刪除。
臨時節點:當創建該節點的客戶端崩潰或關閉了與ZooKeeper的連接時,這個節點就會被刪除。並且臨時節點不允許有子節點。
有序節點:一個znode還可以設置為有序節點。一個有序znode節點被分配唯一個單調遞增的整數。當創建有序節點時,一個序號會被追加到路徑之後。
2.3 版本號
每一個znode都有一個版本號,它隨著每次數據變化而自增。兩個API操作可以有條件地執行:setData和delete。這兩個調用以版本號作為轉入參數,只有當轉入參數的版本號與伺服器上的版本號一致時調用才會成功。
三、Windows安裝
3.1 準備
到ZooKeeper官網下載,下載地址為:https://zookeeper.apache.org/releases.html#download。 由於ZooKeeper需要JDK,所以還要下載JDK,然後需要配置系統的環境變數"JAVA_HOME"(名稱需要完全一致),其值為JDK的文件夾所在路徑。
3.2 介紹
Bin文件目錄:以.sh結尾的腳本運行在UNIX平臺,以.cmd結尾的腳本則用於Windows。
Conf目錄:保存配置文件。(zoo.cfg是預設配置。)
Lib目錄:包含了java的JAR文件,它們是運行ZooKeeper需要的第三方文件。
3.3 配置
Zookeeper 的配置文件在 conf 目錄下,這個目錄下有 zoo_sample.cfg 和 log4j.properties,你需要做的就是將 zoo_sample.cfg 改名為 zoo.cfg,因為 Zookeeper 在啟動時會找這個文件作為預設配置文件。
- tickTime:這個時間是作為 Zookeeper 伺服器之間或客戶端與伺服器之間維持心跳的時間間隔,也就是每個 tickTime 時間就會發送一個心跳。
- dataDir:顧名思義就是 Zookeeper 保存數據的目錄,預設情況下,Zookeeper 將寫數據的日誌文件也保存在這個目錄里。
- dataLogDir:顧名思義就是 Zookeeper 保存日誌文件的目錄
- clientPort:這個埠就是客戶端連接 Zookeeper 伺服器的埠,Zookeeper 會監聽這個埠,接受客戶端的訪問請求。
修改zoo.cfg文件內容為:
tickTime=2000 initLimit=10 syncLimit=5 dataDir=D:\\Software\\ZooKeeper\\data clientPort=2181
啟動zookeeper服務,到/bin文件夾下,用命令行運行 zkService.cmd命令。看到Starting servicer 並且沒有報錯就說明啟動成功。
接下來啟動客戶端,到/bin文件夾下,用命令行運行 zkCli.cmd命令.
3.4 用命令操作節點
在客戶端通過 ls / 命令查看節點:
[zk: localhost:2181(CONNECTED) 1] ls /
[MyApp, zookeeper]
[zk: localhost:2181(CONNECTED) 2] ls /zookeeper
[quota]
[zk: localhost:2181(CONNECTED) 3]
創建節點:create [-s] [-e] path data acl
path:路徑
data:節點的數據
acl:許可權
-e:表示臨時節點
-s:表示順序節點
[zk: localhost:2181(CONNECTED) 5] create -e /Microheart MH Created /Microheart [zk: localhost:2181(CONNECTED) 6] ls / [MyApp, zookeeper, Microheart]
這裡創建的是臨時節點,如果當前客戶端關閉,則此節點就會消失。
刪除節點:
[zk: localhost:2181(CONNECTED) 7] delete /Microheart [zk: localhost:2181(CONNECTED) 8] ls / [MyApp, zookeeper]
這篇文章主要是對ZooKeeper的初步瞭解和認識,使用命令去操作節點,下篇文章寫兩個微服務,將微服務註冊到ZooKeeper中,使用隨機演算法,實現微服務之間的調用。
如果你覺得寫得還行,請點個推薦!