zookeeper_节点数据版本号问题
2024-10-15 13:52:15
转自:Simba_cheng
更新节点数据的方法:
- 同步方法:Stat setData(final String path, byte data[], int version)
- 异步方法:void setData(final String path, byte data[], int version, StatCallback cb, Object ctx)
参数说明:
- path:指定数据节点路径
- data[]:一个字节数组,即需要使用该数据来覆盖节点现在的数据内容
- version:指定节点的数据版本
- cb:注册一个异步回调函数
- ctx:用于传递上下文信息的对象
其中:
version参数用于指定节点的数据版本,表名本次更新操作是针对指定的数据版本进行的。
指定数据版本更新的意义何在呢?
通俗的讲"CAS":对于值V,每次更新前都会比对其值是否是预期值A,只有符合预期,才会将V原子化的更新到新值B
CAS具体解释
zookeeper的setData接口中的version参数是CAS衍化来的
zookeeper每个节点都有数据版本的概念,在调用更新操作的时候,就可以添加version这个参数,该参数可以对应于CAS
原理中对的"预期值",表明是针对该数据版本进行更新。
形象一些说:
假如有一个客户端试图进行更新操作,它会携带上次获取到的version值进行更新。
而如果在这段时间内,ZooKeeper服务器上该节点的数值恰好已经被其他客户端更新了,那么其数据版本一定也会发生变化,
因此肯定与客户端携带对的version无法匹配,于是便无法成功更新 -- 因此可以有效地避免一些分布式更新的并发问题。
Demo代码:
public class TestSetData implements Watcher { // 屏障,计数器
private static CountDownLatch downLatch = new CountDownLatch(1); private static ZooKeeper zookeeper = null; public static void main(String[] args) throws Exception { zookeeper = new ZooKeeper("10.0.227.66:2181", 5000, new TestSetData()); System.out.println("zookeeper.getState()1 : " + zookeeper.getState()); try {
downLatch.await();// 在计数器未归零之前,所有线程等待
} catch (Exception e) {
e.printStackTrace();
} System.out.println("zookeeper.getState()2 : " + zookeeper.getState()); zookeeper.create("/cyx", "ccc".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); zookeeper.getData("/cyx", true, null); // 第一次设置
Stat stat = zookeeper.setData("/cyx", "456".getBytes(), -1);
System.out.println(stat.getCzxid() + " , " + stat.getMzxid() + " , " + stat.getVersion()); // 第二次设置
Stat stat2 = zookeeper.setData("/cyx", "789".getBytes(), -1);
System.out.println(stat2.getCzxid() + " , " + stat2.getMzxid() + " , " + stat2.getVersion()); // 获取第一次设置得到version,进行更新
try { zookeeper.setData("/cyx", "123".getBytes(), stat.getVersion()); } catch (Exception e) {
e.printStackTrace();
} } @Override
public void process(WatchedEvent event) { System.out.println("receive watched event : " + event); if (KeeperState.SyncConnected == event.getState()) { if (EventType.None == event.getType() && null == event.getPath()) {
downLatch.countDown();// 计数器-1
}
}
}
}
输出结果:
zookeeper.getState()1 : CONNECTING
receive watched event : WatchedEvent state:SyncConnected type:None path:null
zookeeper.getState()2 : CONNECTED
receive watched event : WatchedEvent state:SyncConnected type:NodeDataChanged path:/cyx
197568501464 , 197568501465 , 1
197568501464 , 197568501466 , 2
org.apache.zookeeper.KeeperException$BadVersionException: KeeperErrorCode = BadVersion for /cyx
代码编写思路:
- 首先创建节点"/cyx"节点,设置节点参数"ccc"
- 接着我们第一次setData,更新节点参数为"456",同时获取stat,此时version已经改变
- 然后我们再次setData,更新节点参数为"789",同时获取stat,version也改变了
- 接着我们使用第一次获取的version版本号,去setData。
- 然后就抛异常,因为第二次setData的时候,版本号已经更新,这时候,我们拿第一次的更新的版本号去更新,是没法成功的。
解释下setData时的"-1":
在ZooKeeper中,数据版本都是从0开始计数额,所以严格的讲,"-1"不是一个合法得到数据版本,它仅仅是一个标示符。
如果客户端传入的版本参数是"-1",就是告诉zookeeper服务器,客户端需要基于数据的最新版本进行更新操作。
最新文章
- Python OS模块常用函数说明
- 13、Apache中虚拟目录和目录权限配置
- 使用sysprep克隆虚拟机
- 用NodeJs实现延迟调用,规避定时任务的闭包问题
- php基本数据类型需要注意的地方
- template might not exist or might not be accessible by any of the configured Template Resolvers
- 201521123004 《Java程序设计》第13周学习总结
- RxJava(一) create操作符的用法和源码分析
- SpringMVC源码分析--容器初始化(五)DispatcherServlet
- Jquery EasyUI +Ajax +Json +一般处理程序 实现数据的前台与后台的交互 --- 善良公社项目
- nodejs之使用express框架连接mysql数据库,返回jsonapi数据
- 使用百度的富文本编辑器UEditor遇到的问题总结
- js的几个补充事件
- Ubuntu 16.10 server 相关
- 提取json响应结果值_后置处理器JSON Extractor
- 【OpenGL】第一个窗口
- Python3 简单验证码识别思路及实例
- 关于gridview改变行内容事件需要点击别的行或控件才能执行
- 汇智课堂 Node.js相关课程
- quick2.2.6 问题记录