安全組沒開放端口是原罪?。?！導(dǎo)致好多BUG費(fèi)時費(fèi)力。Hbase悄悄咪咪的用了好多端口，比如被我抓到的42239，直接搜索報錯藥不對癥。

下載壓縮包可以去官網(wǎng)下載http://hbase.apache.org/downloads.html也可以去鏡像下載歷史版本http://archive.apache.org/dist/hbase/以1.3.2版本為例：

直接下載或者下載到本地再上傳都行，看你哪個快。

wget http://archive.apache.org/dist/hbase/1.3.2/hbase-1.3.2-bin.tar.gztar -zxvf hbase-1.3.2-bin.tar.gz #解壓mv hbase-1.3.2-bin /urs/local/hbase

配置hbase-site.xml

cd /usr/local/hbase/confvi 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/confecho $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:WindowsSystem32driversetchosts公網(wǎng)ip master

目錄結(jié)構(gòu)：

創(chuàng)建一個maven項目并在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時查看。

（插播反爬信息 ）博主CSDN地址：https://wzlodq.blog.csdn.net/

log4j.properties配置

log4j.rootLogger=debug, stdout, Rlog4j.appender.stdout=org.apache.log4j.ConsoleAppenderlog4j.appender.stdout.layout=org.apache.log4j.PatternLayoutlog4j.appender.stdout.layout.ConversionPattern=%5p - %m%nlog4j.appender.R=org.apache.log4j.RollingFileAppenderlog4j.appender.R.File=firestorm.loglog4j.appender.R.MaxFileSize=100KBlog4j.appender.R.MaxBackupIndex=1log4j.appender.R.layout=org.apache.log4j.PatternLayoutlog4j.appender.R.layout.ConversionPattern=%p %t %c - %m%nlog4j.logger.com.codefutures=DEBUG

hbase-site.xml配置

<?xml version='1.0'?><?xml-stylesheet type='text/xsl' href='http://www.b3g6.com/bcjs/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'); // 換成你自己的IPconfiguration.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信息都可不用管，報錯的話會是紅色字體（評論區(qū)交流），有tomcat內(nèi)味了。

原創(chuà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)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！