`
qindongliang1922
  • 浏览: 2181133 次
  • 性别: Icon_minigender_1
  • 来自: 北京
博客专栏
7265517b-f87e-3137-b62c-5c6e30e26109
证道Lucene4
浏览量:117404
097be4a0-491e-39c0-89ff-3456fadf8262
证道Hadoop
浏览量:125817
41c37529-f6d8-32e4-8563-3b42b2712a50
证道shell编程
浏览量:59821
43832365-bc15-3f5d-b3cd-c9161722a70c
ELK修真
浏览量:71227
社区版块
存档分类
最新评论

分布式助手Zookeeper(六)

阅读更多
散仙,在关于zookeeper的前几篇文章中,除了记录了zookeeper的一些基础知识,也介绍了怎么使用zookeeper来完成,配置文件同步,和主从自动切换的功能,那么,本篇散仙将会介绍下如何使用,zookeeper来完成分布式锁的功能,其实本质上是与主从切换的实现代码是非常类似的,但是功能上强调的重点不一样。

至于,为什么需要分布式锁(公平锁)?为什么不使用JAVA 自带的锁的应用?

1,为什么需要分布式锁? 因为在分布式环境下,可能会出现一些事务,这时候我们除了可以在存储层的数据库进行控制,也可以在应用层控制,举个例子来讲,中国的飞机路线,我们都知道任何时候,都只能由一架飞机通过,而这个控制这个由谁通过,什么时候通过,是由一个信号控制台来决定的,分布式的环境下由于节点分散在各个地方,各个区域,所以控制起来比较麻烦,这时候我们就可以使用zookeeper来轻松的完成,分布式锁的功能。

2,为什么不使用JAVA自带的锁?JAVA JDK提供了公平锁,与非公平锁,但这种实现是基于同一个JVM来说的,如果同一台机器上,不同的JVM,则可以使用文件锁,来实现,但是这些并不是分布式的模式,虽然可以通过RMI的方式来实现,但比较繁琐。

使用zookeeper来完成分布式锁的步骤如下:

序号内容
1创建一个持久znode
2多个程序并发的去zk服务上,创建一个短暂有时序性的节点路径。
3各个节点监听,比它小的里面,最大的节点的动态。
4如果发现,比它小的里面,最大的节点发生锁释放或退出,就自动接替为独占锁
5没发生改变的节点,继续重复步骤,2,3,4


拓扑图如下所示:


注意上图中的master指的就是,获取锁的实例,这其实跟集群环境里只能有一个master的道理一样。

代码如下:


package com.test;

import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.concurrent.CountDownLatch;

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.data.Stat;
/***
 * 基于zookeeper实现的
 * 分布式公平锁
 * 
 * @author qin dong liang 
 * QQ技术群交流:324714439
 * 
 * */
public class Lock1  implements Watcher {
	
	
	/**
	 * ZK实例
	 * */
	private ZooKeeper zk;
	
	/**原子计数锁,防止在zk没有连上前,执行CURD操作*/
	private CountDownLatch down=new CountDownLatch(1);
	
	public Lock1() {
		// TODO Auto-generated constructor stub
	}
	
	
	
	public Lock1(String host)throws Exception {
		 this.zk=new ZooKeeper(host, 5000	, new Watcher() {
			
			@Override
			public void process(WatchedEvent event) {
				// TODO Auto-generated method stub
				/**链接上zk服务,岂可取消阻塞计数**/
				if(event.getState()==KeeperState.SyncConnected){
					down.countDown();
				}
				
			}
		});
	}
	/**
	 * 字符编码
	 * 
	 * **/
	 private static final Charset CHARSET=StandardCharsets.UTF_8;
	/***
	 * 
	 * 此方法是写入数据
	 * 如果不存在此节点
	 * 就会新建,已存在就是
	 * 更新
	 * 
	 * **/
		public void write(String path,String value)throws Exception{
			
			Stat stat=zk.exists(path, false);
			if(stat==null){
				zk.create(path, value.getBytes(CHARSET), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
			}else{
				zk.setData(path, value.getBytes(CHARSET), -1);
			}
			
		}
		
		
		/**
		 * 
		 * 切换锁
		 * 
		 * **/
		 public void check()throws Exception{
			 List<String> list=zk.getChildren("/a", null);
			  Collections.sort(list);//排序使得节点有次序
			  if(list.isEmpty()){
				  System.out.println("此父路径下面没有节点,分布式锁任务完成或还没启动!");
			  }else{
				  
				  String start=list.get(0);//获取第一个节点
				  
				  String data=new String(zk.getData("/a/"+start, false,null));
				  if(data.equals("a")){//等于本身就启动作为Master
					  
					  if(list.size()==1){
						  startMaster();//作为Master启动
						  }else{
							  automicSwitch();//对于非第一个启动的节点,会调用此方法,因为他的第一个挂了
							  //或释放锁了,所以它是抢占的
						  }
				  }else{
					  //非当前节点,就打印当前节点,监控的节点
					  for(int i=0;i<list.size();i++){
						  //获取那个节点存的此客户端的模拟IP
						  String temp=new String(zk.getData("/a/"+list.get(i), false, null));
						  if(temp.equals("a")){
							  //因为前面作为首位判断,所以这个出现的位置不可能是首位
							  //需要监听小节点里面的最大的一个节点
							  String watchPath=list.get(i-1);
							  System.out.println("Lock1监听的是:  "+watchPath);
							  
							  zk.exists("/a/"+watchPath, this);//监听此节点的详细情况,如果发生节点注销事件
							  //则会触发自身的process方法
							  break;//结束循环
						  }
						  
					  }
					  
				  }
				  
				  
			  }
			 
		 }
		
		

	@Override
	public void process(WatchedEvent event) {
		// TODO Auto-generated method stub
		 
		if(event.getType()==Event.EventType.NodeDeleted){
			
			//如果发现,监听的节点,挂掉了,那么就重新,进行监听 
			try{
		   System.out.println("注意有锁退出或释放,公平锁开始抢占........");
			check();
			}catch(Exception e){
				e.printStackTrace();
				
			}
		}
	}
	/**
	 * 
	 * 读取数据,给定一个路径和
	 * 监听事件
	 * 
	 * ***/
	 public String read(String path,Watcher watch)throws Exception{
		 
		 byte[] data=zk.getData(path, watch, null);
		 
		 
		 return new String(data,CHARSET);
	 }
	 
	 SimpleDateFormat f=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

	 
	  /**
	   * 关闭zk连接
	   * 
	   * **/
	 public void close()throws Exception{
		 zk.close();
	 }
	 
	 
	 
	 /**
	  * 释放锁
	  * @throws Exception
	  */
	 public void automicSwitch()throws Exception{
		 
		// System.out.println("有节点释放锁,Lock1锁占入.......,  时间  "+f.format(new Date()));
		 System.out.println("Lock1的上级锁节点退出或释放锁了,Lock1锁占入.......,  时间  "+f.format(new Date()));
	 }
	 
	 /**
	  * 创建一个持久node,
	  * 
	  * **/
	 public void createPersist()throws Exception{
		 
		 zk.create("/a", "主节点".getBytes(), Ids.OPEN_ACL_UNSAFE	, CreateMode.PERSISTENT);
		 
		 System.out.println("创建主节点成功........");
		 
		 
	 }
	 
	 /***
	  * 创建锁node,注意是抢占 的
	  * 
	  * 
	  * */
	 public void createTemp()throws Exception{
		 
		 zk.create("/a/b", "a".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
		 
	  System.out.println("Lock1注册锁成功,进入公平队列...........");	 
		 
	 }
	 
	public static void main(String[] args)throws Exception {
			
			//Slave s=new Slave("192.168.120.128:2181");
			Lock1 lock=new Lock1("192.168.120.128:2181");
		    //  lock.createPersist();//创建主节点
			 lock.createTemp();//注册临时有序节点
			 lock.check();
			  Thread.sleep(Long.MAX_VALUE);
			 //lock.close();
			
	}
	 
	 /***
	  * 获取锁成功
	  * 
	  * */
	 public void startMaster(){
		 
		 System.out.println("Lock1节点获取锁了,其他节点等待........");
	 }
	 
}


代码如上,所示,测试的时候,需要搭建一个3个节点的zookeeper集群,关于怎么搭建zookeeper集群,散仙前面的文章里有介绍,需要注意的是myid文件不要漏掉。

上面这个类,需要拷贝多份,并改变里面的节点的值,放在不同的eclipse中,进行模拟测试。




分享到:
评论

相关推荐

    zookeeper连接工具zktools

    在实际使用中,ZkTools不仅适用于开发和运维人员日常的Zookeeper管理,也是进行系统故障排查和性能优化的有力助手。通过压缩包中的ZkTools,用户可以快速上手,提升工作效率,更好地驾驭Zookeeper这个强大的分布式...

    zookeeper可视化工具

    **Zookeeper可视化工具详解** Apache ZooKeeper 是一个分布式...总之,Zookeeper可视化工具是管理和维护Zookeeper集群不可或缺的助手,通过它们,我们可以更高效、更安全地操作Zookeeper,实现分布式系统的稳定运行。

    zookeeper-3.4.9.zip

    《Zookeeper:分布式服务治理的重要角色》 Zookeeper,作为Apache的一个开源项目,是分布式应用程序协调服务...它不仅提供了丰富的功能,而且有着成熟的社区支持和广泛的应用实践,是构建大规模分布式应用的得力助手。

    zookeeper客户端.zip

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈...它的跨平台性和易用性使得在各种环境下都能灵活应用,是Zookeeper使用者的有力助手。

    zookeeper的myeclipse插件

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下...如果你经常处理ZooKeeper相关的工作,这款插件无疑是你不可或缺的得力助手。

    超级好用的zookeeper查看器

    而“Zookeeper查看器”则成为了开发者和运维人员进行故障排查、监控与管理Zookeeper的得力助手。 首先,我们需要理解Zookeeper的核心功能。在分布式系统中,Zookeeper提供了一种名为“ZNode”的数据结构,类似于...

    Ant编译后的zookeeper源码

    Apache ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下一步合理操作。最终将简单易用的接口和性能高效、功能稳定的系统提供给...

    zookeeper eclipse plugin

    5. **代码助手**:提供ZooKeeper相关的代码提示和自动完成,加速编码过程。 6. **配置向导**:简化ZooKeeper连接设置,只需几步即可连接到本地或远程的ZooKeeper服务器。 7. **版本兼容性**:虽然描述中提到的是...

    ZooInspector-for-zookeeper数据查看

    总结起来,ZooInspector是Zookeeper管理员的得力助手,通过其强大的图形界面,用户可以更直观、便捷地管理和监控Zookeeper的数据。了解并熟练使用ZooInspector,对于提升Zookeeper的管理和故障排查能力至关重要。

    zookeeper-web-master.zip

    总的来说,"zookeeper-web"是Zookeeper管理的得力助手,它通过Web界面极大地提升了Zookeeper的易用性,是分布式系统管理员的必备工具之一。掌握"zookeeper-web"的使用,不仅可以提升工作效率,也有助于更好地理解和...

    zookeeper可视化JAVA工具ZooInspector

    在IT行业中,Zookeeper是Apache软件基金会的一个开源项目,常用于分布式协调服务,确保数据的一致性和高可用性。而ZooInspector则为这个复杂的分布式系统提供了友好的图形用户界面(GUI),极大地简化了开发者和管理...

    ZooInspector:一款ZooKeeper的可视化工具

    ZooKeeper是Apache软件基金会的一个项目,它提供了一个分布式协调服务,广泛应用于分布式系统中,如配置管理、命名服务、分布式同步、组服务等。ZooInspector作为ZooKeeper的可视化界面,极大地简化了用户与...

    zookeepers分布式

    总结来说,ZooKeeper作为分布式系统的协调者,通过提供强一致性、高可用性的服务,极大地简化了分布式环境下的复杂问题,成为大数据和云计算领域的得力助手。理解和掌握ZooKeeper,对于开发和运维分布式系统具有重要...

    开源监控管理zookeeper工具:exhibitor-1.6

    总的来说,Exhibitor是Zookeeper管理员的得力助手,通过它,你可以更高效地管理和维护Zookeeper集群,确保分布式系统的稳定运行。正确配置和使用Exhibitor对于提升Zookeeper的运维效率和系统可靠性具有重要意义。

    zookeeper查看器

    **Zookeeper查看器:ZooInspector详解** ...总结来说,ZooInspector作为Zookeeper的辅助工具,提供了一个图形化的接口,方便用户理解和管理Zookeeper集群,对于开发者和运维人员来说,它是不可或缺的调试和管理助手。

    zookeeper-3.4.6

    《Zookeeper 3.4.6:探索分布式一致性解决...它的设计思路、实现机制以及丰富的API,使其成为分布式系统中的得力助手。通过深入学习和使用,开发者可以有效地构建稳定、高效的分布式应用,应对复杂的分布式环境挑战。

    zookeeper可视化工具安装包

    总之,Zookeeper 可视化工具是管理和维护 Zookeeper 集群的强大助手,能够简化操作流程,提高运维效率,是 IT 专业人士不可或缺的工具之一。通过熟练掌握和使用这些工具,可以更好地管理和优化基于 Zookeeper 的...

    多线程入门,分布式锁,等相关资料

    总结来说,本资源包提供的"多线程入门资料"涵盖了多线程的基本概念、实现方式、线程同步与通信、并发问题及其解决方案,以及分布式锁的原理与实现,是学习Java多线程和分布式系统的好助手。通过深入学习和实践,...

    zookeeper之节点基本操作(一).zip

    在分布式系统领域,ZooKeeper 是一个至关重要的组件,它为分布式应用程序提供了高效且可靠...在实际项目中,ZooKeeper 被广泛应用于配置管理、命名服务、分布式锁、队列等多个场景,是构建高可用分布式系统的得力助手。

Global site tag (gtag.js) - Google Analytics