0
0

hbase单机版(依赖于内置的zookeeper)安装配置及详细使用教程

  1. 环境准备：ubantu、 jdk1.8+、 hbase 2.6.0

    前提：安装的hbase不依赖于hadoop，且使用hbase内置的zookeeper，不依赖于外部zookeeper

  2. 安装步骤：

安装jdk

下载解压安装hbase

配置jdk环境变量

  1. 配置hbase两个核心文件hbase-env.sh和hbase-site.xml

    1.  3.1 hbase-env.sh 文件添加如下两个配置：
    3.      配置hbase的依赖jdk:
    4.       export JAVA_HOME=/home/soft/java8
    5.   单机版不依赖于外部zookeeper:
    6.       export HBASE_MANAGES_ZK=true
    8.  3.2 hbase-site.xml 完整配置如下
  1. <configuration>
  2.   <property>
  3.     <name>hbase.rootdir</name>
  4.     <value>file:///home/data/hbase</value>
  5.   </property>
  6.   <property>
  7.     <name>hbase.zookeeper.property.dataDir</name>
  8.     <value>/home/data/zookeeper</value>
  9.   </property>
  10.   <property>
  11.     <name>hbase.unsafe.stream.capability.enforce</name>
  12.     <value>false</value>
  13.   </property>
  14.   <property>
  15.      <name>hbase.master.ipc.address</name>
  16.      <value>0.0.0.0</value>
  17.   </property>
  18.   <property>
  19.       <name>hbase.regionserver.ipc.address</name>
  20.       <value>0.0.0.0</value>
  21.   </property>
  22.   <!-- hbaseserver 内置的zookeeper名称-->
  23.   <property>
  24.       <name>hbase.zookeeper.quorum</name>
  25.       <value>hbaseserver</value>
  26.  </property>
  27.  <property>
  28.    <name>hbase.zookeeper.property.clientPort</name>
  29.    <value>2181</value>
  30.  </property>
  31.  <property>
  32.    <name>hbase.master.info.port</name>
  33.    <value>16010</value>
  34.  </property>
  35.  <property>
  36.      <name>hbase.regionserver.port</name>
  37.      <value>16020</value>
  38.  </property>
  39.  <property>
  40.   <name>hbase.regionserver.info.port</name>
  41.   <value>16030</value>
  42. </property>
  43.  
  44. </configuration>

  1. hbase2单机是不支持远程客户端连接，所以还需要如下2个操作

    1.  4.1 参考如下文章进行2181端口映射
    3.  hbase远程客户端连接单机hbase2.4.15-CSDN博客
    5.  我的101.132.146.244(是安装hbase单机版本的阿里云服务器IP地址)服务器的rinetd.conf文件配置如下：

4.2 同时还需要进行hostname的操作(安装hbase的远程服务器101.132.146.244)：

1、因为hbase默认通过hostname去找ip然后将这个ip注册到zookeeper中作为hbase单机服务的ip地址。所以我们需要修改/etc/hosts文件。并设置本地域名为hbaseserver。（101.132.146.244是安装hbase单机版本的阿里云服务器IP地址)


2、在自己windows端修改hosts文件 文件路径： C:\Windows\System32\drivers\etc
添加上这一行：
101.132.146.244 hbaseserver

本地可以telnet成功即端口映射配置成功：

