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和端口
評(píng)論
圖片
表情
