0
0

实验二 HBase编程实践（centos7）

链接：https://pan.baidu.com/s/1Pp7fgEEN3ABc4QXkCxGI6w?pwd=5566

提取码：5566

1.zookeeper环境搭建

1.1压缩文件

  1. tar -zxvf zookeeper-3.4.10.tar.gz
  2. sudo mkdir -p /usr/zookeeper  #创建文件
  3. sudo cp -r zookeeper-3.4.10 /usr/zookeeper/

1.2修改配置文件

ZooKeeper的核心服务器属性配置文件是zoo.cfg。在主安装目录下的conf子目录内,系统为用户准备了一个模板文件zoo_sample.cfg，我们可以将这个文件拷贝一份，命名为zoo.cfg，然后修改配置文件。首先我们进入到conf子目录，执行以下命令：

  1. cd /usr/zookeeper/zookeeper-3.4.10/conf
  2. cp zoo_sample.cfg zoo.cfg
  3. vim zoo.cfg

然后，我们进入到zoo.cfg文件中修改配置信息，tickTime：这个时间是作为ZooKeeper服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个tickTime时间就会发送一个心跳；dataDir：顾名思义就是ZooKeeper保存数据的目录，默认情况下，ZooKeeper将数据的日志文件也保存在这个目录里；clientPort：这个端口就是客户端连接ZooKeeper服务器的端口，ZooKeeper会监听这个端口，接收客户端的请求。按如下配置修改tickTime、dataDate、clientPort的值（其余内容不做修改）：

  1. tickTime=2000 
  2. dataDir=/usr/zookeeper/zookeeper-3.4.10/tmp/zookeeper  #自己创建tmp/zookeeper
  3. clientPort=2181

1.3配置环境变量

  1. vim  ~/.bashrc

在文件末尾增加下面内容：

  1. export ZOOKEEPER_HOME=/usr/zookeeper/zookeeper-3.4.10/
  3. export PATH=$ZOOKEEPER_HOME/bin:$PATH

使环境变量生效：

  1. source  ~/.bashrc

1.4启动 zookeeper

  1. zkServer.sh start

2.Hbase环境配置

1.1压缩Hbase

  1. tar -zxvf hbase-1.2.6-bin.tar.gz
  2. sudo mkdir -p /usr/hbase#创建文件
  3. sudo cp -r hbase-1.2.6 /usr/hbase/

1.2配置环境变量

  1. vim  ~/.bashrc

在打开文件的末尾添加以下两行代码，保存并退出。

  1. export HBASE_HOME=/usr/hbase/hbase-1.2.6/
  3. export PATH=$HBASE_HOME/bin:$PATH

使环境变量生效，执行下面命令：

  1. source ~/.bashrc

进入hbase文件后创建data目录

  1. mkdir zookeeper

进入hbase中的conf文件后修改配置文件hbase-env.sh

  1. cd /usr/hbase/hbase-1.2.6/conf
  2. vim hbase-env.sh

在打开的文件中，找到“# export JAVA_HOME”开头的文件，去掉前面的“#”，修改为：

  1. export JAVA_HOME=/usr/java/jdk1.8.0_212

另外，找到“# export HBASE_MANAGES_ZK”开头的文件，去掉前面的“#”，修改为：

  1. export HBASE_MANAGES_ZK=true

1.3修改配置文件hbase-site.xml

  1. cd /usr/hbase/hbase-1.2.6/conf
  2. vim  hbase-site.xml

在打开的文件中编辑内容，如下：

  1. <configuration>
  2. <!--HBase的数据保存在HDFS对应目录-->
  3. <property>
  4.   <name>hbase.rootdir</name>
  5.   <value>hdfs://node1:9000/hbase</value>
  6. </property>    
  7.  
  8. <!--是否是分布式环境-->
  9. <property>
  10.   <name>hbase.cluster.distributed</name>
  11.   <value>true</value>
  12. </property>            
  13.  
  14. <!--配置ZK的地址-->
  15. <property>
  16.   <name>hbase.zookeeper.quorum</name>
  17.   <value>node1</value>
  18. </property>                
  19.  
  20. <!--冗余度-->
  21. <property>
  22.   <name>dfs.replication</name>
  23.   <value>1</value>
  24. </property>
  25.  
  26. <!--zookeeper数据目录-->
  27. <property>
  28.   <name>hbase.zookeeper.property.dataDir</name>
  29.   <value>file:/usr/hbase/hbase-1.2.6/zookeeper</value>
  30. </property>
  31.  
  32. </configuration>

