亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

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)詳解,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

在這里插入圖片描述

開(kāi)放端口

安全組沒(méi)開(kāi)放端口是原罪！??！導(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 #若沒(méi)有安裝jdk可百度（偷懶）
vi hbase-env.sh #添加要一致
export JAVA_HOME=/usr/local/java

在這里插入圖片描述
在這里插入圖片描述

運(yùn)行測(cè)試

cd /usr/local/hbase/bin
./start-hbase.sh

在這里插入圖片描述
在這里插入圖片描述

ip:16010訪問(wèn)

在這里插入圖片描述

域名配置

服務(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)載（本不富裕的訪問(wèn)量雪上加霜 ）
博主首頁(yè)：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使用IntelliJ IDEA連接MySQL的詳細(xì)教程

    Java使用IntelliJ IDEA連接MySQL的詳細(xì)教程

    這篇文章主要給大家介紹了關(guān)于Java使用IntelliJ IDEA連接MySQL的相關(guān)資料，文中通過(guò)圖文介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-04-04
  • springboot redis分布式鎖代碼實(shí)例

    springboot redis分布式鎖代碼實(shí)例

    這篇文章主要介紹了springboot redis分布式鎖代碼實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-12-12
  • Mybatis?plugin的使用及原理示例解析

    Mybatis?plugin的使用及原理示例解析

    這篇文章主要為大家介紹了?Mybatis?plugin的使用及原理示例解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-09-09
  • ?Java數(shù)據(jù)結(jié)構(gòu)的十大排序

    ?Java數(shù)據(jù)結(jié)構(gòu)的十大排序

    這篇文章主要介紹了?Java數(shù)據(jù)結(jié)構(gòu)的十大排序，排序算法分為比較類排序和非比較類排序，具體的內(nèi)容，需要的朋友參考下面思維導(dǎo)圖及文章介紹，希望對(duì)你有所幫助
    2022-01-01
  • java基于UDP實(shí)現(xiàn)圖片群發(fā)功能

    java基于UDP實(shí)現(xiàn)圖片群發(fā)功能

    這篇文章主要為大家詳細(xì)介紹了java基于UDP實(shí)現(xiàn)圖片群發(fā)功能，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2019-01-01
  • 淺談JavaIO之try with底層原理

    淺談JavaIO之try with底層原理

    眾所周知，所有被打開(kāi)的系統(tǒng)資源，比如流、文件或者Socket連接等，都需要被開(kāi)發(fā)者手動(dòng)關(guān)閉，否則隨著程序的不斷運(yùn)行，資源泄露將會(huì)累積成重大的生產(chǎn)事故。本文將介紹JavaIO之try with底層原理。
    2021-06-06
  • Maven中optional標(biāo)簽用法詳解

    Maven中optional標(biāo)簽用法詳解

    這篇文章主要介紹了Maven中optional標(biāo)簽，文章中有詳細(xì)的代碼示例供大家參考，對(duì)大家的學(xué)習(xí)或工作有一定的參考價(jià)值，感興趣的小伙伴可以借鑒一下
    2023-05-05
  • SpringBoot 導(dǎo)出數(shù)據(jù)生成excel文件返回方式

    SpringBoot 導(dǎo)出數(shù)據(jù)生成excel文件返回方式

    這篇文章主要介紹了SpringBoot 導(dǎo)出數(shù)據(jù)生成excel文件返回方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-10-10
  • Java實(shí)現(xiàn)Word/Excel/TXT轉(zhuǎn)PDF的方法

    Java實(shí)現(xiàn)Word/Excel/TXT轉(zhuǎn)PDF的方法

    這篇文章主要介紹了Java實(shí)現(xiàn)Word/Excel/TXT轉(zhuǎn)PDF的方法，本文給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-01-01
  • Java中equals()方法實(shí)例詳解

    Java中equals()方法實(shí)例詳解

    equals方法是java.lang.Object類的方法,下面這篇文章主要給大家介紹了關(guān)于Java中equals()方法的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2021-12-12

最新評(píng)論