Guardian快速接入 Zookeeper

Guardian

讓你的程序快速接入Zookeeper來實(shí)現(xiàn)高可用

介紹

• 使用curator 連接zookeeper，保證連接質(zhì)量。

• 實(shí)時(shí)更新zookeeper的節(jié)點(diǎn)數(shù)據(jù)，保證消費(fèi)和生產(chǎn)一致。

• 實(shí)現(xiàn)了服務(wù)治理，目前提供了 隨機(jī) 和 輪詢兩種方式，后續(xù)會(huì)加入 權(quán)重 和 熔斷 兩種消費(fèi)方式。

• sample 是一個(gè)示例程序，歡迎大家下載使用。

使用介紹：

示例代碼：

//生產(chǎn)者，初始化注冊(cè)節(jié)點(diǎn)
ZookeeperRegistry zr = new ZookeeperRegistry ();
Zdata zdata = new Zdata();
zr.regist(zdata);


//消費(fèi)者，繼承ZookeeperDiscovery，等待回調(diào)

discover(Zdata provider);//可用的節(jié)點(diǎn)

destory();//一旦斷開zookeeper，消費(fèi)者也要斷開，保持一致


//消費(fèi)者如果成功消費(fèi)，需要告訴zookeeper
consume(Zdata provider, String host, int port)//提供消費(fèi)者是誰，以及自身的ip和端口