這篇文章給大家分享的是有關zookeeper如何實現(xiàn)競爭鎖的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務，包含不限于成都網(wǎng)站設計、成都做網(wǎng)站、外貿網(wǎng)站建設、瀘縣網(wǎng)絡推廣、小程序定制開發(fā)、瀘縣網(wǎng)絡營銷、瀘縣企業(yè)策劃、瀘縣品牌公關、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務，您的肯定，是我們最大的嘉獎；創(chuàng)新互聯(lián)為所有大學生創(chuàng)業(yè)者提供瀘縣建站搭建服務，24小時服務熱線：18980820575，官方網(wǎng)址：aaarwkj.com

package com.hgs.sharelocks;
import java.util.Collections;
import java.util.List;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
public class ZKsharelocks {
private ZooKeeper  zk = null; 
    private final static String connectString = "192.168.6.131:2181,192.168.6.132:2181,192.168.6.133:2181";
    private final static int sessionTimeout = 2000;
    private final static String parentNode="/servers";
    private final static String subNode="/sub";
    private volatile String myPath = null;
    private boolean lockflag = false;
public static void main(String[] args) throws Exception {
ZKsharelocks sl = new ZKsharelocks();
sl.getConnect();
Thread.sleep(Long.MAX_VALUE);
}
public void getConnect() throws Exception{
//創(chuàng)建實例
zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
@Override
public void process(WatchedEvent event) {
//判斷事件的類型以及路徑是否是業(yè)務路徑
if(event.getType()==EventType.NodeChildrenChanged&&event.getPath().equals(parentNode)) {
List<String> inchild = null;
                          try {
                          //得到子節(jié)點，繼續(xù)監(jiān)聽
                          inchild = zk.getChildren(parentNode, true);
                          //排序
                          Collections.sort(inchild);
                          //判斷返回的時間路徑不是null并且最小的子路經是當天路徑
                          if(myPath != null&&inchild.size()>0&&inchild.indexOf(myPath.substring(parentNode.length()+1))==0) {    
                          doSomthing();
                          Thread.sleep(2000);
                          myPath=zk.create(parentNode+subNode, null, Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
                          }
} catch (Exception e) {
e.printStackTrace();
}
}
}
});
//首先創(chuàng)建一個臨時的序列的條目
myPath=zk.create(parentNode+subNode, null, Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
//得到父節(jié)點下面的子目錄數(shù)并進行監(jiān)聽
List<String> childs = zk.getChildren(parentNode, true);
//判斷進入到的時候是否只有自己，如果只有自己則可以做業(yè)務邏輯
if(childs.size()==1) {
//業(yè)務方法，在業(yè)務方法內有刪除myPath條目的操作
doSomthing();
//刪除完成后繼續(xù)
myPath=zk.create(parentNode+subNode, null, Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
}
}
public void doSomthing() throws Exception {
System.out.println("get the lock..."+Thread.currentThread().getName());
//得到鎖完成業(yè)務后，刪除持有的鎖，即刪除該條目
zk.delete(myPath, -1);
}
}

感謝各位的閱讀！關于“zookeeper如何實現(xiàn)競爭鎖”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

當前題目：zookeeper如何實現(xiàn)競爭鎖
本文地址：http://aaarwkj.com/article8/iiogop.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供定制開發(fā)、搜索引擎優(yōu)化、域名注冊、Google、網(wǎng)站策劃、靜態(tài)網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)