zookeeper如何实现竞争锁

zookeeper如何实现竞争锁

这篇文章给大家分享的是有关zookeeper如何实现竞争锁的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

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{  //创建实例  zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {  @Override  public void process(WatchedEvent event) {  //判断事件的类型以及路径是否是业务路径  if(event.getType()==EventType.NodeChildrenChanged&&event.getPath().equals(parentNode)) {  List<String> inchild = null;                            try {                            //得到子节点，继续监听                            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();  }  }  }  });  //首先创建一个临时的序列的条目  myPath=zk.create(parentNode+subNode, null, Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);  //得到父节点下面的子目录数并进行监听  List<String> childs = zk.getChildren(parentNode, true);  //判断进入到的时候是否只有自己，如果只有自己则可以做业务逻辑  if(childs.size()==1) {  //业务方法，在业务方法内有删除myPath条目的操作  doSomthing();  //删除完成后继续  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());  //得到锁完成业务后，删除持有的锁，即删除该条目  zk.delete(myPath, -1);  }  }

感谢各位的阅读！关于“zookeeper如何实现竞争锁”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！

[微信提示：高防服务器能助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。

[图文来源于网络，不代表本站立场，如有侵权，请联系高防服务器网删除]
[