2019獨角獸企業重金招聘Python工程師標準>>>

1．? 搭建開發環境

(http://zookeeper.apache.org/)首先下載最新版 zookeeper-3.4.5.tar.gz解壓

2．? 然后進入conf目錄修改zoo_sample.cfg為zoo.cfg,并修改其中的內容

1.? #?The?number?of?milliseconds?of?each?tick??

2.? tickTime=2000??

3.? #?The?number?of?ticks?that?the?initial???

4.? #?synchronization?phase?can?take??

5.? initLimit=10??

6.? #?The?number?of?ticks?that?can?pass?between???

7.? #?sending?a?request?and?getting?an?acknowledgement??

8.? syncLimit=5??

9.? #?the?directory?where?the?snapshot?is?stored.??

10. #?do?not?use?/tmp?for?storage,?/tmp?here?is?just???

11. #?example?sakes.??

12. dataDir=/tmp/zookeeper??

13. #?the?port?at?which?the?clients?will?connect??

14. clientPort=2181??

15. #??

16. #?Be?sure?to?read?the?maintenance?section?of?the???

17. #?administrator?guide?before?turning?on?autopurge.??

18. #??

19. #?http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance??

20. #??

21. #?The?number?of?snapshots?to?retain?in?dataDir??

22. #autopurge.snapRetainCount=3??

23. #?Purge?task?interval?in?hours??

24. #?Set?to?"0"?to?disable?auto?purge?feature??

25. #autopurge.purgeInterval=1?

3．? 編輯保存后進入bin目錄執行,點擊zkServer.cmd

4．? 運行結果為一下表示運行成功.

5．? 創建Maven工程,修改pom.xml文件添加以下依賴jar包.

<dependency>

?????????? ??? <groupId>org.apache.zookeeper</groupId>

?????????? ??? <artifactId>zookeeper</artifactId>

?????????? ??? <version>3.4.4</version>

?????????? </dependency>

??????????

?????????? <dependency>

??????????????????? <groupId>com.netflix.curator</groupId>

??????????????????? <artifactId>curator-framework</artifactId>

??????????????????? <version>1.2.3</version>

?????????? </dependency>

??????????

?????????? <dependency>

??????????????????? <groupId>com.netflix.curator</groupId>

??????????????????? <artifactId>curator-recipes</artifactId>

?????????????????? <version>1.2.3</version>

?????????? </dependency>

??????????

?????????? <dependency>

??????????????????? <groupId>com.netflix.curator</groupId>

??????????????????? <artifactId>curator-test</artifactId>

??????????????????? <version>1.2.3</version>

?????????? </dependency>

??????????

?????????? <dependency>

??????????????????? <groupId>com.netflix.curator</groupId>

??????????????????? <artifactId>curator-x-discovery</artifactId>

??????????????????? <version>1.2.3</version>

?????????? </dependency>

??????????

?????????? <dependency>?

?????????? ??? <groupId>org.slf4j</groupId>?

?????????? ??? <artifactId>slf4j-log4j12</artifactId>?

?????????? ??? <version>1.7.2</version>?

?????????? </dependency>

?????????? ?

?????????? <dependency>

?????????? ??? <groupId>commons-logging</groupId>

?????????? ??? <artifactId>commons-logging</artifactId>

?????????? ??? <version>1.1.1</version>

?????????? </dependency>

6．? 編寫測試代碼

import org.apache.zookeeper.CreateMode;

import org.apache.zookeeper.ZooDefs.Ids;

import org.apache.zookeeper.ZooKeeper;

?

public class ZooKeeperTest {

?public static void main(String[] args) throws Exception{?

??????? ZooKeeper zk = new ZooKeeper("127.0.0.1:2181", 3000, null);?

??????? System.out.println("=========創建節點===========");?

??????? if(zk.exists("/test", false) == null)?

??????? {?

??????????? zk.create("/test", "znode1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);?

??????? }?

??????? System.out.println("=============查看節點是否安裝成功===============");?

??????? System.out.println(new String(zk.getData("/test", false, null)));?

?????????

??????? System.out.println("=========修改節點的數據==========");?

??????? zk.setData("/test", "zNode2".getBytes(), -1);?

??????? System.out.println("========查看修改的節點是否成功=========");?

??????? System.out.println(new String(zk.getData("/test", false, null)));?

?????????

??????? System.out.println("=======刪除節點==========");?

??????? zk.delete("/test", -1);?

??????? System.out.println("==========查看節點是否被刪除============");?

??? ????System.out.println("節點狀態：" + zk.exists("/test", false));?

??????? zk.close();?

??? }??

}

轉載于:https://my.oschina.net/u/2615530/blog/775296

總結

以上是生活随笔為你收集整理的zookeeper环境搭建以及测试的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。