zookeeper入门之curator框架--原子性操作

电玩女神 2021-09-11 06:28 324阅读 0赞

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **package** com.git.zookeeper.passwordmanager.atomic;  
2.    
3.  **import** java.util.ArrayList;  
4.  **import** java.util.Collection;  
5.  **import** java.util.List;  
6.    
7.  **import** org.apache.curator.RetryPolicy;  
8.  **import** org.apache.curator.framework.CuratorFramework;  
9.  **import** org.apache.curator.framework.CuratorFrameworkFactory;  
10. **import** org.apache.curator.framework.api.ACLProvider;  
11. **import** org.apache.curator.framework.api.transaction.CuratorTransactionResult;  
12. **import** org.apache.curator.retry.RetryNTimes;  
13. **import** org.apache.zookeeper.ZooDefs.Perms;  
14. **import** org.apache.zookeeper.data.ACL;  
15. **import** org.apache.zookeeper.data.Id;  
16.   
17. /\*\* 
18.  \* 原子性操作的演示 
19.  \* @author songqinghu 
20.  \* 
21.  \*/  
22. **public** **class** AtomicZookeeperDemo \{  
23.   
24.     **public** **static** **void** main(String\[\] args) **throws** Exception \{  
25.           
26.         CuratorFramework client = getClient();  
27.         atomicCURD(client);  
28.     \}  
29.       
30.     /\*\* 
31.      \*  
32.      \* @描述：原子性操作完成curd   
33.      \* 测试失败的尝试 
34.      \* @param client 
35.      \* @return void 
36.      \* @exception 
37.      \* @createTime：2016年5月18日 
38.      \* @author: songqinghu 
39.      \* @throws Exception  
40.      \*/  
41.     **private** **static** **void** atomicCURD(CuratorFramework client) **throws** Exception\{  
42.         Collection<CuratorTransactionResult> resultone =**null**;  
43.         Collection<CuratorTransactionResult> resulttwo =**null**;  
44.         **try** \{  
45.            //成功!   
46.            resultone = client.inTransaction().create().forPath("/one", "one".getBytes()).and().check()  
47.                    .forPath("/one").and().create().forPath("/two").and().setData().forPath("/two", "two".getBytes())  
48.                    .and().delete().forPath("/one").and().commit();  
49.            //失败!  
50.            resulttwo = client.inTransaction().create().forPath("/test", "test".getBytes()).and().check()  
51.                    .forPath("/test").and().create().forPath("/two").and().setData().forPath("/two", "two".getBytes())  
52.                    .and().delete().forPath("/llll").and().commit();  
53.       \} **catch** (Exception e) \{  
54.           
55.        \}  
56.           
57.         **for** (CuratorTransactionResult result : resultone) \{  
58.             System.out.println("getForPath  "\+result.getForPath());  
59.             System.out.println("getResultPath  "\+result.getResultPath());  
60.             System.out.println("getResultStat  "\+result.getResultStat());  
61.             System.out.println("getType  "\+result.getType());  
62.         \}  
63.           
64.         System.out.println("===============================");  
65.         **for** (CuratorTransactionResult result : resulttwo) \{  
66.             System.out.println("getForPath  "\+result.getForPath());  
67.             System.out.println("getResultPath  "\+result.getResultPath());  
68.             System.out.println("getResultStat  "\+result.getResultStat());  
69.             System.out.println("getType  "\+result.getType());  
70.         \}  
71.     \}  
72.       
73.       
74.       
75.       
76.     /\*\* 
77.      \* @描述：获取连接 
78.      \* @return 
79.      \* @return CuratorFramework 
80.      \* @exception 
81.      \* @createTime：2016年5月18日 
82.      \* @author: songqinghu 
83.      \*/  
84.     **private** **static** CuratorFramework getClient()\{  
85.           
86.         ACLProvider aclProvider  = **new** ACLProvider() \{  
87.             List<ACL> acl ;  
88.             @Override  
89.             **public** List<ACL> getDefaultAcl() \{  
90.                 **if**(acl ==**null**)\{  
91.                     acl =  **new** ArrayList<ACL>();  
92.                     //管理员  
93.                     acl.add(**new** ACL(Perms.ALL, **new** Id("auth","admin:amdin")));  
94.                     //只读用户  
95.                    // acl.add(new ACL(Perms.READ, new Id("auth","user:user")));  
96.                 \}  
97.                 **return** acl;  
98.             \}  
99.               
100.             @Override  
101.             **public** List<ACL> getAclForPath(String arg0) \{  
102.                 **return** acl;  
103.             \}  
104.         \};  
105.           
106.         String scheme = "digest";  
107.         **byte**\[\] auth = "admin:admin".getBytes();  
108.         **int** connectionTimeoutMs = 5000;  
109.         String connectString = "10.125.2.44:2181";  
110.         **byte**\[\] defaultData = "测试连接".getBytes();  
111.         String namespace = "atomic";  
112.         RetryPolicy retryPolicy = **new** RetryNTimes(Integer.MAX\_VALUE, 1000);  
113.         CuratorFramework client = CuratorFrameworkFactory.builder().aclProvider(aclProvider).  
114.         authorization(scheme, auth).  
115.         connectionTimeoutMs(connectionTimeoutMs).  
116.         connectString(connectString).  
117.         defaultData(defaultData).  
118.         namespace(namespace).  
119.         retryPolicy(retryPolicy).build();  
120.         client.start();  
121.         **return** client;  
122.     \}  
123.       
124. \}  
125.

[view plain]: http://blog.csdn.net/sqh201030412/article/details/51446448#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/1688241
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/1688241/fork