Java 程序通过 Thrift2 地址访问 HBase 实例--表格数据库 HBase 版-火山引擎

文档中心

导航

Java 程序通过 Thrift2 地址访问 HBase 实例

最近更新时间：2023.12.18 15:44:46首次发布时间：2022.12.27 16:12:54

表格数据库 HBase 版默认提供了 ZK 连接地址，同时也支持 Thrift 多语言访问，Thrift 是 HBase 标准版实例中的一种服务组件，基于 Apache Thrift（多语言支持的通信框架）开发。本文介绍基于 Java 程序通过 Thrift2 地址访问 HBase 实例的操作步骤。

前提条件

如需通过私网地址访问 HBase 实例，需同时满足如下要求：
- 已购 ECS 服务器与 HBase 实例在相同私有网络 VPC 下。ECS 服务器的购买方法，请参见购买云服务器。
- 已将 ECS 服务器的 IP 地址添加至 HBase 中的白名单中。白名单设置方法，请参见编辑白名单。
如需通过公网地址访问 HBase 实例，需确保运行 Java 工具的设备 IP 地址已加入 HBase 实例的白名单中。白名单设置方法，请参见编辑白名单。
已在 ECS 实例或本地设备上安装 Java 环境，建议使用 JDK 8 版本。更多详情，请参见 Java Downloads。

操作步骤

获取 HBase 实例的 Thrift2 连接地址。
连接地址查看方法，请参见查看连接地址。
说明
表格数据库 HBase 版默认未开通 Thrift2 地址，您需要先申请 Thrift2 连接地址，申请方法，请参见申请 Thrift2 连接地址。

配置 Thrift2 地址来访问 HBase 实例。
在您的业务代码中设置如下配置来连接实例。

说明

将代码中的 ${"HBase Thrift2 的连接地址"}, ${端口号} 替换为您 HBase 实例的 Thrift2 连接地址和端口号，您就可以使用如下示例代码来访问 HBase 实例。如下代码中包括了定义表、写入数据、读取数据的具体代码示例。

package com.bytedance.hbase.example;

import org.apache.hadoop.hbase.thrift2.generated.TColumn;
import org.apache.hadoop.hbase.thrift2.generated.TColumnValue;
import org.apache.hadoop.hbase.thrift2.generated.TGet;
import org.apache.hadoop.hbase.thrift2.generated.THBaseService;
import org.apache.hadoop.hbase.thrift2.generated.TPut;
import org.apache.hadoop.hbase.thrift2.generated.TResult;
import org.apache.hadoop.hbase.thrift2.generated.TScan;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.layered.TFramedTransport;

import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.List;

public class HBaseThriftExample {

  public static void main(String args[]) throws Exception{
    // 通过 TSocket、TBinaryProtocol 开启一个到 HBase 实例的 Thrift2 连接
    TSocket socket = new TSocket(${"HBase Thrift2 的连接地址"}, ${端口号});
    TTransport transport = new TFramedTransport(socket);
    TProtocol protocol = new TBinaryProtocol(transport);

    THBaseService.Iface client = new THBaseService.Client(protocol);
    transport.open();

    // 定义表信息
    ByteBuffer table = ByteBuffer.wrap(${"table name"}.getBytes());
    ByteBuffer row = ByteBuffer.wrap(${"row name"}.getBytes());
    ByteBuffer family = ByteBuffer.wrap(${"columnfamily name"}.getBytes());
    ByteBuffer qualifier = ByteBuffer.wrap(${"qualifier name"}.getBytes());
    ByteBuffer value = ByteBuffer.wrap(${"column value"}.getBytes());

    // 通过 TPut 更新已有数据或插入一个新数据
    System.out.println("---put or update a key---");
    TPut put = new TPut();
    put.setRow(row);
    TColumnValue colVal = new TColumnValue(family, qualifier, value);
    put.setColumnValues(Arrays.asList(colVal));
    client.put(table, put);

    // 通过 TGet 查询指定或全部列及列簇的信息
    System.out.println("---get a row---");
    TGet get = new TGet();
    get.setRow(row);
    TColumn col = new TColumn()
            .setFamily(family)  // 不指定列簇,即是获取所有列簇
            .setQualifier(qualifier); // 不指定列名,即是获取所有列
    get.setColumns(Arrays.asList(col));
    TResult result = client.get(table, get);
    //System.out.println("get row : " + new String(result.getRow()));

    result.getColumnValues().forEach(c -> {
      System.out.println(new String(result.getRow()) + "  " + new String(c.getFamily()) + "_" +
              new String(c.getQualifier()) + ":" + new String(c.getValue()));
    });

    // 通过 TScan 查询全表的信息
    System.out.println("---scan a table---");
    TScan scan = new TScan();
    List<TResult> resultList = client.getScannerResults(table, scan, 2);
    resultList.forEach(r -> r.getColumnValues().forEach(c -> {
      System.out.println(new String(r.getRow()) + "  " + new String(c.getFamily()) + "_" +
              new String(c.getQualifier()) + ":" + new String(c.getValue()));
    }));

    // 通过 close 函数关闭 Thrift2 连接
    transport.close();
    socket.close();
  }

}

表格数据库 HBase 版

前提条件

操作步骤

相关操作