这篇文章主要介绍“Curator怎么实现分布式数字”，在日常操作中，相信很多人在Curator怎么实现分布式数字问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Curator怎么实现分布式数字”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
Curator有2个实现：
第一个：
计算
安全
数据库
网络和加速
企业服务
package curator.counters;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.shared.SharedCount;
import org.apache.curator.framework.recipes.shared.SharedCountListener;
import org.apache.curator.framework.recipes.shared.SharedCountReader;
import org.apache.curator.framework.state.ConnectionState;
import org.apache.curator.retry.ExponentialBackoffRetry;
public class SharedCounterDemo {
public static void main(String[] args) throws Exception {
RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
final CuratorFramework client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(5000).connectionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("test").build();
client.start();
SharedCount count = new SharedCount(client,"/cut",0);
count.start();
count.addListener(new SharedCountListener(){
@Override
public void stateChanged(CuratorFramework client, ConnectionState newState) {
}
@Override
public void countHasChanged(SharedCountReader sharedCount, int newCount) throws Exception {
System.err.println("sharedCount.getCount : "+sharedCount.getCount());
System.err.println(newCount);
}});
Thread.currentThread().sleep(5000);
count.setCount(5);
System.in.read();
}
}第二个：
package curator.counters;
import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.atomic.AtomicValue;
import org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.retry.RetryNTimes;
public class DistributedAtomicIntegerDemo {
public static void main(String[] args) throws Exception {
RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
final CuratorFramework client = CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(5000).connectionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("test").build();
client.start();
DistributedAtomicInteger atomicInteger = new DistributedAtomicInteger(client,"/autlog",new RetryNTimes(32,1000));
AtomicValue<Integer> rc = atomicInteger.add(8);
System.out.println("success:" + rc.succeeded() + ";before:" + rc.preValue() + ";after:" + rc.postValue());
System.in.read();
}
}到此，关于“Curator怎么实现分布式数字”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/u/1378390/blog/297059
