文档章节

分布式服务框架 Zookeeper之分布式锁

醉饮黄龙
 醉饮黄龙
发布于 2015/01/27 16:36
字数 523
阅读 39
收藏 0

先记录下,心烦得很,后面再整理

/**
 * 包名:com.lencee.demo.zookeeper.locks
 * 文件名:LockClient.java
 * 版本信息:
 * 日期:2015年1月23日-下午4:49:48
 * 
 */
package com.lencee.demo.zookeeper.locks;
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;
import org.apache.zookeeper.data.Stat;
/**
 * 
 * <p>TODO:类名称<p>
 * <p>TODO:描述本类实现的功能作用,若为接口应该声明调用地址</p>
 * @version 2015年1月23日 下午4:49:48
 * 
 */
public class LockClient {
 // Zookeeper集群服务地址与端口
 private static String zkUrl = "192.168.0.101:11001";
 // 配置结点根路径
 private final static String ROOT_LOCK = "/lock";
 private final static String WAIT_LOCK = "/lockwait";
 
 private final static String SELF_PATH = "/client";
 private final static String SELF_DATA = "/client";
 
 private ZooKeeper zk = null;
 private boolean iswait = true;
 //锁路径
 private String lockPath;
 //等待路径
 private String selfWaitPath;
 //监听前置锁路径
 private String waitPath;
 
