java - 用于检查 hbase 是否已启动并正在运行的 Java api

Question

我正在尝试处理连接到 HBase 时的故障情况。目前，我正在检查 HBase 是否正在运行HBaseAdmin.checkHBaseAvailable(conf);. MasterNotRunning但是这个 api 会在大约 40 秒的情况下或ZookeeperConnectionException仅在大约 40 秒之后引发异常。所以，我尝试设置以下重试，hbase.client.retries.number = 1并且zookeeper.recovery.retry = 1. 这让我在 6-7 秒内处理了异常。但是，我需要一种更快的方法来了解 HBase 集群是否正在运行，因为我在我的应用程序中通过同步调用登录到 HBase。

Answer 1

以这种方式检查连接怎么样：

import java.net.InetSocketAddress;
import org.apache.hadoop.hbase.ipc.HBaseRPC;
import org.apache.hadoop.hbase.ipc.HMasterInterface;
import org.apache.hadoop.hbase.ipc.RpcEngine;
...

public static boolean isRunning() {
    boolean result = false;
    Configuration conf = HBaseConfiguration.create();
    conf.clear();
    conf.set("hbase.zookeeper.quorum", "myhost");
    conf.set("hbase.zookeeper.property.clientPort", "2181");
    conf.set("hbase.master", "myhost:60000");

    RpcEngine rpcEngine = null;
    try {

        InetSocketAddress isa = new InetSocketAddress("myhost", 60000);
        rpcEngine = HBaseRPC.getProtocolEngine(conf);
        HMasterInterface master = rpcEngine.getProxy(HMasterInterface.class,
                HMasterInterface.VERSION, isa, conf, 1000);
        result = master.isMasterRunning();
    }
    catch (Exception e) {
        // ...
    }
    finally {
        if (rpcEngine != null) {
            rpcEngine.close();
        }
    }
    return result;
}

注意：我假设这里版本 >= 0.94.5