IDEA遠(yuǎn)程連接HBase及其Java API實(shí)戰(zhàn)詳解
更新時(shí)間：2021年04月16日 15:37:53 作者：唔仄lo咚鏘
這篇文章主要介紹了IDEA遠(yuǎn)程連接HBase及其Java API實(shí)戰(zhàn)詳解,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
開放端口
安全組沒開放端口是原罪?。?！導(dǎo)致好多BUG費(fèi)時(shí)費(fèi)力。Hbase悄悄咪咪的用了好多端口，比如被我抓到的42239，直接搜索報(bào)錯(cuò)藥不對(duì)癥。
Hbase安裝
下載壓縮包
可以去官網(wǎng)下載http://hbase.apache.org/downloads.html
也可以去鏡像下載歷史版本http://archive.apache.org/dist/hbase/
以1.3.2版本為例：
直接下載或者下載到本地再上傳都行，看你哪個(gè)快。
wget http://archive.apache.org/dist/hbase/1.3.2/hbase-1.3.2-bin.tar.gz tar -zxvf hbase-1.3.2-bin.tar.gz #解壓 mv hbase-1.3.2-bin /urs/local/hbase
配置hbase-site.xml
cd /usr/local/hbase/conf vi hbase-site.xml
<property>
<name>hbase.cluster.distributed</name>
<value>true</value>
</property>
<property>
<name>hbase.rootdir</name>
<value>/hbase-data</value>
</property>
<property>
<name>hbase.zookeeper.quorum</name>
<value>master:2181</value>
</property>
配置hbase-env.sh
cd /usr/local/hbase/conf echo $JAVA_HOME #若沒有安裝jdk可百度（偷懶） vi hbase-env.sh #添加要一致 export JAVA_HOME=/usr/local/java
運(yùn)行測試
cd /usr/local/hbase/bin ./start-hbase.sh
ip:16010訪問
域名配置
服務(wù)器 vi /etc/hosts
私網(wǎng)ip master
本地 C:\Windows\System32\drivers\etc\hosts
公網(wǎng)ip master
IDEA源碼
目錄結(jié)構(gòu)：
創(chuàng)建一個(gè)maven項(xiàng)目并在pom.xml添加依賴：
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-server</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-client</artifactId>
<version>1.3.2</version>
</dependency>
版本是1.3.2，注意和你自己的一致，可以登錄hbase shell時(shí)查看。
（
插播反爬信息）博主CSDN地址：https://wzlodq.blog.csdn.net/
log4j.properties配置
log4j.rootLogger=debug, stdout, R log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%5p - %m%n log4j.appender.R=org.apache.log4j.RollingFileAppender log4j.appender.R.File=firestorm.log log4j.appender.R.MaxFileSize=100KB log4j.appender.R.MaxBackupIndex=1 log4j.appender.R.layout=org.apache.log4j.PatternLayout log4j.appender.R.layout.ConversionPattern=%p %t %c - %m%n log4j.logger.com.codefutures=DEBUG
hbase-site.xml配置
<?xml version="1.0"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl" rel="external nofollow" ?>
<configuration>
<property>
<name>hbase.cluster.distributed</name>
<value>true</value>
</property>
<property>
<name>hbase.rootdir</name>
<value>/hbase-data</value>
</property>
<property>
<name>hbase.zookeeper.quorum</name>
<value>master:2181</value>
</property>
</configuration>
HBaseCRUD.java
package ex3;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import java.io.IOException;
public class HbaseCRUD {
private static Configuration configuration;
private static Connection connection;
private static Admin admin;
/**
* 建立連接
*/
public static void init(){
configuration=HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum","121.36.240.205"); // 換成你自己的IP
configuration.set("hbase.zookeeper.property.clientPort","2181");
try{
connection=ConnectionFactory.createConnection(configuration);
admin=connection.getAdmin();
}catch (IOException e){
e.printStackTrace();
}
}
/**
* 關(guān)閉連接
*/
public static void close(){
try{
if(admin!=null)
admin.close();
}catch (IOException e){
e.printStackTrace();
}
}
/**
* 創(chuàng)建表
* @param myTableName 表名
* @param colFamily 列族數(shù)組
* @throws IOException
*/
public static void createTable(String myTableName,String[]colFamily)throws IOException{
TableName tablename = TableName.valueOf(myTableName);
if(admin.tableExists(tablename)){
System.out.println("表名已存在！");
}
else{
HTableDescriptor hTableDescriptor = new HTableDescriptor(tablename);
for(String str:colFamily){ //增加一列
HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);
hTableDescriptor.addFamily(hColumnDescriptor);
}
admin.createTable(hTableDescriptor); //建表
}
}
/**
* 添加數(shù)據(jù)
* @param tablename 表名
* @param rowKey 行鍵
* @param colFamily 列族
* @param col 列限定符
* @param val 數(shù)據(jù)
* @throws IOException
*/
public static void insertData(String tablename,String rowKey,String colFamily,String col,String val)throws IOException{
Table table = connection.getTable(TableName.valueOf(tablename));//獲取表名
Put put = new Put(rowKey.getBytes());
put.addColumn(colFamily.getBytes(),col.getBytes(),val.getBytes());
table.put(put);
table.close();
}
/**
* 獲取數(shù)據(jù)
* @param tablename 表名
* @param rowKey 行鍵
* @param colFamily 列族
* @param col 列限定符
* @throws IOException
*/
public static void getData(String tablename,String rowKey,String colFamily,String col)throws IOException{
Table table = connection.getTable(TableName.valueOf(tablename));
Get get = new Get(rowKey.getBytes());
get.addColumn(colFamily.getBytes(),col.getBytes());
Result result = table.get(get);
String val = new String(result.getValue(colFamily.getBytes(),col==null?null:col.getBytes()));
System.out.println("值為："+val);
table.close();
}
}
Client.java
package ex3;
import org.apache.log4j.BasicConfigurator;
import java.io.IOException;
public class Client {
public static void main(String[] args) throws IOException {
HbaseCRUD.init();
//建表
HbaseCRUD.createTable("student",new String[]{"score"});
//插入數(shù)據(jù)
HbaseCRUD.insertData("student","lisa","score","Java","85");
HbaseCRUD.insertData("student","lisa","score","C/C++","80");
HbaseCRUD.insertData("student","lisa","score","MySQL","82");
HbaseCRUD.insertData("student","jerry","score","Java","65");
//查詢數(shù)據(jù)
HbaseCRUD.getData("student","lisa","score","Java");
HbaseCRUD.getData("student","lisa","score","MySQL");
HbaseCRUD.getData("student","jerry","score","Java");
HbaseCRUD.close();
System.out.println("記得一鍵三連~");
}
}
點(diǎn)擊運(yùn)行后需要點(diǎn)耐心等待，灰色I(xiàn)NFO、DEBUG信息都可不用管，報(bào)錯(cuò)的話會(huì)是紅色字體（評(píng)論區(qū)交流），有tomcat內(nèi)味了。
原創(chuàng)不易，請(qǐng)勿轉(zhuǎn)載（
本不富裕的訪問量雪上加霜）
博主首頁：https://wzlodq.blog.csdn.net/
到此這篇關(guān)于IDEA遠(yuǎn)程連接HBase及其Java API實(shí)戰(zhàn)的文章就介紹到這了,更多相關(guān)idea連接HBase內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了java簡單坦克大戰(zhàn)制作代碼,利用Java語言中的集合、Swing、線程等知識(shí)點(diǎn)編寫一個(gè)坦克大戰(zhàn)游戲，需要的朋友可以參考下2016-07-07
這篇文章主要為大家詳細(xì)介紹了Springboot整合pagehelper分頁功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-12-12
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)猜數(shù)游戲代碼，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-12-12
JVM將class文件字節(jié)碼文件加載到內(nèi)存中， 并將這些靜態(tài)數(shù)據(jù)轉(zhuǎn)換成方法區(qū)中的運(yùn)行時(shí)數(shù)據(jù)結(jié)構(gòu)，在堆(并不一定在堆中，HotSpot在方法區(qū)中)中生成一個(gè)代表這個(gè)類的java.lang.Class 對(duì)象，作為方法區(qū)類數(shù)據(jù)的訪問入口，接下來將詳細(xì)講解JVM類加載機(jī)制2021-11-11
Java中java.lang.ClassCastException異常原因及解決方法
大家好，本篇文章主要講的是Java中java.lang.ClassCastException異常原因及解決方法，感興趣的同學(xué)趕快來看一看吧，對(duì)你有幫助的話記得收藏一下2022-01-01
java工具類static靜態(tài)方法讀取yml配置過程
文章介紹了在工具類中獲取YAML配置時(shí)遇到的問題,由于變量是靜態(tài)的,而Spring加載靜態(tài)方法比IOC容器早,導(dǎo)致無法直接使用@Value注解讀取YAML配置,從而讀取結(jié)果為null2024-11-11
手把手教你搭建第一個(gè)Spring Batch項(xiàng)目的步驟
這篇文章主要介紹了手把手教你搭建第一個(gè)Spring Batch項(xiàng)目的步驟，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
這篇文章主要為大家詳細(xì)介紹了Java多線程實(shí)現(xiàn)復(fù)制文件，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-03-03
SpringBoot異步使用@Async的原理以及線程池配置詳解
在項(xiàng)目中當(dāng)訪問其他人的接口較慢時(shí),不想程序一直卡在耗時(shí)任務(wù)上,想程序能夠并行執(zhí)行,我們可以使用多線程來并行的處理任務(wù),也可以使用spring提供的異步處理方式@Async,這篇文章主要給大家介紹了關(guān)于SpringBoot異步使用@Async的原理以及線程池配置的相關(guān)資料2021-09-09
這篇文章主要介紹了JAVA中的Configuration類詳解，具有一定借鑒價(jià)值,需要的朋友可以參考下2018-01-01