使用HBase Client访问阿里云NoSQL数据库表格存储-阿里云开发者社区

开发者社区> 阿里云存储服务> 正文

使用HBase Client访问阿里云NoSQL数据库表格存储

简介: 如何使用HBase Client访问阿里云分布式NoSQL数据库表格存储

Apache HBase

  • Apache HBase是Hadoop database,属于Hadoop生态系统。
  • 自从十四年前Google相继发布论文:《The Google File System》、《MapReduce: Simplified Data Processing on Large Clusters》和《Bigtable: A Distributed Storage System for Structured Data》后,开源界开始模仿论文设计开源版本的这三个系统,其中佼佼者就是Hadoop生态,分别对应于Hadoop,HDFS和HBase。
  • 经过十几年业界大规模的使用和锤炼,目前Hadoop生态已经成为一种事实上的业界规范,导致NoSQL的鼻祖Google的Bigtable都支持HBase wrapper,提供了Bigtable HBase client。

Tablestore

  • Tablestore,中文名表格存储,是阿里云自主研发的NoSQL数据库,不同于HBase使用了Java,表格存储和Bigtable一样使用了C++语言来开发。
  • 作为同类型的NoSQL数据库,HBase的大部分功能也同样存在于表格存储中,甚至大部分场景下性能更优,但是表格存储还是不同于HBase,有部分高级功能,HBase并不拥有,这个后面单独文章介绍。

HBase client

  • HBase client是HBase提供的便于用户访问HBase的客户端,支持读、写、扫描、批量、表管理等功能。

场景

Hadoop生态作为长久以来唯一的开源大数据解决方案,被广泛用于各个公司中。目前,大部分自建数据处理系统的公司使用了HBase等Hadoop生态的系统。当这部分用户想将数据迁移到阿里云的NoSQL数据库表格存储时,之前都需要用户重写客户端代码才能使用表格存储,虽然这种方式性能更好,对后续的使用也更友好的,但是还是初期比较耗时间,为了解决这个问题,表格存储年前也推出了TableStore HBase client。

如何使用

用户如果之前使用HBase Client访问HBase,现在只需要在项目中将对HBase Client的依赖 修改为对Tablestore HBase client的依赖,同时修改hbase-site.xml中的hbase.client.connection.impl值为com.alicloud.tablestore.hbase.TablestoreConnection即可。其他代码都不需要任何改动。

例子

代码位置

当前示例程序使用了HBase API访问表格存储服务,完整的示例程序位于Github的Aliyun Tablestore HBase client for Java项目中,目录位置是src/test/java/samples/HelloWorld.java。

配置项目依赖

Maven的依赖配置如下:

   <dependencies>
        <dependency>
            <groupId>com.aliyun.openservices</groupId>
            <artifactId>tablestore-hbase-client</artifactId>
            <version>1.2.0</version>
        </dependency>
    </dependencies>

配置文件

hbase-site.xml中增加下列配置项:

<configuration>
    <property>
        <name>hbase.client.connection.impl</name>
        <value>com.alicloud.tablestore.hbase.TablestoreConnection</value>
    </property>
    <property>
        <name>tablestore.client.endpoint</name>
        <value>endpoint</value>
    </property>
    <property>
        <name>tablestore.client.instancename</name>
        <value>instance_name</value>
    </property>
    <property>
        <name>tablestore.client.accesskeyid</name>
        <value>access_key_id</value>
    </property>
    <property>
        <name>tablestore.client.accesskeysecret</name>
        <value>access_key_secret</value>
    </property>
    <property>
        <name>hbase.client.tablestore.family</name>
        <value>f1</value>
    </property>
    <property>
        <name>hbase.client.tablestore.table</name>
        <value>ots_adaptor</value>
    </property>
</configuration>

连接表格存储

通过创建一个TableStoreConnection对象链接表格存储服务。

        Configuration config = HBaseConfiguration.create();
        
        // 创建一个Tablestore Connection
        Connection connection = ConnectionFactory.createConnection(config);
        
        // Admin 负责创建、管理、删除等
        Admin admin = connection.getAdmin();

创建表

通过指定表名创建一张表,MaxVersion和TimeToLive都是用默认值。

        // 创建一个HTableDescriptor,只有一个列族
        HTableDescriptor descriptor = new HTableDescriptor(TableName.valueOf(TABLE_NAME));
        
        // 创建一个列族,MaxVersion和TimeToLive使用默认值,MaxVersion默认值是1,TimeToLive默认值是Integer.INF_MAX。
        descriptor.addFamily(new HColumnDescriptor(COLUMN_FAMILY_NAME));
        
        // 通过Admin的createTable接口创建表
        System.out.println("Create table " + descriptor.getNameAsString());
        admin.createTable(descriptor);

写数据

写入一行数据到表格存储。

        // 创建一个TablestoreTable,用于单个表上的读写更新删除等操作
        Table table = connection.getTable(TableName.valueOf(TABLE_NAME));
        
        // 创建一个Put对象,主键是row_1
        System.out.println("Write one row to the table");
        Put put = new Put(ROW_KEY);
        
        // 增加一列,表格存储只支持单列族,列族名称在hbase-site.xml中配置,如果没有配置默认是“f”,所以写入数据时COLUMN_FAMILY_NAME可以是空值
        put.addColumn(COLUMN_FAMILY_NAME, COLUMN_NAME, COLUMN_VALUE);
        
        // 执行Table的put操作,使用Hbase API将这一行数据写入表格存储
        table.put(put);

读数据

读取指定行的数据。

        // 创建一个Get对象,读取主键为ROW_KEY的行
        Result getResult = table.get(new Get(ROW_KEY));
        Result result = table.get(get);
        
        // 打印结果
        String value = Bytes.toString(getResult.getValue(COLUMN_FAMILY_NAME, COLUMN_NAME));
        System.out.println("Get one row by row key");
        System.out.printf("\t%s = %s\n", Bytes.toString(ROW_KEY), value);

扫描数据

范围读取数据。

    扫描全表所有行数据
    System.out.println("Scan for all rows:");
    Scan scan = new Scan();

    ResultScanner scanner = table.getScanner(scan);
    
    // 循环打印结果
    for (Result row : scanner) {
        byte[] valueBytes = row.getValue(COLUMN_FAMILY_NAME, COLUMN_NAME);
        System.out.println('\t' + Bytes.toString(valueBytes));
    }

删表

使用Admin API删除一张表。

        print("Delete the table");
        admin.disableTable(table.getName());
        admin.deleteTable(table.getName());

完结

按照上面的步骤就可以使用Tablestore HBase client了,目前,已经有用户开始使用,后续,我们会根据用户的反馈持续优化Tablestore HBase client,使其性能能追赶到原生的表格存储(Tablestore)。

虽然通过Tablestore HBase Client也可以访问表格存储,但是还是建议用户直接使用表格存储的SDK访问表格存储,这样性能更好,功能更多,价格更便宜。表格存储的官方网站:https://cn.aliyun.com/product/ots

ff

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:

阿里云存储基于飞天盘古2.0分布式存储系统,产品多种多样,充分满足用户数据存储和迁移上云需求。

官方博客
链接