服務注冊中心之ZooKeeper系列(一)


一、服務注冊中心介紹

  分布式服務框架部署在多台不同的機器上。例如服務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中,使用隨機算法,實現微服務之間的調用。

如果你覺得寫得還行,請點個推薦!


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM