zookeeper分布式集群Curator的分布式整型int计数器SharedCount

public class Main {

private int COUNT = 10;

private int TIME = 50;

public static void main(String[] args) {

//初始化log4j，zookeeper否则报错。

//org.apache.log4j.BasicConfigurator.configure();

try {

Main app = new Main();

app.zk();

} catch (Exception e) {

e.printStackTrace();

}

}

private void zk() throws Exception {

//任意位置的SharedCount，只要使用相同的path，都可以得到这个计数值。

String path = “/path/count”;

CuratorFramework client = initClient(path);

//分布式集群中存在的某一处计数。

SharedCount baseCount = new SharedCount(client, path, 0);

baseCount.start();

//baseCount.setCount(0);

baseCount.addListener(new SharedCountListener() {

@Override

public void countHasChanged(SharedCountReader sharedCount, int newCount) throws Exception {

System.out.println(“countHasChanged最新=” + newCount);

}

@Override

public void stateChanged(CuratorFramework client, ConnectionState newState) {

//System.out.println(TAG + “状态变化:” + client.toString());

}

});

List sharedCountList = new ArrayList();

//开启COUNT个线程，模拟对分布式中SharedCount的不同节点的赋值操作。

ExecutorService service = Executors.newFixedThreadPool(COUNT);

for (int i = 0; i < COUNT; i++) {

SharedCount count = new SharedCount(client, path, 0);

count.start();

sharedCountList.add(count);

Runnable runnable = new Runnable() {

@Override

public void run() {

try {

TimeUnit.SECONDS.sleep((long) (Math.random() * TIME));

setValue(count);

} catch (Exception e) {

e.printStackTrace();

}

}

};

service.submit(runnable);

}

service.shutdown();

service.awaitTermination(TIME, TimeUnit.SECONDS);

//使用完成后要记得关闭。

for (SharedCount c : sharedCountList) {

c.close();

}

baseCount.close();

}

private void setValue(SharedCount count) throws Exception {

System.out.println(“-------------”);

int oldCount = count.getCount();

System.out.println(“当前值=” + oldCount);

System.out.println(“当前VersionedValue version=” + count.getVersionedValue().getVersion());

System.out.println(“当前VersionedValue value=” + count.getVersionedValue().getValue());

int n = (int) (Math.random() * 1000);

System.out.println(“尝试赋值:” + n);

/**

• trySetCount设置计数器和setCount不同，setCount强制更新计数器的值。

• trySetCount第一个参数提供当前的VersionedValue,如果期间其它client更新了计数值，

• 你的更新可能不成功，但是这时你的client更新了最新的值，

• 若失败可再尝试更新。

• 只有当此client最后读取的值与zookeeper中的值相等时，才能更新.

• 调用此方法，不成功时，会刷新本地缓存值.

• 之后调用getCount()就是新值.

*/

//boolean b = count.trySetCount(count.getVersionedValue(), n);

//System.out.println(n + “更新?” + b);

//或者使用setCount强制更新计数器的值。

//此方法强制更新计数器值。

count.setCount(n);

}

private CuratorFramework initClient(String path) throws Exception {

CuratorFramework client = makeClient();

client.start();

boolean b = isPathExist(client, path);

//如果不存在这个路径，stat为null，创建新的节点路径。

if (!b) {

String s = client.create()

.creatingParentsIfNeeded()

.withMode(CreateMode.PERSISTENT)

.forPath(path);

System.out.println("创建 " + s);

} else {

System.out.println(“已存在:” + path + “,不需重复创建”);

}

return client;

}

//检测是否存在该路径。

private boolean isPathExist(CuratorFramework client, String path) {

boolean b = false;

//检测是否存在该路径。

try {

Stat stat = client.checkExists().forPath(path);

b = stat == null ? false : true;

} catch (Exception e) {

e.printStackTrace();

}

return b;

}

private CuratorFramework makeClient() {

RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 5);

CuratorFramework client = CuratorFrameworkFactory.builder()

.connectString(getAddress())

.sessionTimeoutMs(10 * 1000)

.connectionTimeoutMs(20 * 1000)

.retryPolicy(retryPolicy)

.build();

return client;

}

private String getAddress() {

String ip = “127.0.0.1”;

return ip + “:2181,” + ip + “:2182,” + ip + “:2183”;

}

}

输出：

创建 /path/count

---

当前值=825700910

当前VersionedValue version=0

最后

今天关于面试的分享就到这里，还是那句话，有些东西你不仅要懂，而且要能够很好地表达出来，能够让面试官认可你的理解，例如Handler机制，这个是面试必问之题。有些晦涩的点，或许它只活在面试当中，实际工作当中你压根不会用到它，但是你要知道它是什么东西。

最后在这里小编分享一份自己收录整理上述技术体系图相关的几十套腾讯、头条、阿里、美团等公司2021年的面试题，把技术点整理成了视频和PDF（实际上比预期多花了不少精力），包含知识脉络 + 诸多细节，由于篇幅有限，这里以图片的形式给大家展示一部分。

还有 高级架构技术进阶脑图、Android开发面试专题资料，高级进阶架构资料 帮助大家学习提升进阶，也节省大家在网上搜索资料的时间来学习，也可以分享给身边好友一起学习。

【算法合集】

【延伸Android必备知识点】

【Android部分高级架构视频学习资源】

Android精讲视频领取学习后更加是如虎添翼！进军BATJ大厂等（备战）！现在都说互联网寒冬，其实无非就是你上错了车，且穿的少（技能），要是你上对车，自身技术能力够强，公司换掉的代价大，怎么可能会被裁掉，都是淘汰末端的业务Curd而已！现如今市场上初级程序员泛滥，这套教程针对Android开发工程师1-6年的人员、正处于瓶颈期，想要年后突破自己涨薪的，进阶Android中高级、架构师对你更是如鱼得水，赶快领取吧！
《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》，点击传送门，即可获取！
g-DvlwCPVo-1715148650544)]

【Android部分高级架构视频学习资源】

Android精讲视频领取学习后更加是如虎添翼！进军BATJ大厂等（备战）！现在都说互联网寒冬，其实无非就是你上错了车，且穿的少（技能），要是你上对车，自身技术能力够强，公司换掉的代价大，怎么可能会被裁掉，都是淘汰末端的业务Curd而已！现如今市场上初级程序员泛滥，这套教程针对Android开发工程师1-6年的人员、正处于瓶颈期，想要年后突破自己涨薪的，进阶Android中高级、架构师对你更是如鱼得水，赶快领取吧！
《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》，点击传送门，即可获取！