ZooKeeper Java客戶端API如何更新數(shù)據(jù)

這篇文章將為大家詳細(xì)講解有關(guān)ZooKeeper Java客戶端API如何更新數(shù)據(jù)，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。

同步更新數(shù)據(jù)

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();
            }
        }
    }
}

結(jié)果打印

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

數(shù)據(jù)節(jié)點(diǎn)的當(dāng)前最新版本表示為 -1，第一版本表示為 0。

第一次設(shè)置數(shù)據(jù)后版本更新為 1，第二次設(shè)置后版本更新為 2。

第三次用版本 1 去更新時出現(xiàn)錯誤，因?yàn)榇藭r的版本已經(jīng)為 2 了。

這里就是樂觀鎖的使用，stat.getVersion()用來進(jìn)行寫入校驗(yàn)。

關(guān)于ZooKeeper Java客戶端API如何更新數(shù)據(jù)就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。