HBase 2.2.6安装及编程实践（基于deepin 20.1社区版&Hadoop 3.1.3）

野性酷女 2022-11-17 05:13 160阅读 0赞

> 参考资料：[HBase2.2.2安装和编程实践指南 厦大数据库实验室博客][HBase2.2.2_]  
> 配置过程中所需资源：  
> HBase 2.2.6安装文件[链接][Link 1]（提取码：of9o）

### 目录 ###

*  安装并配置HBase 2.2.6
 *   *  HBase 2.2.6安装
     *  HBase配置
     *   *  单机模式配置
         *  伪分布式模式配置
 *  编程实践
 *   *  利用HBase Shell命令
     *  HBase Java API编程

# 安装并配置HBase 2.2.6 #

## HBase 2.2.6安装 ##

HBase 2.2.6的安装文件保存在`/home/hadoop/Downloads/`目录下。  
解压hbase-2.2.6-bin.tar.gz文件：

$ cd ~/Downloads/
    $ sudo tar -zxf ./hbase-2.2.6-bin.tar.gz -C /usr/local/

将解压的目录名称修改为`hbase`方便使用，并将权限赋予hadoop用户：

$ cd /usr/local/
    $ sudo mv ./hbase-2.2.6 ./hbase
    $ sudo chown -R hadoop ./hbase

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70]  
配置环境变量：

$ vim ~/.bashrc

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 1]  
使上述配置生效：

$ source ~/.bashrc

添加HBase权限：

$ sudo chown -R hadoop ./hbase

查看HBase版本，如果终端返回HBase版本号即为安装成功：

$ ./hbase/bin/hbase version

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 2]

## HBase配置 ##

### 单机模式配置 ###

编辑`/usr/local/hbase/conf/hbase-env.sh`，配置Java环境变量，并添加配置`HBASE_MANAGES_ZK`为`true`：

$ vim /usr/local/hbase/conf/hbase-env.sh

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 3]  
在启动HBase前需要设置属性`hbase.rootdir`，用于指定HBase数据的存储位置，因为如果不设置的话，`hbase.rootdir`默认为`/tmp/hbase-${user.name}`,这意味着每次重启系统都会丢失数据。此处设置为HBase安装目录下的`hbase-tmp`文件夹，即`/usr/local/hbase/hbase-tmp`。  
配置`/usr/local/hbase/conf/hbase-site.xml`：

$ vim /usr/local/hbase/conf/hbase-site.xml

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 4]

测试运行HBase：

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

在HBase Shell中，输入`exit`即可退出。  
停止HBase运行：

$ ./bin/stop-hbase.sh

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 5]

### 伪分布式模式配置 ###

配置`/usr/local/hbase/conf/hbase-env.sh`：

$ vim /usr/local/hbase/conf/hbase-env.sh

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 6]  
配置`/usr/local/hbase/conf/hbase-site.xml`：

$ vim /usr/local/hbase/conf/hbase-site.xml

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 7]  
接下来测试运行HBase。  
登录SSH，启动Hadoop：

$ ssh localhost
    $ cd /usr/local/hadoop/
    $ ./sbin/start-dfs.sh
    $ jps

启动HBase：

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

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 8]  
进入HBase Shell：

$ ./bin/hbase shell

在HBase Shell中，输入`exit`即可退出。  
停止HBase运行：

$ ./bin/stop-hbase.sh

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 9]  
**注意**：这里启动关闭Hadoop和HBase的顺序一定是“启动Hadoop—>启动HBase—>关闭HBase—>关闭Hadoop”。

# 编程实践 #

## 利用HBase Shell命令 ##

