java 读取hbase_HBase读写的几种方式（一）java篇

1.HBase读写的方式概况

主要分为：

纯Java API读写HBase的方式；

Spark读写HBase的方式；

Flink读写HBase的方式；

HBase通过Phoenix读写的方式；

第一种方式是HBase自身提供的比较原始的高效操作方式，而第二、第三则分别是Spark、Flink集成HBase的方式，最后一种是第三方插件Phoenix集成的JDBC方式，Phoenix集成的JDBC操作方式也能在Spark、Flink中调用。

注意：

这里我们使用HBase2.1.2版本，以下代码都是基于该版本开发的。

2. 纯Java API读写HBase

2.1 连接HBase

这里我们采用静态方式连接HBase，不同于2.1.2之前的版本，无需创建HBase线程池，HBase2.1.2提供的代码已经封装好，只需创建调用即可：

/**

* 声明静态配置

*/

static Configuration conf = null;

static Connection conn = null;

static {

conf = HBaseConfiguration.create();

conf.set("hbase.zookeeper.quorum", "hadoop01,hadoop02,hadoop03");

conf.set("hbase.zookeeper.property.client", "2181");

try{

conn = ConnectionFactory.createConnection(conf);

}catch (Exception e){

e.printStackTrace();

}

}

2.2 创建HBase的表

创建HBase表，是通过Admin来执行的，表和列簇则是分别通过TableDescriptorBuilder和ColumnFamilyDescriptorBuilder来构建。

/**

* 创建只有一个列簇的表

* @throws Exception

*/

public static void createTable() throws Exception{

Admin admin = conn.getAdmin();

if (!admin.tableExists(TableName.valueOf("test"))){

TableName tableName = TableName.valueOf("test");

//表描述器构造器

TableD