在IDEA使用HBase Java API连接

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

官网地址:Maven – Download Apache Maven

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

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

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

<localRepository>D:\\Develop\\maven\\LocalwarehouselocalRepository>

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

<mirror>
	<id>alimavenid>
	<mirrorOf>centralmirrorOf>
	<name>aliyun mavenname>
	<url>http://maven.aliyun.com/nexus/content/repositories/central/url>
mirror>

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

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

 将maven加载到IDEA中：

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

1、新建项目

2、创建Maven项目

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

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

<dependencies>
    
    <dependency>
        <groupId>org.apache.hbasegroupId>
        <artifactId>hbase-clientartifactId>
        <version>2.5.6version>
    dependency>
dependencies>

四、创建HBase连接

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

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

package com.xnzy;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import java.io.IOException;
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、获取一个DDL操作的HBase客户端Admin
        Admin admin = connection.getAdmin();
        // 5、判断一张表是否存在
        System.out.println(admin.tableExists(TableName.valueOf("hbase:meta")));
        System.out.println(connection);
        //6.关闭连接
        admin.close();
        connection.close();
    }
}

运行结果：