锘??xml version="1.0" encoding="utf-8" standalone="yes"?>精品久久久久亚洲,亚洲AV福利天堂一区二区三,亚洲精品乱码久久久久久中文字幕 http://m.tkk7.com/BucketLi/every thing come from new! zh-cn Mon, 12 May 2025 05:41:30 GMT Mon, 12 May 2025 05:41:30 GMT 60 Google Megastore鍒濇帰 http://m.tkk7.com/BucketLi/archive/2011/02/14/344259.htmlBucketLI BucketLI Mon, 14 Feb 2011 04:44:00 GMT http://m.tkk7.com/BucketLi/archive/2011/02/14/344259.html http://m.tkk7.com/BucketLi/comments/344259.html http://m.tkk7.com/BucketLi/archive/2011/02/14/344259.html#Feedback 1 http://m.tkk7.com/BucketLi/comments/commentRss/344259.html http://m.tkk7.com/BucketLi/services/trackbacks/344259.html 鍘誨勾騫村簳 ,鍥㈤槦鍐呴儴鎴愬憳鍒嗕韓浜嗚繖綃?/span>google璁烘枃 ,鍒濊浜嗕笅 ,鍙戠幇鍏舵湁铔鏈夋剰鎬濈殑涓滆タ ,灝辨兂鎶婁粬緲昏瘧涓嬫潵 ,浣嗘槸緲昏瘧浜嗕竴灝忛儴鍒?/span>,鏄庢樉鎰熻濡傛灉榪欐牱鐨勭炕璇戝彂鍑哄幓 ,寰堝彲鑳借浜哄瓙寮?/span>,鎵浠ユ敼鎴愪簡姒傝寮忕殑鍗氭枃 ,榪欑瘒鏂囩珷浼氬皢鍘熻鏂囨渶鏍稿績鐨勫嚑涓儴鍒嗗仛涓嶅畬鍏ㄧ殑緲昏瘧鍜屼釜浜虹悊瑙?/span>,濡傛湁涓嶈В鎴栬呴敊璇殑鍦版柟 ,璇鋒煡鐪嬪師璁烘枃,騫跺笇鏈涜兘澶熸寚姝?璋㈣阿 .
姝f枃
Megastore鏄胺姝屼竴涓唴閮ㄧ殑瀛樺偍緋葷粺 ,瀹冪殑搴曞眰鏁版嵁瀛樺偍渚濊禆 Bigtable,涔熷氨鏄熀浜?/span>NoSql瀹炵幇鐨?/span>,浣嗘槸鍜屼紶緇熺殑 NoSql涓嶅悓鐨勬槸 ,瀹冨疄鐜頒簡綾諱技 RDBMS鐨勬暟鎹ā鍨?/span>(渚挎嵎鎬?/span>),鍚屾椂鎻愪緵鏁版嵁鐨勫己涓鑷存цВ鍐蟲柟妗?/span>(鍚屼竴涓?/span>datacenter,鍩轟簬 MVCC鐨勪簨鍔″疄鐜?/span>),騫朵笖灝嗘暟鎹繘琛岀粏棰楃矑搴︾殑鍒嗗尯 (榪欓噷鐨勫垎鍖烘槸鎸囧湪鍚屼竴涓?/span>datacenter,鎵鏈?/span>datacenter閮芥湁鐩稿悓鐨勫垎鍖烘暟鎹?/span>),鐒跺悗灝嗘暟鎹洿鏂板湪鏈烘埧闂磋繘琛屽悓姝ュ鍒?/span>(榪欎釜淇濊瘉鎵鏈?/span>datacenter涓殑鏁版嵁涓鑷?/span>).
...
涓枃緲昏瘧鍦板潃: http://wenku.baidu.com/view/a465cc260722192e4536f671.html#
鍘熸枃鍦板潃: http://wenku.baidu.com/view/2ddeb1afdd3383c4bb4cd2bb.html
]]>zookeeper浣跨敤鍜屽師鐞嗘帰絀訛紙涓錛?/title> http://m.tkk7.com/BucketLi/archive/2010/12/21/341268.htmlBucketLI BucketLI Tue, 21 Dec 2010 10:58:00 GMT http://m.tkk7.com/BucketLi/archive/2010/12/21/341268.html http://m.tkk7.com/BucketLi/comments/341268.html http://m.tkk7.com/BucketLi/archive/2010/12/21/341268.html#Feedback 15 http://m.tkk7.com/BucketLi/comments/commentRss/341268.html http://m.tkk7.com/BucketLi/services/trackbacks/341268.html zookeeper 浠嬬粛
zookeeper鏄竴涓負鍒嗗竷寮忓簲鐢ㄦ彁渚涗竴鑷存ф湇鍔$殑杞歡錛屽畠鏄紑婧愮殑 Hadoop欏圭洰涓殑涓涓瓙欏圭洰錛屽茍涓旀牴鎹?/span>google鍙戣〃鐨?/span><The Chubby lock service for loosely-coupled distributed systems>璁烘枃鏉ュ疄鐜扮殑錛屾帴涓嬫潵鎴戜滑棣栧厛鏉ュ畨瑁呬嬌鐢ㄤ笅榪欎釜杞歡錛岀劧鍚庡啀鏉ユ帰绱笅鍏朵腑姣旇緝閲嶈涓鑷存х畻娉曘?/span>
zookeeper瀹夎鍜屼嬌鐢?br />
zookeeper鐨勫畨瑁呭熀鏈笂鍙互鎸夌収 http://hadoop.apache.org/zookeeper/docs/current/ zookeeperStarted.html 榪欎釜欏甸潰涓婄殑姝ラ瀹屾垚瀹夎錛岃繖閲屼富瑕佷粙緇嶄笅閮ㄧ講涓涓泦緹ょ殑姝ラ錛屽洜涓鴻繖涓畼鏂歸〉闈技涔庤寰楀茍涓嶆槸闈炲父璇︾粏 (Running Replicated Zookeeper)銆?br />
鐢變簬鎵嬪ご鏈哄櫒涓嶈凍錛屾墍浠ュ湪涓鍙版満鍣ㄤ笂閮ㄧ講浜?/span>3涓?/span>server,濡傛灉浣犳墜澶翠篃姣旇緝绱э紝涔熷彲浠ヨ繖涔堝仛銆傞偅涔堟垜寤轟簡 3涓枃浠跺す錛屽涓?br />
server1 server2 server3
鐒跺悗姣忎釜鏂囦歡澶歸噷闈㈣В鍘嬩竴涓?/span>zookeeper鐨勪笅杞藉寘錛屽茍涓旇繕寤轟簡鍑犱釜鏂囦歡澶癸紝鎬諱綋緇撴瀯濡備笅 ,鏈鍚庨偅涓槸涓嬭澆榪囨潵鍘嬬緝鍖呯殑瑙e帇鏂囦歡
data dataLog logs zookeeper-3.3.2
閭d箞棣栧厛榪涘叆 data鐩綍錛屽垱寤轟竴涓?/span>myid鐨勬枃浠訛紝閲岄潰鍐欏叆涓涓暟瀛楋紝姣斿鎴戣繖涓槸 server1,閭d箞灝卞啓涓涓?/span>1錛?/span>server2瀵瑰簲 myid鏂囦歡灝卞啓鍏?/span>2錛?/span>server3瀵瑰簲myid鏂囦歡灝?span style="font-family: 瀹嬩綋">鍐欎釜 3
鐒跺悗榪涘叆 zookeeper-3.3.2/conf 鐩綍錛岄偅涔堝鏋滄槸鍒氫笅榪囨潵錛屼細鏈?/span>3涓枃浠訛紝 configuration.xml, log4j.properties,zoo_sample.cfg ,榪?/span>3涓枃浠舵垜浠鍏堣鍋氱殑灝辨槸鍦ㄨ繖涓洰褰曞垱寤轟竴涓?/span>zoo.cfg鐨勯厤緗枃浠訛紝褰撶劧浣犲彲浠ユ妸 zoo_sample.cfg鏂囦歡鏀規(guī)垚 zoo.cfg錛岄厤緗殑鍐呭濡備笅鎵紺猴細
tickTime=2000
initLimit=5
syncLimit=2
dataDir=xxxx/zookeeper/server1/data
dataLogDir=xxx/zookeeper/server1/dataLog
clientPort=2181
server.1=127.0.0.1:2888:3888
server.2=127.0.0.1:2889:3889
server.3=127.0.0.1:2890:3890
鏍囩孩鐨勫嚑涓厤緗簲璇ュ畼緗戣寰楀緢娓呮浜嗭紝鍙槸闇瑕佹敞鎰忕殑鏄?/span>clientPort榪欎釜绔彛濡傛灉浣犳槸鍦?/span>1鍙版満鍣ㄤ笂閮ㄧ講澶氫釜 server,閭d箞姣忓彴鏈哄櫒閮借涓嶅悓鐨?/span>clientPort錛屾瘮濡傛垜 server1鏄?/span>2181,server2鏄?/span>2182錛?/span>server3鏄?/span>2183錛?/span>dataDir鍜?/span>dataLogDir涔熼渶瑕佸尯鍒嗕笅銆?/span>
鏈鍚庡嚑琛屽敮涓闇瑕佹敞鎰忕殑鍦版柟灝辨槸 server.X 榪欎釜鏁板瓧灝辨槸瀵瑰簲 data/myid涓殑鏁板瓧銆備綘鍦?/span>3涓?/span>server鐨?/span>myid鏂囦歡涓垎鍒啓鍏ヤ簡 1錛?/span>2錛?/span>3錛岄偅涔堟瘡涓?/span>server涓殑 zoo.cfg閮介厤 server.1,server.2,server.3灝?/span>OK浜嗐傚洜涓哄湪鍚屼竴鍙版満鍣ㄤ笂錛屽悗闈㈣繛鐫鐨?/span>2涓鍙?/span>3涓?/span>server閮戒笉瑕佷竴鏍鳳紝鍚﹀垯绔彛鍐茬獊錛屽叾涓涓涓鍙g敤鏉ラ泦緹ゆ垚鍛樼殑淇℃伅浜ゆ崲錛岀浜屼釜绔彛鏄湪 leader鎸傛帀鏃朵笓闂ㄧ敤鏉ヨ繘琛岄変婦 leader鎵鐢ㄣ?br />
榪涘叆 zookeeper-3.3.2/bin 鐩綍涓?span style="font-family: 瀹嬩綋">錛?strong>./ zkServer.sh start 鍚姩涓涓?/span>server,榪欐椂浼氭姤澶ч噺閿欒錛熷叾瀹炴病浠涔堝叧緋伙紝鍥犱負鐜板湪闆嗙兢鍙搗浜?/span>1鍙?/span>server錛?/span>zookeeper鏈嶅姟鍣ㄧ璧鋒潵浼氭牴鎹?/span>zoo.cfg鐨勬湇鍔″櫒鍒楄〃鍙戣搗閫変婦 leader鐨勮姹傦紝鍥犱負榪炰笉涓婂叾浠栨満鍣ㄨ屾姤閿欙紝閭d箞褰撴垜浠搗絎簩涓?/span>zookeeper瀹炰緥鍚庯紝 leader灝嗕細琚夊嚭錛屼粠鑰屼竴鑷存ф湇鍔″紑濮嬪彲浠ヤ嬌鐢紝榪欐槸鍥犱負 3鍙版満鍣ㄥ彧瑕佹湁 2鍙板彲鐢ㄥ氨鍙互閫夊嚭 leader騫朵笖瀵瑰鎻愪緵鏈嶅姟 (2n+1鍙版満鍣紝鍙互瀹?/span>n鍙版満鍣ㄦ寕鎺?/span>)銆?br />
鎺ヤ笅鏉ュ氨鍙互浣跨敤浜嗭紝鎴戜滑鍙互鍏堥氳繃 zookeeper鑷甫鐨勫鎴風(fēng)浜や簰紼嬪簭鏉ョ畝鍗曟劅鍙椾笅 zookeeper鍒板簳鍋氫竴浜涗粈涔堜簨鎯呫傝繘鍏?/span>zookeeper-3.3.2/bin錛?/span>3涓?/span>server涓換鎰忎竴涓級涓嬶紝 ./zkCli.sh –server 127.0.0.1:2182 ,鎴戣繛鐨勬槸寮鐫 2182绔彛鐨勬満鍣ㄣ?br />
閭d箞錛岄鍏堟垜浠殢渚挎墦涓懡浠わ紝鍥犱負 zookeeper涓嶈璇嗭紝浠栦細緇欏嚭鍛戒護鐨?/span>help,濡備笅鍥?/span>
ls(鏌ョ湅褰撳墠鑺傜偣鏁版嵁 ),
ls2(鏌ョ湅褰撳墠鑺傜偣鏁版嵁騫惰兘鐪嬪埌鏇存柊嬈℃暟絳夋暟鎹?/span>) ,
create(鍒涘緩涓涓妭鐐?/span>) ,
get(寰楀埌涓涓妭鐐癸紝鍖呭惈鏁版嵁鍜屾洿鏂版鏁扮瓑鏁版嵁 ),
set(淇敼鑺傜偣 )
delete(鍒犻櫎涓涓妭鐐?/span>)
閫氳繃涓婅堪鍛戒護瀹炶返錛屾垜浠彲浠ュ彂鐜幫紝 zookeeper浣跨敤浜嗕竴涓被浼兼枃浠剁郴緇熺殑鏍?wèi)缁撴瀯锛屾暟鎹彲浠ユ寕鍦ㄦ煇涓妭鐐逛笂锛屽彲浠ュ杩欎釜鑺傜偣杩涜鍒犳攺V傚彟澶栨垜浠繕鍙戠幇錛屽綋鏀瑰姩涓涓妭鐐圭殑鏃跺欙紝闆嗙兢涓椿鐫鐨勬満鍣ㄩ兘浼氭洿鏂板埌涓鑷寸殑鏁版嵁銆?/span>
zookeeper 鐨勬暟鎹ā鍨?br />
鍦ㄧ畝鍗曚嬌鐢ㄤ簡 zookeeper涔嬪悗錛屾垜浠彂鐜板叾鏁版嵁妯″瀷鏈変簺鍍忔搷浣滅郴緇熺殑鏂囦歡緇撴瀯錛岀粨鏋勫涓嬪浘鎵紺?br />
(1) 姣忎釜鑺傜偣鍦?/span>zookeeper涓彨鍋?/span>znode,騫朵笖鍏舵湁涓涓敮涓鐨勮礬寰勬爣璇嗭紝濡?/span>/SERVER2鑺傜偣鐨勬爣璇嗗氨涓?/span>/APP3/SERVER2
(2) Znode鍙互鏈夊瓙 znode錛屽茍涓?/span>znode閲屽彲浠ュ瓨鏁版嵁錛屼絾鏄?/span>EPHEMERAL綾誨瀷鐨勮妭鐐逛笉鑳芥湁瀛愯妭鐐?br />
(3) Znode涓殑鏁版嵁鍙互鏈夊涓増鏈紝姣斿鏌愪竴涓礬寰勪笅瀛樻湁澶氫釜鏁版嵁鐗堟湰錛岄偅涔堟煡璇㈣繖涓礬寰勪笅鐨勬暟鎹氨闇瑕佸甫涓婄増鏈?br />
(4) znode 鍙互鏄復(fù)鏃惰妭鐐癸紝涓鏃﹀垱寤鴻繖涓?/span> znode 鐨勫鎴風(fēng)涓庢湇鍔″櫒澶卞幓鑱旂郴錛岃繖涓?/span> znode 涔熷皢鑷姩鍒犻櫎錛?/span>Zookeeper 鐨勫鎴風(fēng)鍜屾湇鍔″櫒閫氫俊閲囩敤闀胯繛鎺ユ柟寮忥紝姣忎釜瀹㈡埛绔拰 鏈嶅姟鍣ㄩ氳繃蹇冭煩鏉ヤ繚鎸佽繛鎺ワ紝榪欎釜榪炴帴鐘舵佺О涓?/span> session錛屽鏋?/span> znode 鏄復(fù)鏃惰妭鐐癸紝榪欎釜 session 澶辨晥錛?/span>znode 涔熷氨鍒犻櫎浜?br />
(5) znode 鐨勭洰褰曞悕鍙互鑷姩緙栧彿錛屽 App1 宸茬粡瀛樺湪錛屽啀鍒涘緩鐨勮瘽錛屽皢浼氳嚜鍔ㄥ懡鍚嶄負 App2
(6) znode 鍙互琚洃鎺э紝鍖呮嫭榪欎釜鐩綍鑺傜偣涓瓨鍌ㄧ殑鏁版嵁鐨勪慨鏀癸紝瀛愯妭鐐圭洰褰曠殑鍙樺寲絳夛紝涓鏃﹀彉鍖栧彲浠ラ氱煡璁劇疆鐩戞帶鐨勫鎴風(fēng)錛岃繖涓姛鑳芥槸 zookeeper瀵逛簬搴旂敤鏈閲嶈鐨勭壒鎬э紝閫氳繃榪欎釜鐗規(guī)у彲浠ュ疄鐜扮殑鍔熻兘鍖呮嫭閰嶇疆鐨勯泦涓鐞嗭紝闆嗙兢綆$悊錛屽垎甯冨紡閿佺瓑絳夈?/span>
閫氳繃 java浠g爜浣跨敤 zookeeper
Zookeeper 鐨勪嬌鐢ㄤ富瑕佹槸閫氳繃鍒涘緩鍏?/span>jar 鍖呬笅鐨?/span>Zookeeper 瀹炰緥錛屽茍涓旇皟鐢ㄥ叾鎺ュ彛鏂規(guī)硶榪涜鐨勶紝涓昏鐨勬搷浣滃氨鏄 znode 鐨勫鍒犳敼鎿嶄綔錛岀洃鍚?/span>znode 鐨勫彉鍖栦互鍙婂鐞嗐?/span>
浠ヤ笅涓轟富瑕佺殑 API 浣跨敤鍜岃В閲?/span>
// 鍒涘緩涓涓猌ookeeper瀹炰緥錛岀涓涓弬鏁頒負鐩爣鏈嶅姟鍣ㄥ湴鍧鍜岀鍙o紝絎簩涓弬鏁頒負Session瓚呮椂鏃墮棿錛岀涓変釜涓鴻妭鐐瑰彉鍖栨椂鐨勫洖璋冩柟娉?/span>
ZooKeeper zk = new ZooKeeper( " 127.0.0.1:2181 " , 500000 , new Watcher() {
// 鐩戞帶鎵鏈夎瑙﹀彂鐨勪簨浠?/span>
public void process(WatchedEvent event) {
// dosomething
}
} );
// 鍒涘緩涓涓妭鐐箁oot錛屾暟鎹槸mydata,涓嶈繘琛孉CL鏉冮檺鎺у埗錛岃妭鐐逛負姘鎬箙鎬х殑(鍗沖鎴風(fēng)shutdown浜嗕篃涓嶄細娑堝け)
zk.create( " /root " , " mydata " .getBytes(),Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
// 鍦╮oot涓嬮潰鍒涘緩涓涓猚hildone znode,鏁版嵁涓篶hildone,涓嶈繘琛孉CL鏉冮檺鎺у埗錛岃妭鐐逛負姘鎬箙鎬х殑
zk.create( " /root/childone " , " childone " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
// 鍙栧緱/root鑺傜偣涓嬬殑瀛愯妭鐐瑰悕縐?榪斿洖List<String>
zk.getChildren( " /root " , true );
// 鍙栧緱/root/childone鑺傜偣涓嬬殑鏁版嵁,榪斿洖byte[]
zk.getData( " /root/childone " , true , null );
// 淇敼鑺傜偣/root/childone涓嬬殑鏁版嵁錛岀涓変釜鍙傛暟涓虹増鏈紝濡傛灉鏄?1錛岄偅浼氭棤瑙嗚淇敼鐨勬暟鎹増鏈紝鐩存帴鏀規(guī)帀
zk.setData( " /root/childone " , " childonemodify " .getBytes(), - 1 );
// 鍒犻櫎/root/childone榪欎釜鑺傜偣錛岀浜屼釜鍙傛暟涓虹増鏈紝錛?鐨勮瘽鐩存帴鍒犻櫎錛屾棤瑙嗙増鏈?/span>
zk.delete( " /root/childone " , - 1 );
// 鍏抽棴session
zk.close();
Zookeeper 鐨勪富嫻佸簲鐢ㄥ満鏅疄鐜版濊礬錛堥櫎鍘誨畼鏂圭ず渚嬶級
(1)閰嶇疆綆$悊
闆嗕腑寮忕殑閰嶇疆綆$悊鍦ㄥ簲鐢ㄩ泦緹や腑鏄潪甯稿父瑙佺殑錛屼竴鑸晢涓氬叕鍙稿唴閮ㄩ兘浼氬疄鐜頒竴濂楅泦涓殑閰嶇疆綆$悊涓績錛屽簲瀵逛笉鍚岀殑搴旂敤闆嗙兢瀵逛簬鍏變韓鍚勮嚜閰嶇疆鐨勯渶姹傦紝騫朵笖鍦ㄩ厤緗彉鏇存椂鑳藉閫氱煡鍒伴泦緹や腑鐨勬瘡涓涓満鍣ㄣ?br />
Zookeeper寰堝鏄撳疄鐜拌繖縐嶉泦涓紡鐨勯厤緗鐞嗭紝姣斿灝?/span>APP1 鐨勬墍鏈夐厤緗厤緗埌 /APP1 znode 涓嬶紝 APP1 鎵鏈夋満鍣ㄤ竴鍚姩灝卞 /APP1 榪欎釜鑺傜偣榪涜鐩戞帶 (zk.exist( "/APP1" ,true)), 騫朵笖瀹炵幇鍥炶皟鏂規(guī)硶 Watcher 錛岄偅涔堝湪 zookeeper 涓?/span>/APP1 znode 鑺傜偣涓嬫暟鎹彂鐢熷彉鍖栫殑鏃跺欙紝姣忎釜鏈哄櫒閮戒細鏀跺埌閫氱煡錛?/span>Watcher 鏂規(guī)硶灝嗕細琚墽琛岋紝閭d箞搴旂敤鍐嶅彇涓嬫暟鎹嵆鍙?/span>(zk.getData( "/APP1",false,null ));
浠ヤ笂榪欎釜渚嬪瓙鍙槸綆鍗曠殑綺楅綺掑害閰嶇疆鐩戞帶錛岀粏棰楃矑搴︾殑鏁版嵁鍙互榪涜鍒嗗眰綰х洃鎺э紝榪欎竴鍒囬兘鏄彲浠ヨ璁″拰鎺у埗鐨勩?/span>
(2) 闆嗙兢綆$悊
搴旂敤闆嗙兢涓紝鎴戜滑甯稿父闇瑕佽姣忎竴涓満鍣ㄧ煡閬撻泦緹や腑錛堟垨渚濊禆鐨勫叾浠栨煇涓涓泦緹わ級鍝簺鏈哄櫒鏄椿鐫鐨勶紝騫朵笖鍦ㄩ泦緹ゆ満鍣ㄥ洜涓哄畷鏈猴紝緗戠粶鏂摼絳夊師鍥犺兘澶熶笉鍦ㄤ漢宸ヤ粙鍏ョ殑鎯呭喌涓嬭繀閫熼氱煡鍒版瘡涓涓満鍣ㄣ?br />
Zookeeper鍚屾牱寰堝鏄撳疄鐜拌繖涓姛鑳斤紝姣斿鎴戝湪 zookeeper 鏈嶅姟鍣ㄧ鏈変竴涓?/span>znode 鍙?/span>/APP1SERVERS, 閭d箞闆嗙兢涓瘡涓涓満鍣ㄥ惎鍔ㄧ殑鏃跺欓兘鍘昏繖涓妭鐐逛笅鍒涘緩涓涓?/span>EPHEMERAL 綾誨瀷鐨勮妭鐐癸紝姣斿 server1 鍒涘緩 /APP1SERVERS/SERVER1( 鍙互浣跨敤 ip, 淇濊瘉涓嶉噸澶?/span>) 錛?/span>server2 鍒涘緩 /APP1SERVERS/SERVER2 錛岀劧鍚?/span>SERVER1 鍜?/span>SERVER2 閮?/span>watch /APP1SERVERS 榪欎釜鐖惰妭鐐癸紝閭d箞涔熷氨鏄繖涓埗鑺傜偣涓嬫暟鎹垨鑰呭瓙鑺傜偣鍙樺寲閮戒細閫氱煡瀵硅鑺傜偣榪涜 watch 鐨勫鎴風(fēng)銆傚洜涓?/span>EPHEMERAL 綾誨瀷鑺傜偣鏈変竴涓緢閲嶈鐨勭壒鎬э紝灝辨槸瀹㈡埛绔拰鏈嶅姟鍣ㄧ榪炴帴鏂帀鎴栬?/span>session 榪囨湡灝變細浣胯妭鐐規(guī)秷澶憋紝閭d箞鍦ㄦ煇涓涓満鍣ㄦ寕鎺夋垨鑰呮柇閾劇殑鏃跺欙紝鍏跺搴旂殑鑺傜偣灝變細娑堝け錛岀劧鍚庨泦緹や腑鎵鏈夊 /APP1SERVERS 榪涜 watch 鐨勫鎴風(fēng)閮戒細鏀跺埌閫氱煡錛岀劧鍚庡彇寰楁渶鏂板垪琛ㄥ嵆鍙?br />
鍙﹀鏈変竴涓簲鐢ㄥ満鏅氨鏄泦緹ら?/span>master, 涓鏃?/span>master 鎸傛帀鑳藉椹笂鑳戒粠 slave 涓夊嚭涓涓?/span>master, 瀹炵幇姝ラ鍜屽墠鑰呬竴鏍鳳紝鍙槸鏈哄櫒鍦ㄥ惎鍔ㄧ殑鏃跺欏湪 APP1SERVERS 鍒涘緩鐨勮妭鐐圭被鍨嬪彉涓?/span>EPHEMERAL_SEQUENTIAL 綾誨瀷錛岃繖鏍鋒瘡涓妭鐐逛細鑷姩琚紪鍙鳳紝渚嬪
zk.create( " /testRootPath/testChildPath1 " , " 1 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
zk.create( " /testRootPath/testChildPath2 " , " 2 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
zk.create( " /testRootPath/testChildPath3 " , " 3 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
// 鍒涘緩涓涓瓙鐩綍鑺傜偣
zk.create( " /testRootPath/testChildPath4 " , " 4 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
System.out.println(zk.getChildren( " /testRootPath " , false ));
鎵撳嵃緇撴灉錛?/span> [testChildPath10000000000, testChildPath20000000001, testChildPath40000000003, testChildPath30000000002]
zk.create( " /testRootPath " , " testRootData " .getBytes(),Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
// 鍒涘緩涓涓瓙鐩綍鑺傜偣
zk.create( " /testRootPath/testChildPath1 " , " 1 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
zk.create( " /testRootPath/testChildPath2 " , " 2 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
zk.create( " /testRootPath/testChildPath3 " , " 3 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
// 鍒涘緩涓涓瓙鐩綍鑺傜偣
zk.create( " /testRootPath/testChildPath4 " , " 4 " .getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL);
System.out.println(zk.getChildren( " /testRootPath " , false ));
鎵撳嵃緇撴灉: [testChildPath2, testChildPath1, testChildPath4, testChildPath3]
鎴戜滑榛樿瑙勫畾緙栧彿鏈灝忕殑涓?/span>master, 鎵浠ュ綋鎴戜滑瀵?/span>/APP1SERVERS 鑺傜偣鍋氱洃鎺х殑鏃跺欙紝寰楀埌鏈嶅姟鍣ㄥ垪琛紝鍙鎵鏈夐泦緹ゆ満鍣ㄩ昏緫璁や負鏈灝忕紪鍙瘋妭鐐逛負 master 錛岄偅涔?/span>master 灝辮閫夊嚭錛岃岃繖涓?/span>master 瀹曟満鐨勬椂鍊欙紝鐩稿簲鐨?/span>znode 浼氭秷澶憋紝鐒跺悗鏂扮殑鏈嶅姟鍣ㄥ垪琛ㄥ氨琚帹閫佸埌瀹㈡埛绔紝鐒跺悗姣忎釜鑺傜偣閫昏緫璁や負鏈灝忕紪鍙瘋妭鐐逛負 master 錛岃繖鏍峰氨鍋氬埌鍔ㄦ?/span>master 閫変婦銆?br />
鎬葷粨
鎴戜滑鍒濇浣跨敤浜嗕竴涓?/span>zookeeper騫朵笖灝濊瘯鐫鎻忚堪浜嗗嚑縐嶅簲鐢ㄥ満鏅殑鍏蜂綋瀹炵幇鎬濊礬錛屾帴涓嬫潵鐨勬枃绔狅紝鎴戜滑浼氬皾璇曠潃鍘繪帰絀朵竴涓?/span>zookeeper鐨勯珮鍙敤鎬т笌 leaderElection綆楁硶銆?/span>
鍙傝?/strong>錛?/span>http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/
http://hadoop.apache.org/zookeeper/docs/current/
http://rdc.taobao.com/team/jm/archives/448
]]> JAVA綰跨▼姹犱唬鐮佹祬鏋?/title> http://m.tkk7.com/BucketLi/archive/2010/12/16/340295.htmlBucketLI BucketLI Thu, 16 Dec 2010 05:57:00 GMT http://m.tkk7.com/BucketLi/archive/2010/12/16/340295.html http://m.tkk7.com/BucketLi/comments/340295.html http://m.tkk7.com/BucketLi/archive/2010/12/16/340295.html#Feedback 0 http://m.tkk7.com/BucketLi/comments/commentRss/340295.html http://m.tkk7.com/BucketLi/services/trackbacks/340295.html 闃呰鍏ㄦ枃 ]]> JAVA騫跺彂瀹瑰櫒浠g爜闅忚 http://m.tkk7.com/BucketLi/archive/2010/11/25/335623.htmlBucketLI BucketLI Thu, 25 Nov 2010 05:43:00 GMT http://m.tkk7.com/BucketLi/archive/2010/11/25/335623.html http://m.tkk7.com/BucketLi/comments/335623.html http://m.tkk7.com/BucketLi/archive/2010/11/25/335623.html#Feedback 3 http://m.tkk7.com/BucketLi/comments/commentRss/335623.html http://m.tkk7.com/BucketLi/services/trackbacks/335623.html 闃呰鍏ㄦ枃 ]]> Log4j浠g爜闅忚 http://m.tkk7.com/BucketLi/archive/2010/10/22/335618.htmlBucketLI BucketLI Fri, 22 Oct 2010 02:40:00 GMT http://m.tkk7.com/BucketLi/archive/2010/10/22/335618.html http://m.tkk7.com/BucketLi/comments/335618.html http://m.tkk7.com/BucketLi/archive/2010/10/22/335618.html#Feedback 1 http://m.tkk7.com/BucketLi/comments/commentRss/335618.html http://m.tkk7.com/BucketLi/services/trackbacks/335618.html 闃呰鍏ㄦ枃 ]]> JAVA LOCK浠g爜嫻呮瀽 http://m.tkk7.com/BucketLi/archive/2010/09/30/333471.htmlBucketLI BucketLI Thu, 30 Sep 2010 04:05:00 GMT http://m.tkk7.com/BucketLi/archive/2010/09/30/333471.html http://m.tkk7.com/BucketLi/comments/333471.html http://m.tkk7.com/BucketLi/archive/2010/09/30/333471.html#Feedback 2 http://m.tkk7.com/BucketLi/comments/commentRss/333471.html http://m.tkk7.com/BucketLi/services/trackbacks/333471.html 闃呰鍏ㄦ枃 ]]> Netty浠g爜鍒嗘瀽 http://m.tkk7.com/BucketLi/archive/2010/09/25/332462.htmlBucketLI BucketLI Sat, 25 Sep 2010 04:10:00 GMT http://m.tkk7.com/BucketLi/archive/2010/09/25/332462.html http://m.tkk7.com/BucketLi/comments/332462.html http://m.tkk7.com/BucketLi/archive/2010/09/25/332462.html#Feedback 1 http://m.tkk7.com/BucketLi/comments/commentRss/332462.html http://m.tkk7.com/BucketLi/services/trackbacks/332462.html 闃呰鍏ㄦ枃 ]]>
主站蜘蛛池模板:
一区二区三区视频免费观看 |
无码A级毛片免费视频内谢 |
亚洲男人的天堂一区二区 |
久久精品国产免费一区 |
亚洲国产成人久久77 |
国产gav成人免费播放视频 |
fc2免费人成在线视频 |
91亚洲导航深夜福利 |
国产v片免费播放 |
中文字幕免费不卡二区 |
亚洲色无码专区一区 |
久久精品国产精品亚洲精品 |
免费H网站在线观看的 |
成年免费大片黄在线观看com |
久久亚洲精品人成综合网 |
国产精品二区三区免费播放心 |
永久在线观看免费视频 |
亚洲成av人无码亚洲成av人 |
亚洲AV无码国产精品麻豆天美
|
国产真人无码作爱视频免费 |
亚洲综合免费视频 |
亚洲国产一级在线观看 |
国产乱码免费卡1卡二卡3卡 |
精品免费久久久久国产一区
|
免费国产黄网站在线观看可以下载
|
久久精品私人影院免费看 |
亚洲欧美第一成人网站7777 |
亚洲国产精品一区二区成人片国内 |
日本最新免费不卡二区在线 |
99re热精品视频国产免费 |
深夜福利在线免费观看 |
亚洲成av人片不卡无码 |
日韩va亚洲va欧洲va国产 |
四虎在线播放免费永久视频
|
亚洲av高清在线观看一区二区 |
四虎在线视频免费观看视频 |
97人妻精品全国免费视频 |
曰批全过程免费视频免费看
|
成人网站免费观看 |
中文字幕在线观看免费视频
|
亚洲人成777在线播放 |