{"id":833,"date":"2018-07-20T08:39:46","date_gmt":"2018-07-20T00:39:46","guid":{"rendered":"https:\/\/blog.jsjs.org\/?p=833"},"modified":"2018-07-20T08:39:46","modified_gmt":"2018-07-20T00:39:46","slug":"%e3%80%90%e5%88%86%e5%b8%83%e5%bc%8f%e3%80%91zookeeper%e4%bd%bf%e7%94%a8-%e5%bc%80%e6%ba%90%e5%ae%a2%e6%88%b7%e7%ab%af","status":"publish","type":"post","link":"https:\/\/blog.jsjs.org\/?p=833","title":{"rendered":"\u3010\u5206\u5e03\u5f0f\u3011Zookeeper\u4f7f\u7528–\u5f00\u6e90\u5ba2\u6237\u7aef"},"content":{"rendered":"

\u4e00\u3001\u524d\u8a00<\/strong><\/p>\n

\u4e0a\u4e00\u7bc7\u535a\u5ba2\u5df2\u7ecf\u4ecb\u7ecd\u4e86\u5982\u4f55\u4f7f\u7528Zookeeper\u63d0\u4f9b\u7684\u539f\u751f\u6001Java API\u8fdb\u884c\u64cd\u4f5c\uff0c\u672c\u7bc7\u535a\u6587\u4e3b\u8981\u8bb2\u89e3\u5982\u4f55\u901a\u8fc7\u5f00\u6e90\u5ba2\u6237\u7aef\u6765\u8fdb\u884c\u64cd\u4f5c\u3002<\/p>\n

\u4e8c\u3001ZkClient<\/strong><\/p>\n

ZkClient\u662f\u5728Zookeeper\u539f\u58f0API\u63a5\u53e3\u4e4b\u4e0a\u8fdb\u884c\u4e86\u5305\u88c5\uff0c\u662f\u4e00\u4e2a\u66f4\u6613\u7528\u7684Zookeeper\u5ba2\u6237\u7aef\uff0c\u5176\u5185\u90e8\u8fd8\u5b9e\u73b0\u4e86\u8bf8\u5982Session\u8d85\u65f6\u91cd\u8fde\u3001Watcher\u53cd\u590d\u6ce8\u518c\u7b49\u529f\u80fd\u3002<\/p>\n

2.1 \u6dfb\u52a0\u4f9d\u8d56<\/p>\n

\u5728pom.xml\u6587\u4ef6\u4e2d\u6dfb\u52a0\u5982\u4e0b\u5185\u5bb9\u5373\u53ef\u3002<\/p>\n

\n
        <dependency>\n            <groupId>com.101tec<\/groupId>\n            <artifactId>zkclient<\/artifactId>\n            <version>0.2<\/version>\n        <\/dependency><\/pre>\n<\/div>\n
2.2 \u521b\u5efa\u4f1a\u8bdd<\/p>\n
\u4f7f\u7528ZkClient\u53ef\u4ee5\u8f7b\u677e\u7684\u521b\u5efa\u4f1a\u8bdd\uff0c\u8fde\u63a5\u5230\u670d\u52a1\u7aef\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.zkclient.examples;\n\nimport java.io.IOException;\nimport org.I0Itec.zkclient.ZkClient;\n\npublic class Create_Session_Sample {\n    public static void main(String[] args) throws IOException, InterruptedException {\n        ZkClient zkClient = new ZkClient(\"127.0.0.1:2181\", 5000);\n        System.out.println(\"ZooKeeper session established.\");\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
ZooKeeper session established.<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u5df2\u7ecf\u6210\u529f\u521b\u5efa\u4f1a\u8bdd\u3002<\/p>\n
2.3 \u521b\u5efa\u8282\u70b9<\/p>\n
ZkClient\u63d0\u4f9b\u4e86\u9012\u5f52\u521b\u5efa\u8282\u70b9\u7684\u63a5\u53e3\uff0c\u5373\u5176\u5e2e\u52a9\u5f00\u53d1\u8005\u5b8c\u6210\u7236\u8282\u70b9\u7684\u521b\u5efa\uff0c\u518d\u521b\u5efa\u5b50\u8282\u70b9\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.zkclient.examples;\nimport org.I0Itec.zkclient.ZkClient;\n\npublic class Create_Node_Sample {\n    public static void main(String[] args) throws Exception {\n        ZkClient zkClient = new ZkClient(\"127.0.0.1:2181\", 5000);\n        String path = \"\/zk-book\/c1\";\n        zkClient.createPersistent(path, true);\n        System.out.println(\"success create znode.\");\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
success create znode.<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u5df2\u7ecf\u6210\u529f\u521b\u5efa\u4e86\u8282\u70b9\uff0c\u503c\u5f97\u6ce8\u610f\u7684\u662f\uff0c\u5728\u539f\u751f\u6001\u63a5\u53e3\u4e2d\u662f\u65e0\u6cd5\u521b\u5efa\u6210\u529f\u7684\uff08\u7236\u8282\u70b9\u4e0d\u5b58\u5728\uff09\uff0c\u4f46\u662f\u901a\u8fc7ZkClient\u53ef\u4ee5\u9012\u5f52\u7684\u5148\u521b\u5efa\u7236\u8282\u70b9\uff0c\u518d\u521b\u5efa\u5b50\u8282\u70b9\u3002<\/p>\n
\"\"<\/p>\n
\u53ef\u4ee5\u770b\u5230\u786e\u5b9e\u6210\u529f\u521b\u5efa\u4e86\/zk-book\u548c\/zk-book\/c1\u4e24\u4e2a\u8282\u70b9\u3002<\/p>\n
2.4 \u5220\u9664\u8282\u70b9<\/p>\n
ZkClient\u63d0\u4f9b\u4e86\u9012\u5f52\u5220\u9664\u8282\u70b9\u7684\u63a5\u53e3\uff0c\u5373\u5176\u5e2e\u52a9\u5f00\u53d1\u8005\u5148\u5220\u9664\u6240\u6709\u5b50\u8282\u70b9\uff08\u5b58\u5728\uff09\uff0c\u518d\u5220\u9664\u7236\u8282\u70b9\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.zkclient.examples;\n\nimport org.I0Itec.zkclient.ZkClient;\n\npublic class Del_Data_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\";\n        ZkClient zkClient = new ZkClient(\"127.0.0.1:2181\", 5000);\n        zkClient.createPersistent(path, \"\");\n        zkClient.createPersistent(path+\"\/c1\", \"\");\n        zkClient.deleteRecursive(path);\n        System.out.println(\"success delete znode.\");\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c:<\/p>\n
\n
success delete znode.<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660eZkClient\u53ef\u76f4\u63a5\u5220\u9664\u5e26\u5b50\u8282\u70b9\u7684\u7236\u8282\u70b9\uff0c\u56e0\u4e3a\u5176\u5e95\u5c42\u5148\u5220\u9664\u5176\u6240\u6709\u5b50\u8282\u70b9\uff0c\u7136\u540e\u518d\u5220\u9664\u7236\u8282\u70b9\u3002<\/p>\n
2.5 \u83b7\u53d6\u5b50\u8282\u70b9<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.zkclient.examples;\n\nimport java.util.List;\n\nimport org.I0Itec.zkclient.IZkChildListener;\nimport org.I0Itec.zkclient.ZkClient;\n\npublic class Get_Children_Sample {\n\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\";\n        ZkClient zkClient = new ZkClient(\"127.0.0.1:2181\", 5000);\n        zkClient.subscribeChildChanges(path, new IZkChildListener() {\n            public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {\n                System.out.println(parentPath + \" 's child changed, currentChilds:\" + currentChilds);\n            }\n        });\n\n        zkClient.createPersistent(path);\n        Thread.sleep(1000);\n        zkClient.createPersistent(path + \"\/c1\");\n        Thread.sleep(1000);\n        zkClient.delete(path + \"\/c1\");\n        Thread.sleep(1000);\n        zkClient.delete(path);\n        Thread.sleep(Integer.MAX_VALUE);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
\/zk-book 's child changed, currentChilds:[]\n\/zk-book 's child changed, currentChilds:[c1]\n\/zk-book 's child changed, currentChilds:[]\n\/zk-book 's child changed, currentChilds:null<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\uff1a<\/p>\n
\u5ba2\u6237\u7aef\u53ef\u4ee5\u5bf9\u4e00\u4e2a\u4e0d\u5b58\u5728\u7684\u8282\u70b9\u8fdb\u884c\u5b50\u8282\u70b9\u53d8\u66f4\u7684\u76d1\u542c\u3002<\/p>\n
\u4e00\u65e6\u5ba2\u6237\u7aef\u5bf9\u4e00\u4e2a\u8282\u70b9\u6ce8\u518c\u4e86\u5b50\u8282\u70b9\u5217\u8868\u53d8\u66f4\u76d1\u542c\u4e4b\u540e\uff0c\u90a3\u4e48\u5f53\u8be5\u8282\u70b9\u7684\u5b50\u8282\u70b9\u5217\u8868\u53d1\u751f\u53d8\u66f4\u65f6\uff0c\u670d\u52a1\u7aef\u90fd\u4f1a\u901a\u77e5\u5ba2\u6237\u7aef\uff0c\u5e76\u5c06\u6700\u65b0\u7684\u5b50\u8282\u70b9\u5217\u8868\u53d1\u9001\u7ed9\u5ba2\u6237\u7aef<\/p>\n
\u8be5\u8282\u70b9\u672c\u8eab\u7684\u521b\u5efa\u6216\u5220\u9664\u4e5f\u4f1a\u901a\u77e5\u5230\u5ba2\u6237\u7aef\u3002<\/p>\n
2.6 \u83b7\u53d6\u6570\u636e<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.zkclient.examples;\n\nimport org.I0Itec.zkclient.IZkDataListener;\nimport org.I0Itec.zkclient.ZkClient;\n\npublic class Get_Data_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\";\n        ZkClient zkClient = new ZkClient(\"127.0.0.1:2181\", 5000);\n        zkClient.createEphemeral(path, \"123\");\n\n        zkClient.subscribeDataChanges(path, new IZkDataListener() {\n            public void handleDataDeleted(String dataPath) throws Exception {\n                System.out.println(\"Node \" + dataPath + \" deleted.\");\n            }\n\n            public void handleDataChange(String dataPath, Object data) throws Exception {\n                System.out.println(\"Node \" + dataPath + \" changed, new data: \" + data);\n            }\n        });\n\n        System.out.println(zkClient.readData(path));\n        zkClient.writeData(path, \"456\");\n        Thread.sleep(1000);\n        zkClient.delete(path);\n        Thread.sleep(Integer.MAX_VALUE);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
123\nNode \/zk-book changed, new data: 456\nNode \/zk-book deleted.<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u53ef\u4ee5\u6210\u529f\u76d1\u542c\u8282\u70b9\u6570\u636e\u53d8\u5316\u6216\u5220\u9664\u4e8b\u4ef6\u3002<\/p>\n
2.7 \u68c0\u6d4b\u8282\u70b9\u662f\u5426\u5b58\u5728<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.zkclient.examples;\n\nimport org.I0Itec.zkclient.ZkClient;\n\npublic class Exist_Node_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\";\n        ZkClient zkClient = new ZkClient(\"127.0.0.1:2181\", 2000);\n        System.out.println(\"Node \" + path + \" exists \" + zkClient.exists(path));\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
Node \/zk-book exists false<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\uff0c\u53ef\u4ee5\u901a\u8fc7ZkClient\u8f7b\u6613\u68c0\u6d4b\u8282\u70b9\u662f\u5426\u5b58\u5728\uff0c\u5176\u76f8\u6bd4\u4e8e\u539f\u751f\u6001\u7684\u63a5\u53e3\u66f4\u6613\u4e8e\u7406\u89e3\u3002<\/p>\n
\u4e09\u3001Curator\u5ba2\u6237\u7aef<\/strong><\/p>\n
Curator\u89e3\u51b3\u4e86\u5f88\u591aZookeeper\u5ba2\u6237\u7aef\u975e\u5e38\u5e95\u5c42\u7684\u7ec6\u8282\u5f00\u53d1\u5de5\u4f5c\uff0c\u5305\u62ec\u8fde\u63a5\u91cd\u8fde\uff0c\u53cd\u590d\u6ce8\u518cWatcher\u548cNodeExistsException\u5f02\u5e38\u7b49\uff0c\u73b0\u5df2\u6210\u4e3aApache\u7684\u9876\u7ea7\u9879\u76ee\u3002<\/p>\n
3.1 \u6dfb\u52a0\u4f9d\u8d56<\/p>\n
\u5728pom.xml\u6587\u4ef6\u4e2d\u6dfb\u52a0\u5982\u4e0b\u5185\u5bb9\u5373\u53ef\u3002<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
        <!-- https:\/\/mvnrepository.com\/artifact\/org.apache.curator\/apache-curator -->\n        <dependency>\n            <groupId>org.apache.curator<\/groupId>\n            <artifactId>curator-framework<\/artifactId>\n            <version>2.4.2<\/version>\n        <\/dependency><\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n
3.2\u00a0\u521b\u5efa\u4f1a\u8bdd<\/p>\n
Curator\u9664\u4e86\u4f7f\u7528\u4e00\u822c\u65b9\u6cd5\u521b\u5efa\u4f1a\u8bdd\u5916\uff0c\u8fd8\u53ef\u4ee5\u4f7f\u7528fluent\u98ce\u683c\u8fdb\u884c\u521b\u5efa\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.RetryPolicy;\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\n\npublic class Create_Session_Sample {\n    public static void main(String[] args) throws Exception {\n        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);\n        CuratorFramework client = CuratorFrameworkFactory.newClient(\"127.0.0.1:2181\", 5000, 3000, retryPolicy);\n        client.start();\n        System.out.println(\"Zookeeper session1 established. \");\n        CuratorFramework client1 = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n                .sessionTimeoutMs(5000).retryPolicy(retryPolicy).namespace(\"base\").build();\n        client1.start();\n        System.out.println(\"Zookeeper session2 established. \");\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
Zookeeper session1 established.\nZookeeper session2 established.<\/pre>\n<\/div>\n
\u503c\u5f97\u6ce8\u610f\u7684\u662fsession2\u4f1a\u8bdd\u542b\u6709\u9694\u79bb\u547d\u540d\u7a7a\u95f4\uff0c\u5373\u5ba2\u6237\u7aef\u5bf9Zookeeper\u4e0a\u6570\u636e\u8282\u70b9\u7684\u4efb\u4f55\u64cd\u4f5c\u90fd\u662f\u76f8\u5bf9\/base\u76ee\u5f55\u8fdb\u884c\u7684\uff0c\u8fd9\u6709\u5229\u4e8e\u5b9e\u73b0\u4e0d\u540c\u7684Zookeeper\u7684\u4e1a\u52a1\u4e4b\u95f4\u7684\u9694\u79bb\u3002<\/p>\n
3.3 \u521b\u5efa\u8282\u70b9<\/p>\n
\u901a\u8fc7\u4f7f\u7528Fluent\u98ce\u683c\u7684\u63a5\u53e3\uff0c\u5f00\u53d1\u4eba\u5458\u53ef\u4ee5\u8fdb\u884c\u81ea\u7531\u7ec4\u5408\u6765\u5b8c\u6210\u5404\u79cd\u7c7b\u578b\u8282\u70b9\u7684\u521b\u5efa\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\n\npublic class Create_Node_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\/c1\";\n        CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n                .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n        client.start();\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).forPath(path, \"init\".getBytes());\n        System.out.println(\"success create znode: \" + path);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
success create znode: \/zk-book\/c1<\/pre>\n<\/div>\n
\u5176\u4e2d\uff0c\u4e5f\u521b\u5efa\u4e86\/zk-book\/c1\u7684\u7236\u8282\u70b9\/zk-book\u8282\u70b9\u3002<\/p>\n
3.4 \u5220\u9664\u8282\u70b9<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\nimport org.apache.zookeeper.data.Stat;\n\npublic class Del_Data_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\/c1\";\n        CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n                .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n        client.start();\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).forPath(path, \"init\".getBytes());\n        Stat stat = new Stat();\n        System.out.println(new String(client.getData().storingStatIn(stat).forPath(path)));\n        client.delete().deletingChildrenIfNeeded().withVersion(stat.getVersion()).forPath(path);\n        System.out.println(\"success delete znode \" + path);\n        Thread.sleep(Integer.MAX_VALUE);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
init\nsuccess delete znode \/zk-book\/c1<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u6210\u529f\u5220\u9664\/zk-book\/c1\u8282\u70b9\u3002<\/p>\n
3.5 \u83b7\u53d6\u6570\u636e<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\nimport org.apache.zookeeper.data.Stat;\n\npublic class Get_Data_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\";\n        CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n                .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n        client.start();\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).forPath(path, \"init\".getBytes());\n        Stat stat = new Stat();\n        System.out.println(new String(client.getData().storingStatIn(stat).forPath(path)));\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
init<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u6210\u529f\u83b7\u53d6\u4e86\u8282\u70b9\u7684\u6570\u636e\u3002<\/p>\n
3.6 \u66f4\u65b0\u6570\u636e<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\nimport org.apache.zookeeper.data.Stat;\n\npublic class Set_Data_Sample {\n    public static void main(String[] args) throws Exception {\n        String path = \"\/zk-book\";\n        CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n                .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n        client.start();\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).forPath(path, \"init\".getBytes());\n        Stat stat = new Stat();\n        client.getData().storingStatIn(stat).forPath(path);\n        System.out.println(\"Success set node for : \" + path + \", new version: \"\n                + client.setData().withVersion(stat.getVersion()).forPath(path).getVersion());\n        try {\n            client.setData().withVersion(stat.getVersion()).forPath(path);\n        } catch (Exception e) {\n            System.out.println(\"Fail set node due to \" + e.getMessage());\n        }\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
Success set node for : \/zk-book, new version: 1\nFail set node due to KeeperErrorCode = BadVersion for \/zk-book<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u5f53\u643a\u5e26\u6570\u636e\u7248\u672c\u4e0d\u4e00\u81f4\u65f6\uff0c\u65e0\u6cd5\u5b8c\u6210\u66f4\u65b0\u64cd\u4f5c\u3002<\/p>\n
3.7 \u5f02\u6b65\u63a5\u53e3<\/p>\n
\u5982\u540cZookeeper\u539f\u751fAPI\u63d0\u4f9b\u4e86\u5f02\u6b65\u63a5\u53e3\uff0cCurator\u4e5f\u63d0\u4f9b\u4e86\u5f02\u6b65\u63a5\u53e3\u3002\u5728Zookeeper\u4e2d\uff0c\u6240\u6709\u7684\u5f02\u6b65\u901a\u77e5\u4e8b\u4ef6\u5904\u7406\u90fd\u662f\u7531EventThread\u8fd9\u4e2a\u7ebf\u7a0b\u6765\u5904\u7406\u7684\uff0cEventThread\u7ebf\u7a0b\u7528\u4e8e\u4e32\u884c\u5904\u7406\u6240\u6709\u7684\u4e8b\u4ef6\u901a\u77e5\uff0c\u5176\u53ef\u4ee5\u4fdd\u8bc1\u5bf9\u4e8b\u4ef6\u5904\u7406\u7684\u987a\u5e8f\u6027\uff0c\u4f46\u662f\u4e00\u65e6\u78b0\u4e0a\u590d\u6742\u7684\u5904\u7406\u5355\u5143\uff0c\u4f1a\u6d88\u8017\u8fc7\u957f\u7684\u5904\u7406\u65f6\u95f4\uff0c\u4ece\u800c\u5f71\u54cd\u5176\u4ed6\u4e8b\u4ef6\u7684\u5904\u7406\uff0cCurator\u5141\u8bb8\u7528\u6237\u4f20\u5165Executor\u5b9e\u4f8b\uff0c\u8fd9\u6837\u53ef\u4ee5\u5c06\u6bd4\u8f83\u590d\u6742\u7684\u4e8b\u4ef6\u5904\u7406\u653e\u5230\u4e00\u4e2a\u4e13\u95e8\u7684\u7ebf\u7a0b\u6c60\u4e2d\u53bb\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport java.util.concurrent.CountDownLatch;\nimport java.util.concurrent.ExecutorService;\nimport java.util.concurrent.Executors;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.api.BackgroundCallback;\nimport org.apache.curator.framework.api.CuratorEvent;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\n\npublic class Create_Node_Background_Sample {\n    static String path = \"\/zk-book\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n    static CountDownLatch semaphore = new CountDownLatch(2);\n    static ExecutorService tp = Executors.newFixedThreadPool(2);\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        System.out.println(\"Main thread: \" + Thread.currentThread().getName());\n\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).inBackground(new BackgroundCallback() {\n            public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {\n                System.out.println(\"event[code: \" + event.getResultCode() + \", type: \" + event.getType() + \"]\" + \", Thread of processResult: \" + Thread.currentThread().getName());\n                System.out.println();\n                semaphore.countDown();\n            }\n        }, tp).forPath(path, \"init\".getBytes());\n\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).inBackground(new BackgroundCallback() {\n            public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {\n                System.out.println(\"event[code: \" + event.getResultCode() + \", type: \" + event.getType() + \"]\" + \", Thread of processResult: \" + Thread.currentThread().getName());\n                semaphore.countDown();\n            }\n        }).forPath(path, \"init\".getBytes());\n\n        semaphore.await();\n        tp.shutdown();\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
Main thread: main\nevent[code: -110, type: CREATE], Thread of processResult: main-EventThread\nevent[code: 0, type: CREATE], Thread of processResult: pool-3-thread-1<\/pre>\n<\/div>\n
\u5176\u4e2d\uff0c\u521b\u5efa\u8282\u70b9\u7684\u4e8b\u4ef6\u7531\u7ebf\u7a0b\u6c60\u81ea\u5df1\u5904\u7406\uff0c\u800c\u975e\u9ed8\u8ba4\u7ebf\u7a0b\u5904\u7406\u3002<\/p>\n
Curator\u9664\u4e86\u63d0\u4f9b\u5f88\u4fbf\u5229\u7684API\uff0c\u8fd8\u63d0\u4f9b\u4e86\u4e00\u4e9b\u5178\u578b\u7684\u5e94\u7528\u573a\u666f\uff0c\u5f00\u53d1\u4eba\u5458\u53ef\u4ee5\u4f7f\u7528\u53c2\u8003\u66f4\u597d\u7684\u7406\u89e3\u5982\u4f55\u4f7f\u7528Zookeeper\u5ba2\u6237\u7aef\uff0c\u6240\u6709\u7684\u90fd\u5728recipes\u5305\u4e2d\uff0c\u53ea\u9700\u8981\u5728pom.xml\u4e2d\u6dfb\u52a0\u5982\u4e0b\u4f9d\u8d56\u5373\u53ef<\/p>\n
\n
<dependency>\n   <groupId>org.apache.curator<\/groupId>\n   <artifactId>curator-recipes<\/artifactId>\n   <version>2.4.2<\/version>\n<\/dependency><\/pre>\n<\/div>\n
3.8 \u8282\u70b9\u76d1\u542c<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.recipes.cache.NodeCache;\nimport org.apache.curator.framework.recipes.cache.NodeCacheListener;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\n\npublic class NodeCache_Sample {\n    static String path = \"\/zk-book\/nodecache\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        client.create().creatingParentsIfNeeded().withMode(CreateMode.EPHEMERAL).forPath(path, \"init\".getBytes());\n        final NodeCache cache = new NodeCache(client, path, false);\n        cache.start(true);\n        cache.getListenable().addListener(new NodeCacheListener() {\n            public void nodeChanged() throws Exception {\n                System.out.println(\"Node data update, new data: \" + new String(cache.getCurrentData().getData()));\n            }\n        });\n        client.setData().forPath(path, \"u\".getBytes());\n        Thread.sleep(1000);\n        client.delete().deletingChildrenIfNeeded().forPath(path);\n        Thread.sleep(Integer.MAX_VALUE);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
Node data update, new data: u<\/pre>\n<\/div>\n
\u5f53\u8282\u70b9\u6570\u636e\u53d8\u66f4\u540e\u6536\u5230\u4e86\u901a\u77e5\u3002NodeCache\u4e0d\u4ec5\u53ef\u4ee5\u76d1\u542c\u6570\u636e\u8282\u70b9\u7684\u5185\u5bb9\u53d8\u66f4\uff0c\u4e5f\u80fd\u76d1\u542c\u6307\u5b9a\u8282\u70b9\u662f\u5426\u5b58\u5728\u3002<\/p>\n
3.9 \u5b50\u8282\u70b9\u76d1\u542c<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.recipes.cache.PathChildrenCache;\nimport org.apache.curator.framework.recipes.cache.PathChildrenCache.StartMode;\nimport org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;\nimport org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.zookeeper.CreateMode;\n\npublic class PathChildrenCache_Sample {\n    static String path = \"\/zk-book\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .retryPolicy(new ExponentialBackoffRetry(1000, 3)).sessionTimeoutMs(5000).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        PathChildrenCache cache = new PathChildrenCache(client, path, true);\n        cache.start(StartMode.POST_INITIALIZED_EVENT);\n        cache.getListenable().addListener(new PathChildrenCacheListener() {\n            public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception {\n                switch (event.getType()) {\n                case CHILD_ADDED:\n                    System.out.println(\"CHILD_ADDED,\" + event.getData().getPath());\n                    break;\n                case CHILD_UPDATED:\n                    System.out.println(\"CHILD_UPDATED,\" + event.getData().getPath());\n                    break;\n                case CHILD_REMOVED:\n                    System.out.println(\"CHILD_REMOVED,\" + event.getData().getPath());\n                    break;\n                default:\n                    break;\n                }\n            }\n        });\n        client.create().withMode(CreateMode.PERSISTENT).forPath(path);\n        Thread.sleep(1000);\n        client.create().withMode(CreateMode.PERSISTENT).forPath(path + \"\/c1\");\n        Thread.sleep(1000);\n        client.delete().forPath(path + \"\/c1\");\n        Thread.sleep(1000);\n        client.delete().forPath(path);\n        Thread.sleep(Integer.MAX_VALUE);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
CHILD_ADDED,\/zk-book\/c1\nCHILD_REMOVED,\/zk-book\/c1<\/pre>\n<\/div>\n
\u76d1\u542c\u8282\u70b9\u7684\u5b50\u8282\u70b9\uff0c\u5305\u62ec\u65b0\u589e\u3001\u6570\u636e\u53d8\u5316\u3001\u5220\u9664\u4e09\u7c7b\u4e8b\u4ef6\u3002<\/p>\n
3.10 Master\u9009\u4e3e<\/p>\n
\u501f\u52a9Zookeeper\uff0c\u5f00\u53d1\u8005\u53ef\u4ee5\u5f88\u65b9\u4fbf\u5730\u5b9e\u73b0Master\u9009\u4e3e\u529f\u80fd\uff0c\u5176\u5927\u4f53\u601d\u8def\u5982\u4e0b\uff1a\u9009\u62e9\u4e00\u4e2a\u6839\u8282\u70b9\uff0c\u5982\/master_select\uff0c\u591a\u53f0\u673a\u5668\u540c\u65f6\u5411\u8be5\u8282\u70b9\u521b\u5efa\u4e00\u4e2a\u5b50\u8282\u70b9\/master_select\/lock\uff0c\u5229\u7528Zookeeper\u7279\u6027\uff0c\u6700\u7ec8\u53ea\u6709\u4e00\u53f0\u673a\u5668\u80fd\u591f\u6210\u529f\u521b\u5efa\uff0c\u6210\u529f\u7684\u90a3\u53f0\u673a\u5668\u5c31\u662fMaster\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.recipes.leader.LeaderSelector;\nimport org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\n\npublic class Recipes_MasterSelect {\n    static String master_path = \"\/curator_recipes_master_path\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        LeaderSelector selector = new LeaderSelector(client, master_path, new LeaderSelectorListenerAdapter() {\n            public void takeLeadership(CuratorFramework client) throws Exception {\n                System.out.println(\"\u6210\u4e3aMaster\u89d2\u8272\");\n                Thread.sleep(3000);\n                System.out.println(\"\u5b8c\u6210Master\u64cd\u4f5c\uff0c\u91ca\u653eMaster\u6743\u5229\");\n            }\n        });\n        selector.autoRequeue();\n        selector.start();\n        Thread.sleep(Integer.MAX_VALUE);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
\u6210\u4e3aMaster\u89d2\u8272\n\u5b8c\u6210Master\u64cd\u4f5c\uff0c\u91ca\u653eMaster\u6743\u5229\n\u6210\u4e3aMaster\u89d2\u8272<\/pre>\n<\/div>\n
\u4ee5\u4e0a\u7ed3\u679c\u4f1a\u53cd\u590d\u5faa\u73af\uff0c\u5e76\u4e14\u5f53\u4e00\u4e2a\u5e94\u7528\u7a0b\u5e8f\u5b8c\u6210Master\u903b\u8f91\u540e\uff0c\u53e6\u5916\u4e00\u4e2a\u5e94\u7528\u7a0b\u5e8f\u7684\u76f8\u5e94\u65b9\u6cd5\u624d\u4f1a\u88ab\u8c03\u7528\uff0c\u5373\u5f53\u4e00\u4e2a\u5e94\u7528\u5b9e\u4f8b\u6210\u4e3aMaster\u540e\uff0c\u5176\u4ed6\u5e94\u7528\u5b9e\u4f8b\u4f1a\u8fdb\u5165\u7b49\u5f85\uff0c\u76f4\u5230\u5f53\u524dMaster\u6302\u4e86\u6216\u8005\u63a8\u51fa\u540e\u624d\u4f1a\u5f00\u59cb\u9009\u4e3eMaster\u3002<\/p>\n
3.11 \u5206\u5e03\u5f0f\u9501<\/p>\n
\u4e3a\u4e86\u4fdd\u8bc1\u6570\u636e\u7684\u4e00\u81f4\u6027\uff0c\u7ecf\u5e38\u5728\u7a0b\u5e8f\u7684\u67d0\u4e2a\u8fd0\u884c\u70b9\u9700\u8981\u8fdb\u884c\u540c\u6b65\u63a7\u5236\u3002\u4ee5\u6d41\u6c34\u53f7\u751f\u6210\u573a\u666f\u4e3a\u4f8b\uff0c\u666e\u901a\u7684\u540e\u53f0\u5e94\u7528\u901a\u5e38\u91c7\u7528\u65f6\u95f4\u6233\u65b9\u5f0f\u6765\u751f\u6210\u6d41\u6c34\u53f7\uff0c\u4f46\u662f\u5728\u7528\u6237\u91cf\u975e\u5e38\u5927\u7684\u60c5\u51b5\u4e0b\uff0c\u53ef\u80fd\u4f1a\u51fa\u73b0\u5e76\u53d1\u95ee\u9898\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport java.text.SimpleDateFormat;\nimport java.util.Date;\nimport java.util.concurrent.CountDownLatch;\n\npublic class Recipes_NoLock {\n    public static void main(String[] args) throws Exception {\n        final CountDownLatch down = new CountDownLatch(1);\n        for (int i = 0; i < 10; i++) {\n            new Thread(new Runnable() {\n                public void run() {\n                    try {\n                        down.await();\n                    } catch (Exception e) {\n                    }\n                    SimpleDateFormat sdf = new SimpleDateFormat(\"HH:mm:ss|SSS\");\n                    String orderNo = sdf.format(new Date());\n                    System.err.println(\"\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : \" + orderNo);\n                }\n            }).start();\n        }\n        down.countDown();\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|590\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|590\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|591\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|591\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|590\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|590\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|591\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|590\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|592\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:29:10|591<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n
\u7ed3\u679c\u8868\u793a\u8ba2\u5355\u53f7\u51fa\u73b0\u4e86\u91cd\u590d\uff0c\u5373\u666e\u901a\u7684\u65b9\u6cd5\u65e0\u6cd5\u6ee1\u8db3\u4e1a\u52a1\u9700\u8981\uff0c\u56e0\u4e3a\u5176\u672a\u8fdb\u884c\u6b63\u786e\u7684\u540c\u6b65\u3002\u53ef\u4ee5\u4f7f\u7528Curator\u6765\u5b9e\u73b0\u5206\u5e03\u5f0f\u9501\u529f\u80fd\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport java.text.SimpleDateFormat;\nimport java.util.Date;\nimport java.util.concurrent.CountDownLatch;\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.recipes.locks.InterProcessMutex;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\n\npublic class Recipes_Lock {\n    static String lock_path = \"\/curator_recipes_lock_path\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        final InterProcessMutex lock = new InterProcessMutex(client, lock_path);\n        final CountDownLatch down = new CountDownLatch(1);\n        for (int i = 0; i < 30; i++) {\n            new Thread(new Runnable() {\n                public void run() {\n                    try {\n                        down.await();\n                        lock.acquire();\n                    } catch (Exception e) {\n                    }\n                    SimpleDateFormat sdf = new SimpleDateFormat(\"HH:mm:ss|SSS\");\n                    String orderNo = sdf.format(new Date());\n                    System.out.println(\"\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : \" + orderNo);\n                    try {\n                        lock.release();\n                    } catch (Exception e) {\n                    }\n                }\n            }).start();\n        }\n        down.countDown();\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:50|293\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:50|319\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|278\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|326\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|402\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|420\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|546\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|602\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|626\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|656\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|675\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|701\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|708\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|732\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|763\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|785\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|805\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|823\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|839\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|853\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|868\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|884\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|897\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|910\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|926\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|939\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|951\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|965\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|972\n\u751f\u6210\u7684\u8ba2\u5355\u53f7\u662f : 16:31:51|983<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u6b64\u65f6\u5df2\u7ecf\u4e0d\u5b58\u5728\u91cd\u590d\u7684\u6d41\u6c34\u53f7\u3002<\/p>\n
3.12 \u5206\u5e03\u5f0f\u8ba1\u6570\u5668<\/p>\n
\u5206\u5e03\u5f0f\u8ba1\u6570\u5668\u7684\u5178\u578b\u5e94\u7528\u662f\u7edf\u8ba1\u7cfb\u7edf\u7684\u5728\u7ebf\u4eba\u6570\uff0c\u501f\u52a9Zookeeper\u4e5f\u53ef\u4ee5\u5f88\u65b9\u4fbf\u5b9e\u73b0\u5206\u5e03\u5f0f\u8ba1\u6570\u5668\u529f\u80fd\uff1a\u6307\u5b9a\u4e00\u4e2aZookeeper\u6570\u636e\u8282\u70b9\u4f5c\u4e3a\u8ba1\u6570\u5668\uff0c\u591a\u4e2a\u5e94\u7528\u5b9e\u4f8b\u5728\u5206\u5e03\u5f0f\u9501\u7684\u63a7\u5236\u4e0b\uff0c\u901a\u8fc7\u66f4\u65b0\u8282\u70b9\u7684\u5185\u5bb9\u6765\u5b9e\u73b0\u8ba1\u6570\u529f\u80fd\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.recipes.atomic.AtomicValue;\nimport org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.curator.retry.RetryNTimes;\n\npublic class Recipes_DistAtomicInt {\n    static String distatomicint_path = \"\/curator_recipes_distatomicint_path\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        DistributedAtomicInteger atomicInteger = new DistributedAtomicInteger(client, distatomicint_path,\n                new RetryNTimes(3, 1000));\n        AtomicValue<Integer> rc = atomicInteger.add(8);\n        System.out.println(\"Result: \" + rc.succeeded());\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
Result: true<\/pre>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u5df2\u7ecf\u5c06\u6570\u636e\u6210\u529f\u5199\u5165\u6570\u636e\u8282\u70b9\u4e2d\u3002<\/p>\n
3.13 \u5206\u5e03\u5f0fBarrier<\/p>\n
\u5982\u540cJDK\u7684CyclicBarrier\uff0cCurator\u63d0\u4f9b\u4e86DistributedBarrier\u6765\u5b9e\u73b0\u5206\u5e03\u5f0fBarrier\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.framework.recipes.barriers.DistributedBarrier;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\n\npublic class Recipes_Barrier {\n    static String barrier_path = \"\/curator_recipes_barrier_path\";\n    static DistributedBarrier barrier;\n\n    public static void main(String[] args) throws Exception {\n        for (int i = 0; i < 5; i++) {\n            new Thread(new Runnable() {\n                public void run() {\n                    try {\n                        CuratorFramework client = CuratorFrameworkFactory.builder()\n                                .connectString(\"127.0.0.1:2181\")\n                                .retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n                        client.start();\n                        barrier = new DistributedBarrier(client, barrier_path);\n                        System.out.println(Thread.currentThread().getName() + \"\u53f7barrier\u8bbe\u7f6e\");\n                        barrier.setBarrier();\n                        barrier.waitOnBarrier();\n                        System.err.println(\"\u542f\u52a8...\");\n                    } catch (Exception e) {\n                    }\n                }\n            }).start();\n        }\n        Thread.sleep(2000);\n        barrier.removeBarrier();\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
Thread-1\u53f7barrier\u8bbe\u7f6e\nThread-2\u53f7barrier\u8bbe\u7f6e\nThread-4\u53f7barrier\u8bbe\u7f6e\nThread-3\u53f7barrier\u8bbe\u7f6e\nThread-0\u53f7barrier\u8bbe\u7f6e\n\u542f\u52a8...\n\u542f\u52a8...\n\u542f\u52a8...\n\u542f\u52a8...\n\u542f\u52a8...<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n
\u7ed3\u679c\u8868\u660e\u901a\u8fc7DistributedBarrier\u53ef\u4ee5\u5b9e\u73b0\u7c7b\u4f3c\u4e8eCyclicBarrier\u7684\u5206\u5e03\u5f0fBarrier\u529f\u80fd\u3002<\/p>\n
\u56db\u3001Curator\u5de5\u5177\u7c7b<\/strong><\/p>\n
4.1 ZKPaths<\/p>\n
\u5176\u63d0\u4f9b\u4e86\u7b80\u5355\u7684API\u6765\u6784\u5efaznode\u8def\u5f84\u3001\u9012\u5f52\u521b\u5efa\u3001\u5220\u9664\u8282\u70b9\u7b49\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.curator.utils.ZKPaths;\nimport org.apache.curator.utils.ZKPaths.PathAndNode;\nimport org.apache.zookeeper.ZooKeeper;\n\npublic class ZKPaths_Sample {\n    static String path = \"\/curator_zkpath_sample\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        ZooKeeper zookeeper = client.getZookeeperClient().getZooKeeper();\n\n        System.out.println(ZKPaths.fixForNamespace(path, \"sub\"));\n        System.out.println(ZKPaths.makePath(path, \"sub\"));\n        System.out.println(ZKPaths.getNodeFromPath(\"\/curator_zkpath_sample\/sub1\"));\n\n        PathAndNode pn = ZKPaths.getPathAndNode(\"\/curator_zkpath_sample\/sub1\");\n        System.out.println(pn.getPath());\n        System.out.println(pn.getNode());\n\n        String dir1 = path + \"\/child1\";\n        String dir2 = path + \"\/child2\";\n        ZKPaths.mkdirs(zookeeper, dir1);\n        ZKPaths.mkdirs(zookeeper, dir2);\n        System.out.println(ZKPaths.getSortedChildren(zookeeper, path));\n\n        ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
\u8fd0\u884c\u7ed3\u679c\uff1a<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
\/curator_zkpath_sample\/sub\n\/curator_zkpath_sample\/sub\nsub1\n\/curator_zkpath_sample\nsub1\n[child1, child2]<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n
\u501f\u52a9ZKPaths\u53ef\u5feb\u901f\u65b9\u4fbf\u7684\u5b8c\u6210\u8282\u70b9\u7684\u521b\u5efa\u7b49\u64cd\u4f5c\u3002<\/p>\n
4.2 EnsurePath<\/p>\n
\u5176\u63d0\u4f9b\u4e86\u4e00\u79cd\u80fd\u591f\u786e\u4fdd\u6570\u636e\u8282\u70b9\u5b58\u5728\u7684\u673a\u5236\uff0c\u5f53\u4e0a\u5c42\u4e1a\u52a1\u5e0c\u671b\u5bf9\u4e00\u4e2a\u6570\u636e\u8282\u70b9\u8fdb\u884c\u64cd\u4f5c\u65f6\uff0c\u64cd\u4f5c\u524d\u9700\u8981\u786e\u4fdd\u8be5\u8282\u70b9\u5b58\u5728\u3002<\/p>\n
\"\"<\/p>\n
\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n
package com.hust.grid.leesf.curator.examples;\n\nimport org.apache.curator.framework.CuratorFramework;\nimport org.apache.curator.framework.CuratorFrameworkFactory;\nimport org.apache.curator.retry.ExponentialBackoffRetry;\nimport org.apache.curator.utils.EnsurePath;\n\npublic class EnsurePathDemo {\n    static String path = \"\/zk-book\/c1\";\n    static CuratorFramework client = CuratorFrameworkFactory.builder().connectString(\"127.0.0.1:2181\")\n            .sessionTimeoutMs(5000).retryPolicy(new ExponentialBackoffRetry(1000, 3)).build();\n\n    public static void main(String[] args) throws Exception {\n        client.start();\n        client.usingNamespace(\"zk-book\");\n\n        EnsurePath ensurePath = new EnsurePath(path);\n        ensurePath.ensure(client.getZookeeperClient());\n        ensurePath.ensure(client.getZookeeperClient());\n\n        EnsurePath ensurePath2 = client.newNamespaceAwareEnsurePath(\"\/c1\");\n        ensurePath2.ensure(client.getZookeeperClient());\n    }\n}<\/pre>\n
\"\u590d\u5236\u4ee3\u7801\"<\/a><\/span><\/div>\n<\/div>\n<\/div>\n
EnsurePath\u91c7\u53d6\u4e86\u5982\u4e0b\u8282\u70b9\u521b\u5efa\u65b9\u5f0f\uff0c\u8bd5\u56fe\u521b\u5efa\u6307\u5b9a\u8282\u70b9\uff0c\u5982\u679c\u8282\u70b9\u5df2\u7ecf\u5b58\u5728\uff0c\u90a3\u4e48\u5c31\u4e0d\u8fdb\u884c\u4efb\u4f55\u64cd\u4f5c\uff0c\u4e5f\u4e0d\u5bf9\u5916\u629b\u51fa\u5f02\u5e38\uff0c\u5426\u5219\u6b63\u5e38\u521b\u5efa\u6570\u636e\u8282\u70b9\u3002<\/p>\n
\u4e94\u3001\u603b\u7ed3<\/strong><\/p>\n
\u672c\u7bc7\u4ecb\u7ecd\u4e86\u4f7f\u7528Zookeeper\u7684\u5f00\u6e90\u5ba2\u6237\u7aef\u5982\u4f55\u64cd\u4f5cZookeeper\u7684\u65b9\u6cd5\uff0c\u76f8\u5e94\u7684\u6e90\u7801\u4e5f\u5df2\u7ecf\u4e0a\u4f20\u81f3github<\/a>\uff0c\u8c22\u8c22\u5404\u4f4d\u56ed\u53cb\u7684\u89c2\u770b\uff5e<\/p>\n","protected":false},"excerpt":{"rendered":"
\u4e00\u3001\u524d\u8a00 \u4e0a\u4e00\u7bc7\u535a\u5ba2\u5df2\u7ecf\u4ecb\u7ecd\u4e86\u5982\u4f55\u4f7f\u7528Zookeeper\u63d0\u4f9b\u7684\u539f\u751f\u6001Java API\u8fdb\u884c\u64cd\u4f5c\uff0c\u672c\u7bc7\u535a\u6587\u4e3b\u8981\u8bb2\u89e3\u5982\u4f55\u901a\u8fc7\u5f00\u6e90\u5ba2\u6237\u7aef\u6765\u8fdb\u884c\u64cd\u4f5c\u3002 \u4e8c\u3001ZkClient ZkClient\u662f\u5728Zookeeper\u539f\u58f0API\u63a5\u53e3\u4e4b\u4e0a\u8fdb\u884c\u4e86\u5305\u88c5\uff0c\u662f\u4e00\u4e2a\u66f4\u6613\u7528\u7684Zookeeper\u5ba2\u6237\u7aef\uff0c\u5176\u5185\u90e8\u8fd8\u5b9e\u73b0\u4e86\u8bf8\u5982Session\u8d85\u65f6\u91cd\u8fde\u3001Watcher\u53cd\u590d\u6ce8\u518c\u7b49\u529f\u80fd\u3002 2.1 \u6dfb\u52a0\u4f9d\u8d56 \u5728pom.xml\u6587\u4ef6\u4e2d\u6dfb\u52a0\u5982\u4e0b\u5185\u5bb9\u5373\u53ef\u3002 <dependency> <groupId>com.101tec<\/groupId> <artifactId>zkclient<\/artifactId> <version>0.2<\/version> <\/dependency> 2.2 \u521b\u5efa\u4f1a\u8bdd \u4f7f\u7528ZkClient\u53ef\u4ee5\u8f7b\u677e\u7684\u521b\u5efa\u4f1a\u8bdd\uff0c\u8fde\u63a5\u5230\u670d\u52a1\u7aef\u3002 package com.hust.grid.leesf.zkclient.examples; import java.io.IOException; […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"site-sidebar-layout":"default","site-content-layout":"","ast-site-content-layout":"default","site-content-style":"default","site-sidebar-style":"default","ast-global-header-display":"","ast-banner-title-visibility":"","ast-main-header-display":"","ast-hfb-above-header-display":"","ast-hfb-below-header-display":"","ast-hfb-mobile-header-display":"","site-post-title":"","ast-breadcrumbs-content":"","ast-featured-img":"","footer-sml-layout":"","ast-disable-related-posts":"","theme-transparent-header-meta":"","adv-header-id-meta":"","stick-header-meta":"","header-above-stick-meta":"","header-main-stick-meta":"","header-below-stick-meta":"","astra-migrate-meta-layouts":"default","ast-page-background-enabled":"default","ast-page-background-meta":{"desktop":{"background-color":"var(--ast-global-color-5)","background-image":"","background-repeat":"repeat","background-position":"center center","background-size":"auto","background-attachment":"scroll","background-type":"","background-media":"","overlay-type":"","overlay-color":"","overlay-opacity":"","overlay-gradient":""},"tablet":{"background-color":"","background-image":"","background-repeat":"repeat","background-position":"center center","background-size":"auto","background-attachment":"scroll","background-type":"","background-media":"","overlay-type":"","overlay-color":"","overlay-opacity":"","overlay-gradient":""},"mobile":{"background-color":"","background-image":"","background-repeat":"repeat","background-position":"center center","background-size":"auto","background-attachment":"scroll","background-type":"","background-media":"","overlay-type":"","overlay-color":"","overlay-opacity":"","overlay-gradient":""}},"ast-content-background-meta":{"desktop":{"background-color":"var(--ast-global-color-4)","background-image":"","background-repeat":"repeat","background-position":"center center","background-size":"auto","background-attachment":"scroll","background-type":"","background-media":"","overlay-type":"","overlay-color":"","overlay-opacity":"","overlay-gradient":""},"tablet":{"background-color":"var(--ast-global-color-4)","background-image":"","background-repeat":"repeat","background-position":"center center","background-size":"auto","background-attachment":"scroll","background-type":"","background-media":"","overlay-type":"","overlay-color":"","overlay-opacity":"","overlay-gradient":""},"mobile":{"background-color":"var(--ast-global-color-4)","background-image":"","background-repeat":"repeat","background-position":"center center","background-size":"auto","background-attachment":"scroll","background-type":"","background-media":"","overlay-type":"","overlay-color":"","overlay-opacity":"","overlay-gradient":""}},"footnotes":""},"categories":[1],"tags":[],"class_list":["post-833","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"_links":{"self":[{"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=\/wp\/v2\/posts\/833","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=833"}],"version-history":[{"count":0,"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=\/wp\/v2\/posts\/833\/revisions"}],"wp:attachment":[{"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=833"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=833"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/blog.jsjs.org\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=833"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}