二、zookeeper基础

1、zk能够用来干什么java

先说大话,zk官网上是这么描述的:ZooKeeper是一个分布式的开源协调服务。node

ZooKeeper is a centralized service for maintaining configuration information, naming, providing distributed synchronization, and providing group services. 数据库

这大概描述了Zookeeper主要能够干哪些事情:配置管理,名字服务,提供分布式同步以及集群管理。那这些服务又究竟是什么呢?咱们为何须要这样的服务?咱们又为何要使用Zookeeper来实现呢,使用Zookeeper有什么优点?接下来我会挨个介绍这些究竟是什么,以及有哪些开源系统中使用了。编程

一、配置管理服务器

在咱们的应用中除了代码外,还有一些就是各类配置。好比数据库链接等。通常咱们都是使用配置文件的方式,在代码中引入这些配置文件。可是当咱们只有一种配置,只有一台服务器,而且不常常修改的时候,使用配置文件是一个很好的作法,可是若是咱们配置很是多,有不少服务器都须要这个配置,并且还多是动态的话使用配置文件就不是个好主意了。这个时候每每须要寻找一种集中管理配置的方法,咱们在这个集中的地方修改了配置,全部对这个配置感兴趣的均可以得到变动。好比咱们能够把配置放在数据库里,而后全部须要配置的服务都去这个数据库读取配置。可是,由于不少服务的正常运行都很是依赖这个配置,因此须要这个集中提供配置服务的服务具有很高的可靠性。通常咱们能够用一个集群来提供这个配置服务,可是用集群提高可靠性,那如何保证配置在集群中的一致性呢? 这个时候就须要使用一种实现了一致性协议的服务了。Zookeeper就是这种服务,它使用Zab这种一致性协议来提供一致性。如今有不少开源项目使用Zookeeper来维护配置,好比在HBase中,客户端就是链接一个Zookeeper,得到必要的HBase集群的配置信息,而后才能够进一步操做。还有在开源的消息队列Kafka中,也使用Zookeeper来维护broker的信息。在Alibaba开源的SOA框架Dubbo中也普遍的使用Zookeeper管理一些配置来实现服务治理。网络

二、分布式锁数据结构

Zookeeper是一个分布式协调服务。这样咱们就能够利用Zookeeper来协调多个分布式进程之间的活动。好比在一个分布式环境中,为了提升可靠性,咱们的集群的每台服务器上都部署着一样的服务。可是,一件事情若是集群中的每一个服务器都进行的话,那相互之间就要协调,编程起来将很是复杂。而若是咱们只让一个服务进行操做,那又存在单点。一般还有一种作法就是使用分布式锁,在某个时刻只让一个服务去干活,当这台服务出问题的时候锁释放,当即fail over到另外的服务。这在不少分布式系统中都是这么作,这种设计有一个更好听的名字叫Leader Election(leader选举)。好比HBase的Master就是采用这种机制。但要注意的是分布式锁跟同一个进程的锁仍是有区别的,因此使用的时候要比同一个进程里的锁更谨慎的使用。架构

【zk的分布式锁,使用临时节点实现的,临时节点的生命周期即一个会话的生命周期】框架

三、集群管理分布式

在分布式的集群中,常常会因为各类缘由,好比硬件故障,软件故障,网络问题,有些节点会进进出出。有新的节点加入进来,也有老的节点退出集群。这个时候,集群中其余机器须要感知到这种变化,而后根据这种变化作出对应的决策。好比咱们是一个分布式存储系统,有一个中央控制节点负责存储的分配,当有新的存储进来的时候咱们要根据如今集群目前的状态来分配存储节点。这个时候咱们就须要动态感知到集群目前的状态。还有,好比一个分布式的SOA架构中,服务是一个集群提供的,当消费者访问某个服务时,就须要采用某种机制发现如今有哪些节点能够提供该服务(这也称之为服务发现,好比Alibaba开源的SOA框架Dubbo就采用了Zookeeper做为服务发现的底层机制)。还有开源的Kafka队列就采用了Zookeeper做为Cosnumer的上下线管理。

 

===========================================================

 

2、ZK配置


tickTime=2000   
            基本的时间单位,做为zk服务器与服务期间  或  客户端与服务器间的心跳间隔

dataDir=/opt/zookeeper/data    
            zk的内存数据结构的快照和日志都存储在这个目录(若是没有dataLogDir的话)

clientPort=2181    
            客户端链接zk服务器的端口

initLimit=10            
            zk能忍受的客户端的最长链接时长,超过这个时长的话客户端链接失败  10*tickTime

syncLimit=5        
            flower和leader通话的请求和应答最大时长



server.0 = 192.168.31.101:2888:3888
server.1 = 192.168.31.16:2888:3888
server.2 = 192.168.31.7:2888:3888
            集群配置,分别表示服务0、服务一、服务2,各个的IP是10一、1六、7,他们之间的通讯端口是2888,
            若是leader服务器宕机须要从新选择leader的话:所须要的端口即便3888

配置-myid

在dataDir里会放置一个myid文件,里面就一个数字,用来惟一标识这个服务。这个id是很重要的,必定要保证整个集群中惟一。zookeeper会根据这个id来取出server.x上的配置。好比当前id为1,则对应着zoo.cfg里的server.1的配置。并且在leader选举的时候,这个id的大小也是有意义的。

===========================================================

3、ZK选举机制

下一篇详写

===========================================================

4、ZK基本ZPI

官网上是这么描述zk  API的

One of the design goals of ZooKeeper is provide a very simple programming interface. As a result, it supports only these operations:

一、create建立一个节点

creates a node at a location in the tree

二、delete删除一个节点

deletes a node

三、exists判断节点是否存在

tests if a node exists at a location

四、get data获取节点数据

reads the data from a node

五、set data修改节点数据

writes data to a node

六、get children获取一个节点

retrieves a list of children of a node

七、sync同步

waits for data to be propagated

 

======================================================

5、简单java操做

相关文章
相关标签/搜索