ZooKeeper Java客户端API如何更新数据

66次阅读
没有评论

共计 1954 个字符,预计需要花费 5 分钟才能阅读完成。

这篇文章将为大家详细讲解有关 ZooKeeper Java 客户端 API 如何更新数据,文章内容质量较高,因此丸趣 TV 小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

同步更新数据

import java.util.concurrent.CountDownLatch;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.data.Stat;
public class SetData_API_Sync_Usage implements Watcher { private static CountDownLatch connectedSemaphore = new CountDownLatch(1);
 private static ZooKeeper zk = null;
 
 public static void main (String[] args) throws Exception{
 
 String path =  /titush-book2 
 zk = new ZooKeeper( 202.201.*.*:2100 ,
 5000,
 new SetData_API_Sync_Usage()); 
 
 connectedSemaphore.await();
 
 zk.create(path,  1231 .getBytes(),
 Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
 zk.getData(path, true, null);
 
 Stat stat = zk.setData(path,  4561 .getBytes(), -1);
 System.out.println(stat.getCzxid()+ , +stat.getMzxid()+ , +stat.getVersion());
 
 Stat stat2 = zk.setData(path,  4561 .getBytes(), stat.getVersion());
 System.out.println(stat2.getCzxid()+ , +stat2.getMzxid()+ , +stat2.getVersion());
 
 try{ zk.setData(path,  456 .getBytes(), stat.getVersion());
 } catch ( KeeperException e) { System.out.println( Error:  + e.code() +  ,  + e.getMessage());
 }
 
 Thread.sleep( Integer.MAX_VALUE);
 }
 
 @Override
 public void process(WatchedEvent event) { if (KeeperState.SyncConnected == event.getState()) { if (EventType.None == event.getType()   null == event.getPath()) { connectedSemaphore.countDown();
 }
 }
 }
}

结果打印

111,112,1
111,113,2
Error:BADVERSION,KeeperErrorCode = BadVersion for /titush-book2

数据节点的当前最新版本表示为 -1,第一版本表示为 0。

第一次设置数据后版本更新为 1,第二次设置后版本更新为 2。

第三次用版本 1 去更新时出现错误,因为此时的版本已经为 2 了。

这里就是乐观锁的使用,stat.getVersion() 用来进行写入校验。

关于 ZooKeeper Java 客户端 API 如何更新数据就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-25发表,共计1954字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)