https://zookeeper.apache.org/...html
ZooKeeper is a distributed, open-source coordination service for distributed applications. It exposes a simple set of primitives that distributed applications can build upon to implement higher level services for synchronization, configuration maintenance, and groups and naming. It is designed to be easy to program to, and uses a data model styled after the familiar directory tree structure of file systems.
Zookeeper是高性能,高可用,嚴格有序的分佈式協調服務,提供了統一配置(configuration),命名(naming),同步(synchronization),以及分組服務(group service)。node
同時,Zookeeper自己支持複製集羣,實例間是兩兩鏈接的,維護內存中的數據狀態,並持久存儲中的事務日誌和快照。只要大多數服務器可用,ZooKeeper服務將可用。
在「讀爲主」的工做負載中,它特別快。ZooKeeper應用程序可在數千臺計算機上運行,而且在讀取比寫入更爲常見的狀況下,其性能最佳,比率約爲10:1。shell
ZooKeeper提供的名稱空間與標準文件系統的名稱空間很是類似。apache
名稱是由斜槓(/)分隔的一系列路徑元素。ZooKeeper命名空間中的每一個節點都由路徑進行惟一標識。編程
ZooKeeper的層次命名空間服務器
與標準文件系統不一樣,ZooKeeper命名空間中的每一個節點均可以具備與其關聯的數據以及子節點。就像擁有一個文件系統同樣,該文件系統也容許文件成爲目錄。
每個節點均可以存儲數據,只是須要注意的是存儲的容量是有限,通常不能超過 1MiB。微信
Znode的類型分爲三類:session
persistent node
)節點會被持久ephemeral node
),客戶端斷開鏈接後,ZooKeeper會自動刪除臨時節點sequential node
),每次建立順序節點時,ZooKeeper都會在路徑後面自動添加上10位的數字,從1開始,最大是2147483647 (2^32-1)每一個順序節點都有一個單獨的計數器,而且單調遞增的,由Zookeeper的leader
實例維護。數據結構
Znode實際上有四種形式,默認是persistent
。app
create /test/a "hello"
,經過 create <path> <data>
參數指定爲持久節點create -s <path> <data>
參數指定爲順序節點create -e <path> <data>
參數指定爲順序節點create -s -e <path> <data>
參數指定爲臨時及順序節點
(1) 建立順序節點
[zk: 127.0.0.1:2281(CONNECTED) 0] create /seq_test/ "" Created /seq_test [zk: 127.0.0.1:2281(CONNECTED) 1] create -s /seq_test/s "hello" Created /seq_test/s0000000001 [zk: 127.0.0.1:2281(CONNECTED) 2] create -s /seq_test/s "hello" Created /seq_test/s0000000002 [zk: 127.0.0.1:2281(CONNECTED) 3] ls /seq_test [s0000000001, s0000000002]
(2) 建立臨時節點
[zk: 127.0.0.1:2281(CONNECTED) 0] create /ephe_test/ "" Created /ephe_test [zk: 127.0.0.1:2281(CONNECTED) 1] create -e /ephe_test/e "hello" Created /ephe_test/e [zk: 127.0.0.1:2281(CONNECTED) 2] ls /ephe_test [e]
斷開從新鏈接
[zk: 127.0.0.1:2281(CONNECTED) 0] ls /ephe_test []
(3) 建立臨時順序節點
[zk: 127.0.0.1:2281(CONNECTED) 0] create /ephe_seq_test/ "" Created /ephe_seq_test [zk: 127.0.0.1:2281(CONNECTED) 1] create -e -s /ephe_seq_test/s "hello" Created /ephe_seq_test/s0000000001 [zk: 127.0.0.1:2281(CONNECTED) 2] ls /ephe_seq_test [s0000000001]
ZooKeeper Transaction Id
)
每次的變化都會產生一個集羣全局的惟一的事務id, Zxid(ZooKeeper Transaction Id
),由Zookeeper的leader
實例維護。
這裏的變化包括:
Server
Server
鏈接create
、修改set
、刪除delete
,rmr
Zxid是一個64位的數字,高32位表示紀元,從1開始,每次選舉出一個新的leader
,就會遞增1;低32位是當前紀元維護的單調遞增的數字,一樣從1開始。
cZxid
:建立的事務標識。ctime
:建立的時間戳mZxid
:修改的事務標識,每次修改操做(set
)後都會更新mZxid
和mtime
。mtime
:修改的時間戳pZxid
:直接子節點最後更新的事務標識,子節點有變化(建立create
、修改set
、刪除delete
,rmr
)時,都會更新pZxid
。cversion
:直接子節點的版本號。當子節點有變化(建立create
、修改set
、刪除delete
,rmr
)時,cversion
的值就會增長1。dataVersion
:節點數據的版本號,每次對節點進行修改操做(set
)後,dataVersion
的值都會增長1(即便設置的是相同的數據)。aclVersion
:節點ACL的版本號,每次節點的ACL進行變化時,aclVersion
的值就會增長1。ephemeralOwner
:當前節點是臨時節點(ephemeral node
)時,這個ephemeralOwner
的值是客戶端持有的session
id。dataLength
:節點存儲的數據長度,單位爲 B (字節)。numChildren
:直接子節點的個數。➜ zkCli.sh -server 127.0.0.1:2281 [zk: 127.0.0.1:2281(CONNECTED) 0] get / cZxid = 0x0 ctime = Thu Jan 01 08:00:00 CST 1970 mZxid = 0x0 mtime = Thu Jan 01 08:00:00 CST 1970 pZxid = 0x0 cversion = -1 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 0 numChildren = 1
默認根節點 / 和 /zookeeper 是存在,所以 cZxid 是 0x0。
[zk: 127.0.0.1:2281(CONNECTED) 1] ls / [zookeeper] [zk: 127.0.0.1:2281(CONNECTED) 2] create /test "hello" Created /test [zk: 127.0.0.1:2281(CONNECTED) 3] ls / [zookeeper, test]
當建立了一個 /test 節點後,根節點的子節點就多出來了。
[zk: 127.0.0.1:2281(CONNECTED) 4] get /test hello cZxid = 0x100000002 ctime = Sat May 23 15:43:10 CST 2020 mZxid = 0x100000002 mtime = Sat May 23 15:43:10 CST 2020 pZxid = 0x100000002 cversion = 0 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 5 numChildren = 0
爲何cZxid
高32位是 0x1 代表了當前紀元爲第一代,低32位是00000002 代表了當前紀元第2筆事務操做建立了 /test 節點。
爲何是2呢?由於咱們是經過 zkCli.sh 客戶端鏈接到Server
的,這裏會消耗一次 Zxid。
[zk: 127.0.0.1:2281(CONNECTED) 5] set /test "hello world" cZxid = 0x100000002 ctime = Sat May 23 15:43:10 CST 2020 mZxid = 0x100000003 mtime = Sat May 23 15:43:41 CST 2020 pZxid = 0x100000002 cversion = 0 dataVersion = 1 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 11 numChildren = 0
修改 /test 節點數據,mZxid
,mtime
和 dataVersion
發生了變化, dataLength
變爲了( "hello world"佔用了11個字節)。
[zk: 127.0.0.1:2281(CONNECTED) 6] create /test/a "" Created /test/a [zk: 127.0.0.1:2281(CONNECTED) 7] get /test hello world cZxid = 0x100000002 ctime = Sat May 23 15:43:10 CST 2020 mZxid = 0x100000003 mtime = Sat May 23 15:43:41 CST 2020 pZxid = 0x100000004 cversion = 1 dataVersion = 1 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 11 numChildren = 1
建立 子節點 /test/a,咱們查看 /test 節點屬性,發現 pZxid
,cversion
, numChildren
都發生了變化。
[zk: 127.0.0.1:2281(CONNECTED) 8] get /test/a cZxid = 0x100000004 ctime = Sat May 23 15:44:12 CST 2020 mZxid = 0x100000004 mtime = Sat May 23 15:44:12 CST 2020 pZxid = 0x100000004 cversion = 0 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 0 numChildren = 0
查看 /test/a 節點屬性,發現 cZxid
與 父節點的 pZxid
是一致的,證明了 pZxid
是直接子節點最後更新的事務標識。
ZooKeeper支持 Watch。客戶端能夠在znode上設置 Watch。
znode更改時,將觸發並刪除監視。觸發監視後,客戶端會收到一個數據包,說明znode已更改。
若是客戶端與其中一個ZooKeeper服務器之間的鏈接斷開,則客戶端將收到本地通知。
3.6.0中的新增功能:
客戶端還能夠在znode上設置永久性的遞歸監視,這些監視在觸發時不會刪除,而且會以遞歸方式觸發註冊znode以及全部子znode的更改。
支持 Watch的 客戶端命令:
stat path [watch]
ls path [watch]
ls2 path [watch]
get path [watch]
[zk: 127.0.0.1:2281(CONNECTED) 3] get /test/d watch cZxid = 0x100000013 ctime = Sat May 23 16:47:41 CST 2020 mZxid = 0x100000013 mtime = Sat May 23 16:47:41 CST 2020 pZxid = 0x100000013 cversion = 0 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x0 dataLength = 0 numChildren = 0
此時使用另一個客戶端去更改 /test/d 節點的數據,咱們就能夠看到原來的客戶端自動收到了一個WATCHER 通知。
[zk: 127.0.0.1:2281(CONNECTED) 4] WATCHER:: WatchedEvent state:SyncConnected type:NodeDataChanged path:/test/d
@SvenAugustus( https://www.flysium.xyz/)
更多請關注微信公衆號【編程不離宗】,專一於分享服務器開發與編程相關的技術乾貨: