zookeeper与java交互小结(zookeeper java使用)

资讯 2024年04月11日 08:30 63 admin

本文目录一览：

1、一般使用Redis来实现分布式锁都是利用Redis的 SETNX key value 这个命令，只有当key不存在时才会执行成功，如果key已经存在则命令执行失败。

2、什么是分布式锁？实现分布式锁的三种方式在很多场景中，我们为了保证数据的最终一致性，需要很多的技术方案来支持，比如分布式事务、分布式锁等。

3、传统数据库解决不了，那么分布式就该上场了。如果功能特别简单，完全可以不去使用MAPREDUCE和Hbase，自己动手搞一个吧。

ZooKeeper代码版本中，提供了分布式独享锁、选举、队列的接口，代码在$zookeeper_home\src\recipes。其中分布锁和队列有Java和C两个版本，选举只有Java版本。

其中连接状态事件(type=None， path=null)不需要客户端注册，客户端只要有需要直接处理就行了。

其实就是对方案3的一个封装，不用自己写代码了。直接拿来用就可以了。menagerie基于Zookeeper实现了java.util.concurrent包的一个分布式版本。这个封装是更大粒度上对各种分布式一致性使用场景的抽象。

purgeMgr.start()；接下来会初始化ServerCnxnFactory，这个是用来接收来自客户端的连接的，也就是这里启动的是一个tcp server。在Zookeeper里提供两种tcp server的实现，一个是使用java原生NIO的方式，另外一个是使用Netty。

调用grant或revoke进行权限设置完成后，需要commit命令提交修改到ZooKeeperKerberos模式下，AuthorizationManager需要先使用AuthenticationManager.login方法登录，与ZooKeeper建立安全的连接，再进行权限设置。

rmi协议默认为 java 原生序列化，http协议默认为为 json。dubbo的通信方式？采用单一长连接和NIO异步通信，基于Hessian2作为序列化协议。

zookeeper与java交互小结(zookeeper java使用)

因为在zookeeper的选举过程中，为了保证选举过程最后能选出leader就一定不能出现两台机器得票相同的僵局，所以一般就会要求zk集群的server数量一定要是奇数，也就是2n+1台。

zookeeper通常是会集群化，也就是启动好几台zookeeper同时提供服务的，因此在每台zookeeper服务的配置文件里面都要配置上其它zookeeper服务的ip和端口。第二点不懂的话直接看配置文件就好了。

并且，如果集群出现问题，其中存活的机器必须大于n+1台，否则leader就无法获得多数server的支持，系统就自动挂掉，所以一般是3个或者3个以上节点。

initLimit这个配置项是用来配置Zookeeper接受客户端（这里所说的客户端不是用户连接Zookeeper服务器的客户端，而是Zookeeper服务器集群中连接到Leader的Follower 服务器）初始化连接时最长能忍受多少个心跳时间间隔数。

ZAB 协议能够保证一个全局的变更序列，即可以为每一个事务分配一个全局的递增编号 xid。