欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

docker?部署hbase并且java?Api連接的操作過程

 更新時間:2023年11月23日 11:35:32   作者:藍胖子不是胖子  
這篇文章主要介紹了docker?部署hbase并且java?Api連接的操作過程,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友參考下吧

1.首先先運行容器

docker run -d --name hbase -p 2181:2181 -p 16010:16010 -p16000:16000 -p 16020:16020 -p 16030:16030 harisekhon/hbase

2.在本機的hosts中注冊docker的id
因為docker內(nèi)部集成了其他環(huán)境而其他環(huán)境 中的ip是docker id 所以需要在hosts中轉(zhuǎn)換

192.168.80.120	dockerhbase sa445is094a

3.客戶端連接依賴

<dependencies>
            <!--        hbaseClient依賴包,需要排除日志log4j,不然和springboot的沖突了-->
                <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client -->
                <dependency>
                    <groupId>org.apache.hbase</groupId>
                    <artifactId>hbase-client</artifactId>
                    <version>2.5.4</version>
                    <exclusions>
                        <exclusion>
                            <groupId>org.slf4j</groupId>
                            <artifactId>slf4j-log4j12</artifactId>
                        </exclusion>
                    </exclusions>
                </dependency>
                <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase -->
                <dependency>
                    <groupId>org.apache.hbase</groupId>
                    <artifactId>hbase</artifactId>
                    <version>2.5.4</version>
                    <type>pom</type>
                </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.17</version>
            </dependency>
        </dependencies>

倆個依賴出現(xiàn)log4j的依賴申明錯誤,所以這里需要排除,并且新建一個properties后綴的配置文件

log4j.rootLogger=debug, stdout, R
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
# Pattern to output the caller's file name and line number.
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] (%F:%L) - %m%n
log4j.appender.R=org.apache.log4j.RollingFileAppender
log4j.appender.R.File=example.log
log4j.appender.R.MaxFileSize=100KB
# Keep one backup file
log4j.appender.R.MaxBackupIndex=5
log4j.appender.R.layout=org.apache.log4j.PatternLayout
log4j.appender.R.layout.ConversionPattern=%p %t %c - %m%n

4.java api 調(diào)用

public class Practice4 {
        public static Configuration configuration;
        public static Connection connection;
        public static Admin admin;
        public static void main(String[] args)throws IOException{
            init();
            createTable("student",new String[]{"score"});
            insertData("student","zhangsan","score","English","69");
            insertData("student","zhangsan","score","Math","86");
            insertData("student","zhangsan","score","Computer","77");
            getData("student", "zhangsan", "score","English");
            close();
        }
        public static void init(){
            configuration  = HBaseConfiguration.create();
//            configuration.set("hbase.rootdir","hdfs://192.168.249.132:8020/");
            configuration.set("hbase.zookeeper.quorum", "192.168.249.132");
            configuration.set("hbase.zookeeper.property.clientPort", "2181");
            try{
                connection = ConnectionFactory.createConnection(configuration);
                admin = connection.getAdmin();
            }catch (IOException e){
                e.printStackTrace();
            }
        }
        public static void close(){
            try{
                if(admin != null){
                    admin.close();
                }
                if(null != connection){
                    connection.close();
                }
            }catch (IOException e){
                e.printStackTrace();
            }
        }
        public static void createTable(String myTableName,String[] colFamily) throws IOException {
            TableName tableName = TableName.valueOf(myTableName);
            if(admin.tableExists(tableName)){
                System.out.println("talbe is exists!");
            }else {
                TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);
                for(String str:colFamily){
                    ColumnFamilyDescriptor family =
                            ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build();
                    tableDescriptor.setColumnFamily(family);
                }
                admin.createTable(tableDescriptor.build());
            }
        }
        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();
        }
        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);
            System.out.println(new String(result.getValue(colFamily.getBytes(),col==null?null:col.getBytes())));
            table.close();
        }
    }

到此這篇關(guān)于docker 部署hbase 并且java Api連接的文章就介紹到這了,更多相關(guān)docker 部署hbase內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • docker私庫Harbor的架構(gòu)與組件說明

    docker私庫Harbor的架構(gòu)與組件說明

    今天小編就為大家分享一篇關(guān)于docker私庫Harbor的架構(gòu)與組件說明,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價值,需要的朋友一起跟隨小編來看看吧
    2018-12-12
  • 前端項目容器化Docker打包部署方式詳解

    前端項目容器化Docker打包部署方式詳解

    這篇文章主要為大家介紹了前端項目容器化Docker打包部署方式詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-11-11
  • 如何使用Docker Desktop進行本地打包和推送

    如何使用Docker Desktop進行本地打包和推送

    本文給大家介紹如何使用Docker Desktop進行本地打包和推送,本文給大家介紹的非常詳細,感興趣的朋友一起看看吧
    2025-04-04
  • 使用Docker創(chuàng)建FTP服務(wù)器的過程解析

    使用Docker創(chuàng)建FTP服務(wù)器的過程解析

    這篇文章主要介紹了使用Docker創(chuàng)建FTP服務(wù)器的過程解析,使用?Docker?搭建?FTP?服務(wù),不僅十分簡單,而且可以對宿主機有一定的隔離,對Docker創(chuàng)建FTP服務(wù)器的過程感興趣的朋友一起看看吧
    2022-04-04
  • docker容器時區(qū)錯誤問題

    docker容器時區(qū)錯誤問題

    常出現(xiàn)docker中運行的容器獲取到的時間與北京時間相差8小時的問題,其實是因為容器運行的時區(qū)不正確。本文主要介紹了docker容器時區(qū)錯誤問題,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-12-12
  • 詳解docker pull 下來的鏡像文件存放的位置

    詳解docker pull 下來的鏡像文件存放的位置

    本篇文章主要介紹了詳解docker pull 下來的鏡像文件存放的位置,具有一定的參考價值,有興趣的可以了解一下。
    2017-04-04
  • 在CentOS 7上安裝Docker環(huán)境的方法與注意事項

    在CentOS 7上安裝Docker環(huán)境的方法與注意事項

    這篇文章主要介紹了在CentOS 7上安裝Docker環(huán)境的方法與注意事項,需要的朋友可以參考下
    2016-10-10
  • Docker常見命令整理匯總(包括鏡像命令、容器命令)

    Docker常見命令整理匯總(包括鏡像命令、容器命令)

    這篇文章主要給大家介紹了關(guān)于Docker常見命令整理匯總的相關(guān)資料,包括鏡像命令、容器命令等等,通過一個個示例來加深各位看官對docker相關(guān)命令的理解以及記憶,需要的朋友可以參考下
    2022-07-07
  • 一文詳解如何修改Docker的默認存儲路徑

    一文詳解如何修改Docker的默認存儲路徑

    這篇文章主要介紹了關(guān)于如何修改Docker的默認存儲路徑的相關(guān)資料,默認安裝的情況下,會使用 /var/lib/docker/ 目錄作為存儲目錄,用以存放拉取的鏡像和創(chuàng)建的容器等,這個路徑是系統(tǒng)存儲目錄,一般空間會比較小,需要的朋友可以參考下
    2023-08-08
  • Docker使用Prune命令清理none鏡像

    Docker使用Prune命令清理none鏡像

    本文主要介紹了Docker使用Prune命令清理none鏡像,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-10-10

最新評論