首頁(yè) 猿問(wèn) java客戶端連接zookeepe...

java客戶端連接zookeeper集群時(shí)如何才能避開(kāi)失效的服務(wù)器

JavaScript

慕運(yùn)維8079593 2019-04-16 20:27:49

集群模式下，比如我有3個(gè)zookeeper服務(wù)器，分別是zk1,zk2,zk3，zookeeper兌現(xiàn)創(chuàng)建時(shí)連接串寫(xiě)法是zk1:2181,zk2:2181,zk3:2181，按照zk的選舉算法，只要有超過(guò)半數(shù)的節(jié)點(diǎn)活著集群就能工作。但是如果這時(shí)客戶端剛開(kāi)始初始化，但是zk1掛了，會(huì)使用zk1的服務(wù)器配置去創(chuàng)建連接，從而報(bào)連接被拒絕的異常以致啟動(dòng)退出。這里有什么優(yōu)雅的方法能在啟動(dòng)階段讓zookeeper自動(dòng)避開(kāi)已經(jīng)失效的節(jié)點(diǎn)去選擇有效的節(jié)點(diǎn)去連接么？

查看完整描述

2 回答

神不在的星期二

TA貢獻(xiàn)1963條經(jīng)驗(yàn) 獲得超6個(gè)贊

找到一個(gè)辦法，由于zk的連接是異步創(chuàng)建的，可以在zookeeper對(duì)象new之后等待一下，同時(shí)判斷state是否為connected，上代碼：if(!zk.getState().equals(States.CONNECTED)){while(true){if(zk.getState().equals(States.CONNECTED)){break;}try{TimeUnit.SECONDS.sleep(5);}catch(InterruptedExceptione){e.printStackTrace();}}}

反對(duì) 回復(fù) 2019-04-16

元芳怎么了

TA貢獻(xiàn)1798條經(jīng)驗(yàn) 獲得超7個(gè)贊

怎么不好好看文檔呢》Tocreateaclientsessiontheapplicationcodemustprovideaconnectionstringcontainingacommaseparatedlistofhost:portpairs,eachcorrespondingtoaZooKeeperserver(e.g."127.0.0.1:4545"or"127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002").TheZooKeeperclientlibrarywillpickanarbitraryserverandtrytoconnecttoit.Ifthisconnectionfails,oriftheclientbecomesdisconnectedfromtheserverforanyreason,theclientwillautomaticallytrythenextserverinthelist,untilaconnectionis(re-)established.另外你知道zk有個(gè)玩意叫watcher嗎，自己檢測(cè)連接也是逗

反對(duì) 回復(fù) 2019-04-16