zookeeper与java交互小结：如何高效地使用API

zookeeper会话及超时处理

1、zookeeper session也就是会话，用于维持客户端与服务器之间的连接状态。在ZooKeeper中，客户端和服务端建立连接后会创建一个session（会话），每一个session对应一个全局唯一的会话ID（Session ID）。就像浏览器和Web服务器一样，首次连接Web服务器的时候为了跟踪客户端，Web服务器会创建一个Session。

2、会话默认每两Tick（zk的时钟周期）后会过期，以确保连接的实时性。客户端会自动处理连接故障，通过持续的请求保持活跃，并通过PING请求验证连接的存活。监听机制是zk的单向通知，允许读操作设置超时，确保数据获取的实时性。

3、对于ZooKeeper来说，它的会话与服务端是通过心跳保持连接的，当心跳超时客户端会收到链接丢失的事件，通常来说这不是问题，因为ZK的客户端对自动连接。但如果一直连接不上，服务端会在会话有效期之后，将会话置为过期。

4、一般包括数据节点创建与删除、数据内容更新和客户端会话创建与失效等操作。对应每一个事务请求，为了保证事务的顺序一致性，ZooKeeper都会为其分配一个全局唯一的事务ID，用 ZXID 表示，通常是一个64位的数字。

5、PERSISTENT-持久节点 除非手动删除，否则节点一直存在于 Zookeeper 上 （2）EPHEMERAL-临时节点 临时节点的生命周期与客户端会话绑定，一旦客户端会话失效（客户端与zookeeper 连接断开不一定会话失效），那么这个客户端创建的所有临时节点都会被移除。

6、Eureka可以很好应对网络故障导致部分码芹梁节点失去联系的情况，而不会想Zookeeper一样，使得整个注册系统瘫痪。两者遵循的原则不一样，Eureka保证的AP，Zookeeper保证的CP。

HBase访问接口

HBase提供了多种访问接口，以满足不同场景的需求：Native Java API：这是最常见的高效方式，适用于与Hadoop MapReduce Job并行处理大批量HBase数据。 HBase Shell：作为命令行工具，适合于HBase的日常管理和操作。

在线访问hbase表数据。pig是一种脚本语言，在hbase访问接口中，适合处理大规模数据，也适合做数据统计，可以用在需要在线访问hbase表数据的场合。

NativeJavaAPI，最常规和高效的访问方式，适合HadoopMapReduceJob并行批处理HBase表数据。HBaseShell，HBase的命令行工具，最简单的接口，适合HBase管理使用。ThriftGateway，利用Thrift序列化技术，支持C＋＋，PHP，Python等多种语言，适合其他异构系统在线访问HBase表数据。

hbase的特点：高可靠性、高性能、面向列、可伸缩的。HBase – Hadoop Database，是一个高可靠性、高性能、面向列、可伸缩的分布式存储系统，利用HBase技术可在廉价PC Server上搭建起大规模结构化存储集群。HBase是Apache的Hadoop项目的子项目。

关于zookeeper,下列说法错误的是

1、关于zookeeper，下列说法错误的是不选举Leader。

2、错误的说法是：Zookeeper只能用于分布式系统的协调服务。Zookeeper的基本功能与用途 首先要明确的是，Zookeeper的确经常被用于分布式系统的协调服务。它可以帮助分布式系统实现诸如领导选举、配置管理、命名服务、分布式同步等功能。然而，这并不意味着Zookeeper只能用于分布式系统的协调服务。

3、关于Zookeeper的说法错误的是：Zookeeper是一个分布式协调服务的收费框架。Zookeepe的定义 Zookeeper是一个分布式协调服务，由雅虎研究员开发，是Google的Chubby一个开源实现。

4、判断）FusionInsight HD 的Streaming对于Zookeeper弱依赖，即使Zookeeper故障Streaming也可以正常提供服务。

5、ZooKeeper以树形结构保存数据。这很类似于文件系统，但“文件夹”（译者注：这里指非最底层的节点）又和文件很像。znode是ZooKeeper保存的实体。Node（节点）的说法很容易被混淆，所以为了避免混淆这里使用了znode。因为我们稍后还会使用，所以这里我们让客户端保持连接状态。开启一个新窗口，并创建一个zookeeperdemophp文件。

dubbo和zookeeper面试题

1、Zookeeper一个分布式的服务框架，是树型的目录服务的数据存储，能做到集群管理数据 ，这里能很好的作为Dubbo服务的注册中心，Dubbo能与Zookeeper做到集群部署，当提供者出现断电等异常停机时，Zookeeper注册中心能自动删除提供者信息，当提供者重启时，能自动恢复注册数据，以及订阅请求。

2、在Dubbo registry上配置相应的用户、密码，服务就注册不到Zookeeper上了，会报KeeperErrorCode = NoAuth错误。总结：通过源码的分析发现使用ZkclientZookeeperClient进行连接zookeeper和注册服务是不会设置安全配置。将dubbo.registry.client由zkclient改为curator即可。

3、其实一个zookeeper集群能被多个应用公用，因为不同的框架会在zookeeper上建不同的节点，互不影响。如dubbo会创建一个/dubbo节点，storm会创建一个/storm节点。

4、发布服务到远程zk，dubbo是调用ServiceConfig.doExportUrlsFor1Protocol方法，在doExportUrlsFor1Protocol方法中，通过以下两步获取到host和port两个值。服务注册到zk上所用的ip，正是这个host，这个findConfigedHosts方法，入参就包括protocolConfig。

5、看了下相关源码，如果是在Zookeeper上通过digest方式设置ACL，然后在dubbo上配置用户、密码，服务就注册不到Zookeeper上了，会报KeeperErrorCode = NoAuth。看了下调用相关代码，发现注册服务时所传的ACL如下图，而配置在dubbo上的，没有发现被使用的地方（如果注册中心是Zookeeper的话）。

如何解决java接口访问ZooKeeper时的connectionloss错误

1、我们在新建ZK连接后要等一段时间，保证连接成功后再访问ZK。 网上比较赞同的解决方案：主要利用两个Java类：（1）java.util.concurrent.CountDownLatch：一个同步辅助类，类似倒数计数，直到计数器为0时才能对资源“解锁”。未解锁前等待该资源的进程只能被阻塞。

2、原因：是因为ZooKeeper建立连接时采用异步操作，连接操作后并不能保证ZK连接已成功。如果在ZK连接成功前的这个小时间窗口去访问ZK，就会碰到如上错误。 解决思路 我们在新建ZK连接后要等一段时间，保证连接成功后再访问ZK。