1.4 修改配置文件regionservers

  1. vim regionservers

在打开的文件中，将里面的内容修改为(自己主机名)：

  1. node1

1.5启动hbase

  1. cd /usr/hbase/hbase-1.2.6/conf
  2. start-hbase.sh

jps查看进程

访问http://192.168.159.128:16010 （换成自己的ip地址）

3.HBase Java API编程实践

1）createTable(String tableName, String[] fields)

创建表，参数tableName为表的名称，字符串数组fields为存储记录各个字段名称的数组。要求当HBase已经存在名为tableName的表的时候，先删除原有的表，然后再创建新的表。

2）addRecord(String tableName, String row, String[] fields, String[] values)

向表tableName、行row（用S_Name表示）和字符串数组fields指定的单元格中添加对应的数据values。其中，fields中每个元素如果对应的列族下还有相应的列限定符的话，用“columnFamily:column”表示。例如，同时向“Math”、“Computer Science”、“English”三列添加成绩时，字符串数组fields为{“Score:Math”, ”Score:Computer Science”, ”Score:English”}，数组values存储这三门课的成绩。

3）modifyData(String tableName, String row, String column)

修改表tableName，行row（可以用学生姓名S_Name表示），列column指定的单元格的数据。

4）deleteRow(String tableName, String row)

删除表tableName中row指定的行的记录。

本实例采用Eclipse开发工具。
启动Eclipse，启动以后，出现如下图所示界面，点击ok按钮。

添加hbase安装包下的所有jar包

在开始运行程序之前，需要启动HDFS和HBase。我的已经运行了