 public LockClient(){
  try {
   ZooKeeper zk = new ZooKeeper(zkUrl,3000,new Watcher(){
    @Override
    public void process(WatchedEvent event) {
     try {
      if(event.getType()==EventType.NodeDeleted){
       System.out.println(event.getPath()+":"+waitPath);
       getLock();
      }
     } catch (Exception e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
     }
    }});
   
   while (zk.getState() != ZooKeeper.States.CONNECTED) {
    //System.out.println("connecting:"+zk.getState());
    Thread.sleep(3000);
   }
   
   this.zk = zk;
   
   //创建根结点
   String rootValue = "分布式锁";
   if(zk.exists(ROOT_LOCK, true)==null){
    zk.create(ROOT_LOCK, rootValue.getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
   }
   if(zk.exists(WAIT_LOCK, true)==null){
    zk.create(WAIT_LOCK, rootValue.getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
   }
   
   //在锁结点上增加子结点
   this.lockPath = addNode(ROOT_LOCK+SELF_PATH,SELF_DATA.getBytes(),CreateMode.EPHEMERAL_SEQUENTIAL);
   
   //在等待结点上增加子结点
   this.selfWaitPath = WAIT_LOCK+this.lockPath.substring(ROOT_LOCK.length());
   addNode(this.selfWaitPath,SELF_DATA.getBytes(),CreateMode.EPHEMERAL);
   
   
   System.out.println("lockpath:"+this.lockPath);
   System.out.println("selfWaitPath:"+this.selfWaitPath);
   
   System.out.println("waitPath:"+this.waitPath);
  } catch (Exception e) {
   e.printStackTrace();
  } 
 }
 public void getLock() throws Exception {
  //检查本线程是否取到锁
  List<String> list = zk.getChildren(ROOT_LOCK, false);
  Collections.sort(list);
  for(String child:list){
   System.out.println(child);
  }
  
  String lookfor = this.lockPath.substring(ROOT_LOCK.length()+1);
  System.out.println(lookfor);
  
  int index = list.indexOf(lookfor);
  if(index==-1){
   System.out.println("NND,别坑我");
  }else if(index==0){
   //获取到锁
   System.out.println("do something...");
   //删除锁队列
   //zk.delete(this.lockPath, -1);
   
   //删除等待队列
   //zk.delete(this.selfWaitPath, -1);
   
   this.iswait = false;
  }else{
   //未取到锁,侦听前一个节点
   String waitLockPath = list.get(index-1);
   this.waitPath = WAIT_LOCK+"/"+waitLockPath;
   zk.getData(this.waitPath, true, new Stat());
   System.out.println("没取到锁,侦听"+this.waitPath);
  }
 }
 public String addNode(String path,byte[] data,CreateMode createMode) throws Exception{
  String nodePath = null;
  if(!path.startsWith("/")){
   throw new Exception("传入的路径没有以'/'开始");
  }
  if(this.zk.exists(path, true)==null){
   //结点不存在
   nodePath = this.zk.create(path, data, Ids.OPEN_ACL_UNSAFE, createMode);
  }
  return nodePath;
 }
 
 
 /**
  * iswait
  *
  * @return  the iswait
  * @since   1.0.0
  */
 public boolean isIswait() {
  return iswait;
 }
 /**
  * @param iswait the iswait to set
  */
 public void setIswait(boolean iswait) {
  this.iswait = iswait;
 }
 public static void main(String[] args) throws Exception {
  LockClient lc = new LockClient();
  System.out.println("初始化结束。。。。。");
  Thread.sleep(20*1000);
  lc.getLock();
  while(lc.isIswait());
 }
}

© 著作权归作者所有

共有 人打赏支持
醉饮黄龙
粉丝 1
博文 17
码字总数 16194
作品 0
江北
分布式网站架构后续:zookeeper技术浅析

 Zookeeper是hadoop的一个子项目,虽然源自hadoop,但是我发现zookeeper脱离hadoop的范畴开发分布式框架的运用越来越多。今天我想谈谈zookeeper,本文不谈如何使用zookeeper,而是zookeeper...

蓝狐乐队
2014/04/21
0
0
ZooKeeper可以用来做什么(转)

在ZooKeeper的官网上有这么一句话:ZooKeeper is a centralized service for maintaining configuration information, naming, providing distributed synchronization, and providing grou......

easonjim
2017/09/05
0
0
分布式锁与实现(二)基于ZooKeeper实现

引言 ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包...

rechardchensir
10/08
0
0
分布式锁与实现(二)——基于ZooKeeper实现

ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配...

刘祖鹏
05/08
0
0
分布式设计与开发(三)------高一致性服务ZooKeeper

分布式环境中大多数服务是允许部分失败,也允许数据不一致,但有些最基础的服务是需要高可靠性,高一致性的,这些服务是其他分布式服务运转的基础,比如naming service、分布式lock等,这些分...

山哥
2012/03/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

【大福利】极客时间专栏返现二维码大汇总

我已经购买了如下专栏,大家通过我的二维码你可以获得一定额度的返现! 然后,再给大家来个福利,只要你通过我的二维码购买,并且关注了【飞鱼说编程】公众号,可以加我微信或者私聊我,我再...

飞鱼说编程
13分钟前
1
0
Spring5对比Spring3.2源码之容器的基本实现

最近看了《Spring源码深度解析》,该书是基于Spring3.2版本的,其中关于第二章容器的基本实现部分,目前spring5的实现方式已有较大改变。 Spring3.2的实现: public void testSimpleLoad(){...

Ilike_Java
23分钟前
1
0
【王阳明心学语录】-001

1.“破山中贼易,破心中贼难。” 2.“夫万事万物之理不外于吾心。” 3.“心即理也。”“心外无理,心外无物,心外无事。” 4.“人心之得其正者即道心;道心之失其正者即人心。” 5.“无...

卯金刀GG
今天
2
0
OSChina 周三乱弹 —— 我们无法成为野兽

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @ _刚刚好: 霸王洗发水这波很骚 手机党少年们想听歌,请使劲儿戳(这里) hahahahahahh @嘻酱:居然忘了喝水。 让你喝可乐的话, 你准忘不了...

小小编辑
今天
7
0
vm GC 日志 配置及查看

-XX:+PrintGCDetails 打印 gc 日志 -XX:+PrintTenuringDistribution 监控晋升分布 -XX:+PrintGCTimeStamps 包含时间戳 -XX:+printGCDateStamps 包含时间 -Xloggc:<filename> 可以将数据保存为......

Canaan_
昨天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部