大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章将为大家详细讲解有关ZooKeeper Java客户端API如何更新数据,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。
10年积累的成都做网站、网站建设、外贸营销网站建设经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站设计后付款的网站建设流程,更有南丰免费网站建设让你可以放心的选择与我们合作。
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如何更新数据就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。