无法从Java连接本地HBase求助：Shell正常但报ConnectionLoss异常

问题描述 #

我已经搭建了本地HBase环境，在HBase Shell中执行status命令一切正常，输出如下：

1 active master, 0 backup masters, 1 servers, 0 dead, 3.0000 average load

但运行以下Java代码尝试连接HBase时：

Configuration hBaseConfiguration = HBaseConfiguration.create();
hBaseConfiguration.set("hbase.zookeeper.quorum", "localhost");
hBaseConfiguration.set("hbase.zookeeper.property.clientPort", "2181");
hBaseConfiguration.set("zookeeper.znode.parent", "/hbase");
HBaseAdmin.available(hBaseConfiguration);

出现了ConnectionLossException异常，具体栈信息如下：

Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /hbase/hbaseid
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
    at org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient$ZKTask$1.exec(ReadOnlyZKClient.java:189)
    at org.apache.hadoop.hbase.zookeeper.ReadOnlyZKClient.run(ReadOnlyZKClient.java:323)
    at java.lang.Thread.run(Thread.java:748)

排查与解决方法 #

既然HBase Shell能正常运行，说明集群本身是健康的，问题基本集中在Java客户端的配置或网络连通性上，你可以按以下步骤逐一排查：

• 检查ZooKeeper的实际监听地址
  有时候ZooKeeper可能没有绑定localhost，而是绑定了机器的内网IP、hostname或者0.0.0.0。你可以通过以下命令查看ZooKeeper实际监听的端口和地址：

  netstat -tulpn | grep 2181
  

  如果输出显示监听的不是127.0.0.1，那你需要把Java代码中的hbase.zookeeper.quorum改成对应的IP或hostname，而不是localhost。另外也可以查看ZooKeeper配置文件zoo.cfg中的listenAddress参数确认。

• 确认ZooKeeper根节点配置匹配
  代码中设置的zookeeper.znode.parent为/hbase，但要确保这和HBase服务端的配置一致。你可以：

  1. 在HBase Shell中执行hbase zkcli进入ZooKeeper命令行
  2. 输入ls /查看根目录下的节点，如果实际HBase的ZNode父节点不是/hbase（比如有些环境会用/hbase-unsecure），就要修改代码中的对应配置。
     或者直接查看HBase的hbase-site.xml文件中的hbase.zookeeper.znode.parent参数值。

• 测试端口可达性与防火墙设置
  即使是本地环境，防火墙也可能拦截2181端口。你可以用以下命令测试端口是否能正常访问：

  telnet localhost 2181
  # 或者用nc命令
  nc -zv localhost 2181
  

  如果连接失败，需要关闭本地防火墙（比如Linux的ufw disable或systemctl stop firewalld，Windows的话在防火墙设置里开放2181端口）。

• 确保客户端与服务端版本一致
  HBase的版本兼容性要求很高，如果你的Java客户端依赖的HBase版本和服务端版本不一致，很可能会出现协议不匹配导致的连接失败。请检查你的项目依赖（比如Maven的pom.xml），确保HBase相关依赖的版本和服务端完全相同。

• 调整客户端连接超时参数
  有时候连接超时也会触发ConnectionLossException，你可以在代码中增加以下配置来延长超时时间：

  hBaseConfiguration.set("hbase.client.retries.number", "3");
  hBaseConfiguration.set("hbase.client.pause", "1000");
  hBaseConfiguration.set("zookeeper.session.timeout", "60000");
  

  给客户端足够的时间来建立与ZooKeeper的连接。

• 查看日志定位细节问题
  如果以上方法都没解决，建议查看ZooKeeper的日志（通常在zookeeper/logs目录下）和HBase Master的日志（通常在hbase/logs目录下），日志里会有更详细的错误信息，比如ZNode权限问题、集群状态异常等，帮助你进一步定位问题。

内容的提问来源于stack exchange，提问作者Vasudha Gupta