HBaseTest.java代码内容具体如下

  1. import java.io.IOException;
  2. import java.util.HashSet;
  3. import java.util.Set;
  5. import org.apache.hadoop.conf.Configuration;
  6. import org.apache.hadoop.hbase.HBaseConfiguration;
  7. import org.apache.hadoop.hbase.TableName;
  8. import org.apache.hadoop.hbase.client.Admin;
  9. import org.apache.hadoop.hbase.client.Connection;
  10. import org.apache.hadoop.hbase.client.ConnectionFactory;
  11. import org.apache.hadoop.hbase.client.Delete;
  12. import org.apache.hadoop.hbase.client.Put;
  13. import org.apache.hadoop.hbase.client.Table;
  14. import org.apache.hadoop.hbase.HColumnDescriptor;
  15. import org.apache.hadoop.hbase.HTableDescriptor;
  16. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
  17. import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
  18. import org.apache.hadoop.hbase.client.TableDescriptorBuilder;
  19. import org.apache.hadoop.hbase.util.Bytes;
  21. public class HBaseTest {
  22.     private Configuration conf = null; // 用于配置 HBase 连接的配置对象
  23.     private Connection conn = null;    // 用于连接 HBase 的连接对象
  25.     // 初始化连接
  26.     public void init() throws Exception {
  27.         conf = HBaseConfiguration.create();
  28.         conf.set("hbase.zookeeper.quorum", "node1:2181");
  29.         conn = ConnectionFactory.createConnection(conf);
  30.     }
  32.     // 创建表，若表已存在则先删除再创建
  33.     public void createTable(String tableName, String[] fields) throws Exception {
  34.         try (Admin admin = conn.getAdmin()) {
  35.             TableName table = TableName.valueOf(tableName);
  36.             if (admin.tableExists(table)) {
  37.                 admin.disableTable(table);
  38.                 admin.deleteTable(table);
  39.                 System.out.println("Old table deleted.");
  40.             }
  42.             // 创建列族
  43.             Set<String> families = new HashSet<>();
  44.             for (String field : fields) {
  45.                 String columnFamily = field.split(":")[0];
  46.                 families.add(columnFamily);
  47.             }
  49.             // 创建表描述符并添加列族
  50.             TableDescriptorBuilder builder = TableDescriptorBuilder.newBuilder(table);
  51.             for (String family : families) {
  52.                 ColumnFamilyDescriptor cfDesc = ColumnFamilyDescriptorBuilder.of(family);
  53.                 builder.setColumnFamily(cfDesc);
  54.             }
  55.             admin.createTable(builder.build());
  56.             System.out.println("Table created successfully.");
  57.         } catch (Exception e) {
  58.             e.printStackTrace();
  59.         }
  60.     }
  62.     // 添加记录
  63.     public void addRecord(String tableName, String row, String[] fields, String[] values) throws Exception {
  64.         try (Table table = conn.getTable(TableName.valueOf(tableName))) {
  65.             Put put = new Put(Bytes.toBytes(row));
  66.             for (int i = 0; i < fields.length; i++) {
  67.                 String[] parts = fields[i].split(":");
  68.                 String family = parts[0];
  69.                 String qualifier = parts.length > 1 ? parts[1] : "";
  70.                 put.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(values[i]));
  71.             }
  72.             table.put(put);
  73.             System.out.println("Data inserted successfully.");
  74.         } catch (Exception e) {
  75.             e.printStackTrace();
  76.         }
  77.     }
  79.     // 修改数据
  80.     public void modifyData(String tableName, String row, String column, String value) throws Exception {
  81.         try (Table table = conn.getTable(TableName.valueOf(tableName))) {
  82.             Put put = new Put(Bytes.toBytes(row));
  83.             String[] parts = column.split(":");
  84.             String family = parts[0];
  85.             String qualifier = parts.length > 1 ? parts[1] : "";
  86.             put.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(value));
  87.             table.put(put);
  88.             System.out.println("Data modified successfully.");
  89.         } catch (Exception e) {
  90.             e.printStackTrace();
  91.         }
  92.     }
  94.     // 删除行
  95.     public void deleteRow(String tableName, String row) throws Exception {
  96.         try (Table table = conn.getTable(TableName.valueOf(tableName))) {
  97.             Delete delete = new Delete(Bytes.toBytes(row));
  98.             table.delete(delete);
  99.             System.out.println("Row deleted successfully.");
  100.         } catch (Exception e) {
  101.             e.printStackTrace();
  102.         }
  103.     }
  105.     // 主程序
  106.     public static void main(String[] args) {
  107.         HBaseTest demo = new HBaseTest();
  108.         try {
  109.             demo.init();
  111.             // 创建表
  112.             demo.createTable("student", new String[]{
  113.                 "Info:S_No", "Info:S_Name", "Info:S_Sex", "Info:S_Age", 
  114.                 "Score:Math", "Score:Computer Science", "Score:English"
  115.             });
  117.             // 添加记录
  118.             demo.addRecord("student", "2015001",
  119.                 new String[]{
  120.                     "Info:S_No", "Info:S_Name", "Info:S_Sex", "Info:S_Age", 
  121.                     "Score:Math", "Score:Computer Science", "Score:English"
  122.                 },
  123.                 new String[]{"2015001", "ZhangQuanDe", "man", "21", "90", "92", "66"}
  124.             );
  126.             // 修改数据
  127.             demo.modifyData("student", "2015001", "Score:Math", "60");
  129.             // 删除行
  130.             demo.deleteRow("student", "2015001");
  132.         } catch (Exception e) {
  133.             e.printStackTrace();
  134.         }
  135.     }
  136. }
标签： hbase 数据库 centos
本文转载自: https://blog.csdn.net/qq_73915074/article/details/143314555
版权归原作者 代码搬运工小覃 所有， 如有侵权，请联系我们删除。
登录后发布评论

“实验二 HBase编程实践（centos7）”的评论:

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

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

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

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

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

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

Kafka学习笔记

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