如何优雅地使用 java 连接 HBase 客户端

HBase 版本：1.2.0-cdh5.7.0

一、客户端的长短连接

java 远程连接 HBase 客户端，大体分为两种方式。一种是长连接，一种是短连接。

短链接，顾名思义，就是客户端执行完某个操作之后，就关闭连接的这种方式，就是短链接。

而长连接就是有且连接一次，后续的所有操作都是基于这次连接做的操作，操作完成后，不关闭连接。长连接适用于频繁交互的场景，今天我们就来着重说一下它。

二、使用单例模式来初始化 HBase 客户端

以 HBase 为例，如果使用长连接，那就得需要确保 connection 唯一，所有的操作都使用这一个 connection 。实现方法有很多，比如双重校验，加锁等方法。

但我们也可以使用静态内部类的形式实现上述场景。静态内部类也是实现单例模式的一种，保证只加载一次，懒加载并且线程安全。

/**
 * HBase客户端操作（长连接）
 */
public class HBaseUtil {

    private static final Logger log = LoggerFactory.getLogger(HBaseUtil.class);

    private Connection connection;
    private static Configuration configuration;

    /**
     * 私有构造器
     * 初始化 HBase Connection
     */
    private HBaseUtil() {
        configuration = initHBaseEnv();
        try {
            connection = ConnectionFactory.createConnection(configuration);
        } catch (IOException e) {
            log.error("HBase Client connect abnormal: ", e);
            System.exit(-1);
        }
    }

    /**
     * 静态内部类
     */
    private static class InstanceHolder {
        // 不会在外部类初始化时就直接加载，只有当调用了getInstance方法时才会静态加载，线程安全。
        private static final HBaseUtil instance = new HBaseUtil();
    }

    /**
     * 单例模式，获取HBase实例
     */
    public static HBaseUtil getInstance() {
        return InstanceHolder.instance;
    }

    /**
     * 初始化 HBase 配置
     */
    public static Configuration initHBaseEnv() {

        try {
            configuration = HBaseConfiguration.create();
            configuration.set("hbase.zookeeper.quorum", "cdh-worker-1,cdh-worker-2,cdh-worker-3");
            configuration.set("hbase.zookeeper.property.clientPort", 2181);
            configuration.set("zookeeper.znode.parent", "/hbase");
        } catch (Exception e) {
            log.error("HBase Client Configuration Initialization exception: ", e);
        }
        return configuration;
    }
    
    /**
     * 获取namespace中所有的表名
     *
     * @param namespace
     */
    public List<String> listTables(String namespace) throws IOException {
        List<String> tableNameList = new ArrayList<>();
        // 获取namespace中所有的表名
        TableName[] tbs = connection.getAdmin().listTableNamesByNamespace(namespace);

        for (TableName tableName : tbs) {
            tableNameList.add(tableName.toString());
        }
        return tableNameList;
    }
}