CuratorFramework怎么用

这篇文章主要介绍“Curator Framework怎么用”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Curator Framework怎么用”文章能帮助大家解决问题。

榆树网站制作公司哪家好,找成都创新互联公司!从网页设计、网站建设、微信开发、APP开发、响应式网站设计等网站项目制作,到程序开发,运营维护。成都创新互联公司于2013年开始到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选成都创新互联公司

Framework 比较简单,就是一些CRUD,Watch :

package curator.framework;

import java.util.List;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;

public class FrameworkDemo {

	public static void main(String[] args) {
		connection1();
	}

	private static void connection1() {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
		CuratorFramework client = CuratorFrameworkFactory.builder()
				.connectString("127.0.0.1:2181")
				.sessionTimeoutMs(5000)
				.connectionTimeoutMs(10000)
				.retryPolicy(retryPolicy)
				.namespace("text").build();
		client.start();
		try {
			byte[] b = null;
			// 创建
			client.create().withMode(CreateMode.EPHEMERAL).forPath("/xx",new String("").getBytes());
			// 得到值
			client.getData().forPath("");
			// 得到子节点 List
			List ls = client.getChildren().forPath("");
			// 删除
			client.delete().forPath("");
			// 修改
			client.setData().forPath("", b);
		} catch (Exception e) {
		}
		client.close();
	}

	private static void connection2() {
		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
		CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", retryPolicy);
		client.start();
		client.close();
	}
	
	
	
}

关于“Curator Framework怎么用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注创新互联行业资讯频道,小编每天都会为大家更新不同的知识点。


分享名称:CuratorFramework怎么用
网页网址:http://csdahua.cn/article/jphide.html
扫二维码与项目经理沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流