HBase概念学习（九）HTablePool为何弃用？

素颜马尾好姑娘i 2021-06-24 14:36 310阅读 0赞

我们先看HConnection的getTable方法描述：

Retrieve an HTableInterface implementation for access to a table. The returned HTableInterface is not thread safe, a new 
    instance should be created for each using thread. This is a lightweight operation, pooling or caching of the returned 
    HTableInterface is neither required nor desired. Note that the HConnection needs to be unmanaged (created 
    withHConnectionManager.createConnection(Configuration) ).

上面说HTable的的父类HTableInterface是非线程安全的，针对每个线程建议都应该创建一个新的HTableInterface实例，这个创建过程是轻量的，缓存HTableInterface对象既不是必须的也不是推荐的！

然后再联想到只要HTable使用的Configuration是同一个，那么它们一定是共用一个HConnection的，HConnection才是HBase客户端到Hbase集群的真正的连接。

再想想HTablePool的作用，无非就是HTable的连接池，里面维护的HTable应该来说都是使用的同一个HConnecion。

既然HTable的创建是轻量级的，使用同一个Confuguration的HTable都会共用一个HConnection，那么HTablePool就显得那么多余！

所以Hbase抛弃了HTablePool，我们唯一要做的就是保证HConnection实例是唯一的，全局共享的。然后针对HTableInterface对象最好在每次操作HBase表的时候根据HConnection对象来重新创建，使用完成之后及时关闭即可！

通过HConnection的getTable()方法就能够获取到用户操作HBase表的HTableInterface对象了。

下面是一个使用HConnection的getTable()方法获取HTableInterface对象的例子

public void addUser(User user) throws IOException 
      {
        HTableInterface usersTable = conn.getTable(TABLE_NAME);
        
        Put put = makePut(user);		
        usersTable.put(put);
        
        usersTable.close();
        log.info("Add a User:"+user.name+" successfully");
      }

至于HConnection对象如何创建，HBase推荐使用的方法是：

Create a new HConnection instance using the passed conf instance.
    Note: This bypasses the usual HConnection life cycle management done bygetConnection(Configuration) . The caller is 
    responsible for callingCloseable.close() on the returned connection instance. This is the recommended way to create 
    HConnections. HConnection connection = HConnectionManager.createConnection(conf); HTableInterface table = 
    connection.getTable("mytable"); table.get(...); ... table.close(); connection.close();

下面是单例创建：

public class HBaseUtils {
    
      private static final String QUORUM = "192.168.1.100";
      private static final String CLIENTPORT = "2181";
      private static Configuration conf = null;
      private static HConnection conn = null;
      
      /**
       * 获取全局唯一的Configuration实例
       * @return
       */
      public static synchronized Configuration getConfiguration()
      {		
        if(conf == null)
        {
          conf =  HBaseConfiguration.create();
          conf.set("hbase.zookeeper.quorum", QUORUM); 
          conf.set("hbase.zookeeper.property.clientPort", CLIENTPORT);			
        }		
        return conf;				
      }
      
      /**
       * 获取全局唯一的HConnection实例
       * @return
       * @throws ZooKeeperConnectionException
       */
      public static synchronized HConnection getHConnection() throws ZooKeeperConnectionException
      {
        if(conn == null)
        {
          /*
           * * 创建一个HConnection
           * HConnection connection = HConnectionManager.createConnection(conf); 
           * HTableInterface table = connection.getTable("mytable");
           * table.get(...); ...
           * table.close(); 
           * connection.close();
           * */
          conn = HConnectionManager.createConnection(getConfiguration());
        }
        
        return conn;
      }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，310人围观）

还没有评论，来说两句吧...

相关阅读

相关 vue3.0为何弃用Object.defineProperty而选择Proxy

到vue 双向绑定原理是少不了的知识点，对于vue新版本有关注的小伙伴应该知道尤大大已经宣称在**3.0中双向绑定将会使用Proxy来代替2.x版本的Object.de...

太过爱你忘了你带给我的痛/ 2024年04月17日 06:07/ 0 赞/ 9 阅读

相关 mysqldataentityframeworkcore已弃用

已经存在的数据库提示table doesn't exist update语句错误。在服务运行目录找到my.ini或者my.cnf文件，打开文件，找到\[mysqld\

川长思鸟来/ 2023年09月25日 10:26/ 0 赞/ 8 阅读

相关 HBase rowkey概念

决定一行数据按照字典序排列 1 - 11 - 111 - 2 - 22 查询范围的数据场景较多精确查询场景少字典序能提高查询效率 row key只能存储

矫情吗；*/ 2022年09月13日 11:20/ 0 赞/ 125 阅读

相关 HBase基本概念和hbase shell常用命令用法

1. 简介　　HBase是一个分布式的、面向列的开源数据库,源于google的一篇论文[《bigtable：一个结构化数据的分布式存储系统》][bigtable]。HBas

浅浅的花香味﹌/ 2022年08月21日 05:42/ 0 赞/ 162 阅读

相关 HBase概念

什么是hbase HBase是一个分布式的、面向列的开源数据库，该技术来源于 Fay Chang 所撰写的Google论文“Bigtable：一个结构化数据的分布式存储系

女爷i/ 2022年06月07日 07:36/ 0 赞/ 124 阅读

相关 HBase概念学习

HBase可以认为是一种类似于数据库的存储层，并且HBase是一种列式的分布式数据库（由谷歌当年的BigTable论文而生），也就是说HBase适用于结构化的存储。注意HBas

川长思鸟来/ 2022年05月31日 02:58/ 0 赞/ 219 阅读

相关九、HBase禁用表

要删除表或改变其设置，首先需要使用 disable 命令关闭表。使用 enable 命令，可以重新启用它。下面给出的语法是用来禁用一个表： disable ‘em

超、凢脫俗/ 2022年05月19日 09:36/ 0 赞/ 166 阅读

相关 Hbase基本概念

1. HBase简介 1.1 什么是HBase HBASE是一个高可靠性、高性能、面向列、可伸缩的分布式存储系统，利用HBASE技术可在廉价PC Server上搭建

待我称王封你为后i/ 2022年04月24日 12:22/ 0 赞/ 194 阅读

相关 HBase 相关概念

什么是HBase HBase的原型是Google的BigTable论文，受到了该论文思想的启发，目前作为Hadoop的子项目来开发维护，用于支持结构化的数据存储。官方

我就是我/ 2021年12月23日 14:31/ 0 赞/ 243 阅读

相关 HBase概念学习（九）HTablePool为何弃用？

我们先看HConnection的getTable方法描述： Retrieve an HTableInterface implementation for access

素颜马尾好姑娘i/ 2021年06月24日 14:36/ 0 赞/ 311 阅读