行业知识
在IDEA使用HBase Java API连接
2026-10-25 07:21:34
来源:互联网转载
一、下载安装Maven并加载到IDEA中
官网地址:Maven – Download Apache Maven
将对应版本的压缩包下载到本地,并新建一个文件夹Localwarehouse,用来保存下载的依赖文件
配置maven的系统环境配置,将maven安装的bin目录地址写入path环境变量:
打开maven安装包下的conf文件夹下面的settings.xml,配置本地仓库(开始新建的文件夹Localwarehouse),本地仓库其实起到了一个缓存的作用,具体代码如下:
D:\Develop\maven\Localwarehouse
在settings.xml配置文件中找到mirrors节点,添加阿里云仓库代码,具体代码如下配置(注意要添加在和两个标签之间):
alimavencentralaliyun mavenhttp://maven.aliyun.com/nexus/content/repositories/central/
添加如下代码用来配置jdk版本:
jdk-1.8.0 true 1.8.0 1.8.0 1.8.0 1.8.0
将maven加载到IDEA中:
二、打开IDEA软件,创建maven项目
1、新建项目
2、创建Maven项目
3、给项目起名字并完成项目的创建
三、在pom.xml文件中添加依赖
org.apache.hbase hbase-client 2.5.6
四、创建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(); }} 运行结果:
上一篇:lol怎么去其他服务器?
下一篇:贵州智能机房哪里买?