5.java连接hbase测试类

  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.*;
  4. import org.apache.hadoop.hbase.client.*;
  5. import java.io.IOException;
  7. public class TestExampleForHbase {
  8.     public static Configuration configuration;
  9.     public static Connection connection;
  10.     public static Admin admin;
  12.     //主函数中的语句请逐句执行，只需删除其前的//即可，如：执行insertRow时请将其他语句注释
  13.     public static void main(String[] args)throws IOException{
  14.         //创建一个表，表名为Score，列族为sname,course
  15.         createTable("test:Score",new String[]{"sname","course"});
  17.         //在Score表中插入一条数据，其行键为95001,sname为Mary（因为sname列族下没有子列所以第四个参数为空）
  18.         //等价命令：put 'Score','95001','sname','Mary'
  19.         insertRow("test:Score", "95001", "sname", "", "Mary");
  20.         //在Score表中插入一条数据，其行键为95001,course:Math为88（course为列族，Math为course下的子列）
  21.         //等价命令：put 'Score','95001','score:Math','88'
  22.         insertRow("test:Score", "95001", "course", "Math", "88");
  23.         //在Score表中插入一条数据，其行键为95001,course:English为85（course为列族，English为course下的子列）
  24.         //等价命令：put 'Score','95001','score:English','85'
  25.         insertRow("test:Score", "95001", "course", "English", "85");
  27.         //1、删除Score表中指定列数据，其行键为95001,列族为course，列为Math
  28.         //执行这句代码前请deleteRow方法的定义中，将删除指定列数据的代码取消注释注释，将删除制定列族的代码注释
  29.         //等价命令：delete 'Score','95001','score:Math'
  30.         //deleteRow("Score", "95001", "course", "Math");
  32.         //2、删除Score表中指定列族数据，其行键为95001,列族为course（95001的Math和English的值都会被删除）
  33.         //执行这句代码前请deleteRow方法的定义中，将删除指定列数据的代码注释，将删除制定列族的代码取消注释
  34.         //等价命令：delete 'Score','95001','score'
  35.         //deleteRow("Score", "95001", "course", "");
  37.         //3、删除Score表中指定行数据，其行键为95001
  38.         //执行这句代码前请deleteRow方法的定义中，将删除指定列数据的代码注释，以及将删除制定列族的代码注释
  39.         //等价命令：deleteall 'Score','95001'
  40.         //deleteRow("Score", "95001", "", "");
  41.         
  42.         //查询Score表中，行键为95001，列族为sname的值（因为sname列族下没有子列所以第四个参数为空）
  43.         getData("test:Score", "95001", "sname", "");
  45.         //删除Score表
  46.         //deleteTable("Score");
  47.     }
  49.     //建立连接
  50.     public static void init(){
  51.         configuration  = HBaseConfiguration.create();
  52.         //configuration.set("hbase.zookeeper.quorum","hdfs://localhost:9000/hbase");
  53.         configuration.set("hbase.zookeeper.quorum","hbaseserver");  //hbase 服务地址
  54.         configuration.set("hbase.zookeeper.property.clientPort","2182"); //端口号默认2128不用改
  55.         try{
  56.             connection = ConnectionFactory.createConnection(configuration);
  57.             admin = connection.getAdmin();
  58.         }catch (IOException e){
  59.             e.printStackTrace();
  60.         }
  61.     }
  62.     //关闭连接
  63.     public static void close(){
  64.         try{
  65.             if(admin != null){
  66.                 admin.close();
  67.             }
  68.             if(null != connection){
  69.                 connection.close();
  70.             }
  71.         }catch (IOException e){
  72.             e.printStackTrace();
  73.         }
  74.     }
  76.     /**
  77.      * 建表。HBase的表中会有一个系统默认的属性作为主键，主键无需自行创建，默认为put命令操作中表名后第一个数据，因此此处无需创建id列
  78.      * @param myTableName 表名
  79.      * @param colFamily 列族名
  80.      * @throws IOException
  81.      */
  82.     public static void createTable(String myTableName,String[] colFamily) throws IOException {
  84.         init();
  85.         TableName tableName = TableName.valueOf(myTableName);
  87.         if(admin.tableExists(tableName)){
  88.             System.out.println("talbe is exists!");
  89.         }else {
  90.             HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
  91.             for(String str:colFamily){
  92.                 HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);
  93.                 hTableDescriptor.addFamily(hColumnDescriptor);
  94.             }
  95.             admin.createTable(hTableDescriptor);
  96.             System.out.println("create table success");
  97.         }
  98.         close();
  99.     }
  100.     /**
  101.      * 删除指定表
  102.      * @param tableName 表名
  103.      * @throws IOException
  104.      */
  105.     public static void deleteTable(String tableName) throws IOException {
  106.         init();
  107.         TableName tn = TableName.valueOf(tableName);
  108.         if (admin.tableExists(tn)) {
  109.             admin.disableTable(tn);
  110.             admin.deleteTable(tn);
  111.         }
  112.         close();
  113.     }
  115.     /**
  116.      * 查看已有表
  117.      * @throws IOException
  118.      */
  119.     public static void listTables() throws IOException {
  120.         init();
  121.         HTableDescriptor hTableDescriptors[] = admin.listTables();
  122.         for(HTableDescriptor hTableDescriptor :hTableDescriptors){
  123.             System.out.println(hTableDescriptor.getNameAsString());
  124.         }
  125.         close();
  126.     }
  127.     /**
  128.      * 向某一行的某一列插入数据
  129.      * @param tableName 表名
  130.      * @param rowKey 行键
  131.      * @param colFamily 列族名
  132.      * @param col 列名（如果其列族下没有子列，此参数可为空）
  133.      * @param val 值
  134.      * @throws IOException
  135.      */
  136.     public static void insertRow(String tableName,String rowKey,String colFamily,String col,String val) throws IOException {
  137.         init();
  138.         Table table = connection.getTable(TableName.valueOf(tableName));
  139.         Put put = new Put(rowKey.getBytes());
  140.         put.addColumn(colFamily.getBytes(), col.getBytes(), val.getBytes());
  141.         table.put(put);
  142.         table.close();
  143.         close();
  144.     }
  146.     /**
  147.      * 删除数据
  148.      * @param tableName 表名
  149.      * @param rowKey 行键
  150.      * @param colFamily 列族名
  151.      * @param col 列名
  152.      * @throws IOException
  153.      */
  154.     public static void deleteRow(String tableName,String rowKey,String colFamily,String col) throws IOException {
  155.         init();
  156.         Table table = connection.getTable(TableName.valueOf(tableName));
  157.         Delete delete = new Delete(rowKey.getBytes());
  158.         //删除指定列族的所有数据
  159.         //delete.addFamily(colFamily.getBytes());
  160.         //删除指定列的数据
  161.         //delete.addColumn(colFamily.getBytes(), col.getBytes());
  163.         table.delete(delete);
  164.         table.close();
  165.         close();
  166.     }
  167.     /**
  168.      * 根据行键rowkey查找数据
  169.      * @param tableName 表名
  170.      * @param rowKey 行键
  171.      * @param colFamily 列族名
  172.      * @param col 列名
  173.      * @throws IOException
  174.      */
  175.     public static void getData(String tableName,String rowKey,String colFamily,String col)throws  IOException{
  176.         init();
  177.         Table table = connection.getTable(TableName.valueOf(tableName));
  178.         Get get = new Get(rowKey.getBytes());
  179.         get.addColumn(colFamily.getBytes(),col.getBytes());
  180.         Result result = table.get(get);
  181.         showCell(result);
  182.         table.close();
  183.         close();
  184.     }
  185.     /**
  186.      * 格式化输出
  187.      * @param result
  188.      */
  189.     public static void showCell(Result result){
  190.         Cell[] cells = result.rawCells();
  191.         for(Cell cell:cells){
  192.             System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
  193.             System.out.println("Timetamp:"+cell.getTimestamp()+" ");
  194.             System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
  195.             System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
  196.             System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");
  197.         }
  198.     }
  199. }
标签： hbase 数据库 大数据
本文转载自: https://blog.csdn.net/wangyunbo158/article/details/143114199
版权归原作者 wangyunbo158 所有， 如有侵权，请联系我们删除。
登录后发布评论

“hbase单机版(依赖于内置的zookeeper)安装配置及详细使用教程”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？

文章导航
没有找到文章内容分段。。。