在IDEA使用HBase Java API连接

一、下载安装Maven并加载到IDEA中

官网地址:Maven – Download Apache Maven

将对应版本的压缩包下载到本地,并新建一个文件夹Localwarehouse，用来保存下载的依赖文件

配置maven的系统环境配置，将maven安装的bin目录地址写入path环境变量：

打开maven安装包下的conf文件夹下面的settings.xml，配置本地仓库（开始新建的文件夹Localwarehouse），本地仓库其实起到了一个缓存的作用，具体代码如下：

<localRepository>D:\\Develop\\maven\\Localwarehouse</localRepository>

在settings.xml配置文件中找到mirrors节点，添加阿里云仓库代码，具体代码如下配置（注意要添加在<mirrors>和</mirrors>两个标签之间）：

<!-- 阿里云仓库 -->
<mirror>
	<id>alimaven</id>
	<mirrorOf>central</mirrorOf>
	<name>aliyun maven</name>
	<url>http://maven.aliyun.com/nexus/content/repositories/central/</url>
</mirror>

添加如下代码用来配置jdk版本：

   <profile>
    <id>jdk-1.8.0</id>
    <activation>
    <activeByDefault>true</activeByDefault>
    <jdk>1.8.0</jdk>
    </activation>
    <properties>
    <maven.compiler.source>1.8.0</maven.compiler.source>
    <maven.compiler.target>1.8.0</maven.compiler.target>
    <maven.compiler.compilerVersion>1.8.0</maven.compiler.compilerVersion>
    </properties>
   </profile>

将maven加载到IDEA中：

二、打开IDEA软件，创建maven项目

1、新建项目

2、创建Maven项目

3、给项目起名字并完成项目的创建

三、在pom.xml文件中添加依赖

<dependencies>
    <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client -->
    <dependency>
        <groupId>org.apache.hbase</groupId>
        <artifactId>hbase-client</artifactId>
        <version>2.5.6</version>
    </dependency>
</dependencies>

四、创建HBase连接

根据官方 API 介绍，HBase 的客户端连接由 ConnectionFactory 类来创建，用户使用完成之后需要手动关闭连接。以下是单线程创建连接的代码：

首先在java文件夹下新建一个java类文件（HbaseConnection.java），在com.xnzy包下：

package com.xnzy;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.AsyncConnection;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.CompletableFuture;

public class HbaseConnection {
    public static void main(String[] args) throws IOException{
        //1.创建连接配置对象
        Configuration conf = new Configuration();
        //2.添加配置参数
        conf.set("hbase.zookeeper.quorum","hadoop");
         //3.创建连接
        Connection connection = ConnectionFactory.createConnection(conf);
        //4.使用连接
        System.out.println(connection);
        //5.关闭连接
        connection.close();
    }
}

运行结果：