学习
实践
活动
专区
工具
TVP
写文章
专栏首页大数据实战演练如何优雅地使用 java 连接 HBase 客户端

如何优雅地使用 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;
    }
}

上述代码,只有当触发 getInstance() 方法时,才会初始化 connection ,且 connection 只会被加载一次。

比如我们要执行 HBase 客户端操作的话,可以执行:HBaseUtil.getInstance().listTables("xxx") 。

三、总结

1、为什么这样实现就是单例的?

因为 HBaseUtil.java 的实例化是靠静态内部类的静态常量 instance 实例化的。instance 是常量,因此只能赋值一次;它还是静态的,因此随着内部类一起加载。

2、这样实现有什么好处?

我记得以前接触的懒汉式的代码好像有线程安全问题,需要加同步锁才能解决。采用静态内部类实现的代码也是懒加载的,只有触发静态内部类的静态常量 instance 的时候才加载;同时也不会有线程安全问题。

3、不只是 HBase 可以这样初始化客户端,Elasticsearch 等等的长连接也都可以,这样,你学会了吗?

文章分享自微信公众号:
大数据实战演练

本文参与 腾讯云自媒体分享计划 ,欢迎热爱写作的你一起参与!

作者:CREATE 17
原始发表时间:2020-12-15
如有侵权,请联系 cloudcommunity@tencent.com 删除。
登录 后参与评论
0 条评论

相关文章

  • 如何使用Java连接Kerberos的HBase

    出于CDH集群安全考虑,在CDH集群中增加了Kerberos认证机制。因为HBase的存储系统是基于Hadoop的存储,所以通过HBase客户端访问HBase数...

    Fayson
  • 如何优雅地使用 Docker

    很久很久以前,就曾经尝试过使用 Docker 。但是由于没有足够的动力学习,导致多次半途而废(就像学 vim 一样)。 终于,在想要使用 gitbook 转换开...

    OhYee
  • 如何优雅地使用minicom

    minicom是linux下一款常用的串口调试工具。ubuntu环境下,使用如下命令安装

    zqb_all
  • 如何优雅地停止Java进程

    我们知道,Java程序的运行需要一个运行时环境,即:JVM,启动Java进程即启动了一个JVM。 因此,所谓停止Java进程,本质上就是关闭JVM。 那么,...

    编程随笔
  • 如何更优雅地使用 Redux

    本文主要介绍 Redux 在业务实际使用中遇到的问题、思考以及解决办法,其中文中所说的不一定适用所有业务,也不一定正确,希望只是能带给大家一些思考。

    陈津
  • 如何优雅地使用 Nginx 限流

    这个算法的核心是:缓存请求、匀速处理、多余的请求直接丢弃。 相比漏桶算法,令牌桶算法不同之处在于它不但有一只“桶”,还有个队列,这个桶是用来存放令牌的,队列才...

    Bug开发工程师
  • Kotlin 如何优雅地使用 Scope Functions

    作用域函数:它是 Kotlin 标准库的函数,其唯一目的是在对象的上下文中执行代码块。 当您在提供了 lambda 表达式的对象上调用此类函数时,它会形成一个临...

    fengzhizi715
  • minicom指令_如何优雅地使用minicom

    minicom是linux下一款常用的串口调试工具。ubuntu环境下,使用如下命令安装

    全栈程序员站长
  • 论如何优雅地使用 Windows 10!

    都 0202 年了,Windows 10 都已经发布 5 年多了,我个人也是从 Windows 一发布就从 Windows 7 换到了 Windows 10。就...

    村雨遥
  • 在 Java 中如何优雅地判空

      作为搬砖党的一族们,我们对判空一定再熟悉不过了,不要跟我说你很少进行判空,除非你喜欢NullPointerException。

    芋道源码
  • java程序 如何优雅地读取xml文件

    Meet相识
  • Java如何优雅地实现接口数据校验

    本篇文章给大家分享平时开发中总结的一点小技巧!在工作中写过Java程序的朋友都知道,目前使用Java开发服务最主流的方式就是通过Spring MVC定义一个Co...

    用户5927304
  • 在Java中如何优雅地判空

    作为搬砖党的一族们,我们对判空一定再熟悉不过了,不要跟我说你很少进行判空,除非你喜欢 NullPointerException。

    JAVA葵花宝典
  • 如何优雅地在Redis中使用Lua

    今天讲一些redis和lua脚本的相关的东西,lua这个脚本是一个好东西,可以运行在任何平台上,也可以嵌入到大多数语言当中,来扩展其功能。lua脚本是用C语言写...

    Bug开发工程师
  • 如何更优雅地使用 bilibili(b站)

    这里再分享个强大的哔哩哔哩增强脚本https://greasyfork.org/zh-CN/scripts/373563-bilibili-evolved

    苏生不惑
  • 如何优雅地使用Redis之位图操作

    在进入今天的主题前,先简单地解释下Redis中的位图到底是什么。Redis官方文档对于位图的介绍如下:

    Bug开发工程师
  • 如何优雅地使用Sublime Text3

    Sublime Text:一款具有代码高亮、语法提示、自动完成且反应快速的编辑器软件,不仅具有华丽的界面,还支持插件扩展机制,用她来写代码,绝对是一种享受。相比...

    用户1667431
  • Python中如何优雅地使用switch语句

    我们知道Python中没有类似C++或者Java中的switch...case语句,我们可以使用多个if...elif...else进行模拟,但是这样的写法让代...

    卡尔曼和玻尔兹曼谁曼
  • 如何优雅地打印一个Java对象?

    你好呀,我是沉默王二,一个和黄家驹一样身高,和刘德华一样颜值的程序员。虽然已经写了十多年的 Java 代码,但仍然觉得自己是个菜鸟(请允许我惭愧一下)。

    沉默王二

扫码关注腾讯云开发者

领取腾讯云代金券