<table> 
 <thead> 
  <tr> 
   <th>操作</th> 
   <th>命令</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>创建表</td> 
   <td><code>create</code></td> 
  </tr> 
  <tr> 
   <td>查看表的基本信息</td> 
   <td><code>describe</code></td> 
  </tr> 
  <tr> 
   <td>添加数据</td> 
   <td><code>put</code></td> 
  </tr> 
  <tr> 
   <td>删除一个数据</td> 
   <td><code>delete</code></td> 
  </tr> 
  <tr> 
   <td>删除一行数据</td> 
   <td><code>deleteall</code></td> 
  </tr> 
  <tr> 
   <td>查看表的某一行数据</td> 
   <td><code>get</code></td> 
  </tr> 
  <tr> 
   <td>查看表的全部数据</td> 
   <td><code>scan</code></td> 
  </tr> 
  <tr> 
   <td>使表不可用</td> 
   <td><code>disable</code></td> 
  </tr> 
  <tr> 
   <td>删除表</td> 
   <td><code>drop</code></td> 
  </tr> 
 </tbody> 
</table>

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 10]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 11]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 12]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 13]

## HBase Java API编程 ##

启动Eclipse，指定Workspace为`/home/hadoop/workspace`，新建Java工程：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 14]  
点击“Libraries”选项卡，然后点击“Add External JARs…”，向Java工程中加入以下JAR包：

*  `/usr/local/hbase/lib`目录下的所有JAR包（注意：不包括目录`client-facing-thirdparty`、`ruby`、`shaded-clients`和`zkcli`）。
 *  `/usr/local/hbase/lib/client-facing-thirdparty`目录下的所有JAR包。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 15]  
新建Java Class：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 16]  
启动Hadoop和HBase：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 17]  
ExampleForHBase.java代码如下：

import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.*;
    import org.apache.hadoop.hbase.client.*;
    import org.apache.hadoop.hbase.util.Bytes;
    
    import java.io.IOException;
    
    public class ExampleForHBase { 
        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://localhost:9000/hbase");
            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("table 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();
        }
    }

点击上方“Run”选项卡，选择“Run As”，点击“1 Java Application”，运行程序：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 18]  
在HBase Shell中查看表是否创建成功：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 19]

[HBase2.2.2_]: http://dblab.xmu.edu.cn/blog/2442-2/
[Link 1]: https://pan.baidu.com/s/1lIePW8UD9C1V6tVO-Oea0w
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70]: /images/20221022/b9031742211048d5bfae12631e8bd166.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 1]: /images/20221022/7bf64ffa58bb452b8b717794818c6f19.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 2]: /images/20221022/71dedf28f7d6465692a66caaeb9415b2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 3]: /images/20221022/7a14234f3f834ee1906672a4f72c7c3c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 4]: /images/20221022/c0d415b7da924d66a391327c74ee4c87.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 5]: /images/20221022/311c1433271342bebb192188c5adaabd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 6]: /images/20221022/9d01869bb0ae491ebb00ac93b1f4b3ed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 7]: /images/20221022/d08a066760fb47729cc7f0681dc5323f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 8]: /images/20221022/2a8d31a117504d9f8998e74a3b377b46.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 9]: /images/20221022/9ad4a66a688b4a29a2467a1bc51a5dff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 10]: /images/20221022/c8472b06086c4759a69d66794a83984f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 11]: /images/20221022/5c177c3b8e02424aa7f2e46474c3b012.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 12]: /images/20221022/e80ae6df5b3d4b69a4befc868bdf77e3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 13]: /images/20221022/f4e4d183b0674d4b9706a82b60024012.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 14]: /images/20221022/542f5dc179624b96853a1e70ede3a098.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 15]: /images/20221022/5a3f13a163de4894b1963b9bf55bb035.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 16]: /images/20221022/2f7b9d75eee7420195dab93b0c5e7d92.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 17]: /images/20221022/4b8bae994e81489ab0def8047aa676c2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 18]: /images/20221022/6027c7b1778a4acab824cf22df8c9bb6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ1NTU0MDEw_size_16_color_FFFFFF_t_70 19]: /images/20221022/638c346c11a64e1597d1fc2ee9140c2b.png