ToB企服应用市场:ToB评测及商务社交产业平台

标题: HBase Java API编程-学习记录 [打印本页]
作者: 科技颠覆者    时间: 2024-11-25 20:41
标题: HBase Java API编程-学习记录
Hbase伪分布式情况部署见：Hbase情况部署
前置准备

启动hdfs和hbase并验证情况正常

启动服务

通过shell命令启动hdfs文件体系和hbase服务，jps下出现如下图所示的进程即为精确。
  1. start-all.sh   # 启动HDFS文件系统 (datanode, namenode, secondary namenode)
  2. start-hbase.sh   # 启动HBase服务 (HMaster, HRegionServer, HQuorumPeer)
  3. jps   # 查看当前运行的任务进程
复制代码

验证运行情况

进入hbase shell终端或进入hbase提供的web页面（HBase默认端口：16030），验证情况正常。

HBase web页面如下图所示

搭建HBase客户端

使用IDEA创建Maven项目


修改pom.xml配置文件

为项目添加hbase-lient的依靠（刷新完成不飘红即为引入乐成）

添加log4j输出日志的依靠（刷新完成不飘红即为引入乐成）

使用Java API操作HBase

Java毗连Hbase

  1. // 静态代码块
  2. static {
  3.     Configuration conf = HBaseConfiguration.create();
  4.     conf.set("hbase.zookeeper.quorum", "192.168.159.139");   //这里替换成自己Hbase的IP地址
  5.     try {
  6.         //创建HBase连接对象
  7.         connection = ConnectionFactory.createConnection(conf);
  8.     } catch (IOException ex) {
  9.         ex.printStackTrace();
  10.     }
  11. }
复制代码
创建命名空间

  1. public static void createNameSpace(String nameSpaceName) throws IOException {
  2.         if (nameSpaceName == null || nameSpaceName.isEmpty()) {
  3.             logger.error("namespace 不能为空!");
  4.             return;
  5.         }
  6.         Admin admin = connection.getAdmin();
  7.         NamespaceDescriptor.Builder builder = NamespaceDescriptor.create(nameSpaceName);
  8.         NamespaceDescriptor namespaceDescriptor = builder.build();
  9.         try {
  10.             admin.createNamespace(namespaceDescriptor);
  11.             logger.info("namespace: {} 创建成功", nameSpaceName);
  12.         } catch (NamespaceExistException e) {
  13.             logger.error("namespace 名字已存在!");
  14.         }
  15.     }
复制代码
运行截图：

Hbase中前后对比：

表的创建和删除

  1. // 表的创建和删除
  2.     public static void createTable() {
  3.         TableName tableName = TableName.valueOf("stu");
  5.         try (Admin admin = connection.getAdmin()) {
  6.             // 检查表是否存在
  7.             if (admin.tableExists(tableName)) {
  8.                 admin.disableTable(tableName);
  9.                 admin.deleteTable(tableName);
  10.                 logger.info(tableName.toString() + " exists, deleted it.");
  11.             }
  12.             // 创建表描述符
  13.             TableDescriptor tableDescriptor = TableDescriptorBuilder.newBuilder(tableName)
  14.                     .setColumnFamily(ColumnFamilyDescriptorBuilder.of("StuInfo"))
  15.                     .setColumnFamily(ColumnFamilyDescriptorBuilder.of("Grades"))
  16.                     .build();
  17.             // 创建表
  18.             admin.createTable(tableDescriptor);
  19.             logger.info("Table " + tableName + " created successfully.");
  20.         } catch (IOException e) {
  21.             logger.error("Error: " + e.getMessage());
  22.             e.printStackTrace();
  23.         }
  24.     }
复制代码
运行截图：

Hbase中前后对比：

插入数据

  1. // 数据插入
  2.     public static void addData() throws IOException {
  3.         Table table = connection.getTable(TableName.valueOf("stu"));
  4.         Put put1 = new Put(Bytes.toBytes("row1"));
  5.         put1.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Jack"));
  6.         put1.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("18"));
  7.         put1.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("90"));
  8.         put1.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("85"));
  9.         table.put(put1);
  11.         Put put2 = new Put(Bytes.toBytes("row2"));
  12.         put2.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Alice"));
  13.         put2.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("19"));
  14.         put2.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("88"));
  15.         put2.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("92"));
  16.         table.put(put2);
  18.         Put put3 = new Put(Bytes.toBytes("row3"));
  19.         put3.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Bob"));
  20.         put3.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("20"));
  21.         put3.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("95"));
  22.         put3.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("80"));
  23.         table.put(put3);
  25.         Put put4 = new Put(Bytes.toBytes("row4"));
  26.         put4.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Emma"));
  27.         put4.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("21"));
  28.         put4.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("82"));
  29.         put4.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("90"));
  30.         table.put(put4);
  32.         Put put5 = new Put(Bytes.toBytes("row5"));
  33.         put5.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("David"));
  34.         put5.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("22"));
  35.         put5.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("91"));
  36.         put5.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("88"));
  37.         table.put(put5);
  38.         logger.info("SUCCESS");
  39.         table.close();
  40.     }
复制代码
运行截图：

Hbase表中的变化：

数据查询

行键查询

  1. // 数据获取（通过行键查询）
  2.     public static void getData() throws IOException {
  3.         Table table = connection.getTable(TableName.valueOf("stu"));
  4.         Get get = new Get(Bytes.toBytes("row1"));
  5.         Result result = table.get(get);
  6.         for (Cell cell : result.rawCells()) {
  7.             System.out.println(CellUtil.getCellKeyAsString(cell));
  8.             System.out.println(new String(CellUtil.cloneQualifier(cell)));
  9.             System.out.println(new String(CellUtil.cloneValue(cell)));
  10.             System.out.println(cell.getTimestamp());
  11.             System.out.println("----------------------------");
  12.         }
  13.         table.close();
  14.     }
复制代码
运行截图：

全部查询

  1. // 全部查询
  2. public static void getDataAll() throws IOException {
  3.     Table table = connection.getTable(TableName.valueOf("stu"));
  4.     Scan scan = new Scan();
  5.     ResultScanner scanner = table.getScanner(scan);
  6.     for (Result result : scanner) {
  7.         for (Cell cell : result.rawCells()) {
  8.             System.out.println(CellUtil.getCellKeyAsString(cell));
  9.             System.out.println(new String(CellUtil.cloneQualifier(cell)));
  10.             System.out.println(new String(CellUtil.cloneValue(cell)));
  11.             System.out.println(cell.getTimestamp());
  12.             System.out.println("----------------------------");
  13.         }
  14.     }
  15.     scanner.close();
  16.     table.close();
  17. }
复制代码
运行截图：

特定前缀列查询

  1. // 使用ColumnPrefixFilter过滤器 查询特定列前缀的列
  2. public static void getDataWithColumnPrefixFilter() throws IOException {
  3.     Table table = connection.getTable(TableName.valueOf("stu"));
  4.     Filter filter = new ColumnPrefixFilter(Bytes.toBytes("na"));
  5.     Scan scan = new Scan();
  6.     scan.setFilter(filter);
  7.     ResultScanner scanner = table.getScanner(scan);
  8.     for (Result result : scanner) {
  9.         for (Cell cell : result.rawCells()) {
  10.             System.out.println(CellUtil.getCellKeyAsString(cell));
  11.             System.out.println(new String(CellUtil.cloneQualifier(cell)));
  12.             System.out.println(new String(CellUtil.cloneValue(cell)));
  13.             System.out.println(cell.getTimestamp());
  14.             System.out.println("----------------------------");
  15.         }
  16.     }
  17.     scanner.close();
  18.     table.close();
  19. }
复制代码
运行截图：

完整代码

  1. package org.example;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.*;import org.apache.hadoop.hbase.client.*;import org.apache.hadoop.hbase.filter.*;import org.apache.hadoop.hbase.util.Bytes;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import java.io.IOException;public class HBaseDemo {    private static Connection connection;    private static final Logger logger = LogManager.getLogger(HBaseDemo.class);    static {        Configuration conf = HBaseConfiguration.create();        conf.set("hbase.zookeeper.quorum", "192.168.159.139");        try {            connection = ConnectionFactory.createConnection(conf);            logger.info("Hbase 毗连乐成！");        } catch (IOException ex) {            logger.error(ex.getMessage(), ex);        }    }    //创建命名空间    public static void createNameSpace(String nameSpaceName) throws IOException {
  2.         if (nameSpaceName == null || nameSpaceName.isEmpty()) {
  3.             logger.error("namespace 不能为空!");
  4.             return;
  5.         }
  6.         Admin admin = connection.getAdmin();
  7.         NamespaceDescriptor.Builder builder = NamespaceDescriptor.create(nameSpaceName);
  8.         NamespaceDescriptor namespaceDescriptor = builder.build();
  9.         try {
  10.             admin.createNamespace(namespaceDescriptor);
  11.             logger.info("namespace: {} 创建成功", nameSpaceName);
  12.         } catch (NamespaceExistException e) {
  13.             logger.error("namespace 名字已存在!");
  14.         }
  15.     }
  16.     // 表的创建和删除
  17.     public static void createTable() {
  18.         TableName tableName = TableName.valueOf("stu");
  20.         try (Admin admin = connection.getAdmin()) {
  21.             // 检查表是否存在
  22.             if (admin.tableExists(tableName)) {
  23.                 admin.disableTable(tableName);
  24.                 admin.deleteTable(tableName);
  25.                 logger.info(tableName.toString() + " exists, deleted it.");
  26.             }
  27.             // 创建表描述符
  28.             TableDescriptor tableDescriptor = TableDescriptorBuilder.newBuilder(tableName)
  29.                     .setColumnFamily(ColumnFamilyDescriptorBuilder.of("StuInfo"))
  30.                     .setColumnFamily(ColumnFamilyDescriptorBuilder.of("Grades"))
  31.                     .build();
  32.             // 创建表
  33.             admin.createTable(tableDescriptor);
  34.             logger.info("Table " + tableName + " created successfully.");
  35.         } catch (IOException e) {
  36.             logger.error("Error: " + e.getMessage());
  37.             e.printStackTrace();
  38.         }
  39.     }
  40.     // 数据插入
  41.     public static void addData() throws IOException {
  42.         Table table = connection.getTable(TableName.valueOf("stu"));
  43.         Put put1 = new Put(Bytes.toBytes("row1"));
  44.         put1.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Jack"));
  45.         put1.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("18"));
  46.         put1.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("90"));
  47.         put1.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("85"));
  48.         table.put(put1);
  50.         Put put2 = new Put(Bytes.toBytes("row2"));
  51.         put2.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Alice"));
  52.         put2.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("19"));
  53.         put2.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("88"));
  54.         put2.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("92"));
  55.         table.put(put2);
  57.         Put put3 = new Put(Bytes.toBytes("row3"));
  58.         put3.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Bob"));
  59.         put3.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("20"));
  60.         put3.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("95"));
  61.         put3.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("80"));
  62.         table.put(put3);
  64.         Put put4 = new Put(Bytes.toBytes("row4"));
  65.         put4.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("Emma"));
  66.         put4.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("21"));
  67.         put4.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("82"));
  68.         put4.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("90"));
  69.         table.put(put4);
  71.         Put put5 = new Put(Bytes.toBytes("row5"));
  72.         put5.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("name"), Bytes.toBytes("David"));
  73.         put5.addColumn(Bytes.toBytes("StuInfo"), Bytes.toBytes("age"), Bytes.toBytes("22"));
  74.         put5.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("math"), Bytes.toBytes("91"));
  75.         put5.addColumn(Bytes.toBytes("Grades"), Bytes.toBytes("english"), Bytes.toBytes("88"));
  76.         table.put(put5);
  77.         logger.info("SUCCESS");
  78.         table.close();
  79.     }
  80.     // 全部查询    public static void getDataAll() throws IOException {        Table table = connection.getTable(TableName.valueOf("stu"));        Scan scan = new Scan();        ResultScanner scanner = table.getScanner(scan);        for (Result result : scanner) {            for (Cell cell : result.rawCells()) {                System.out.println(CellUtil.getCellKeyAsString(cell));                System.out.println(new String(CellUtil.cloneQualifier(cell)));                System.out.println(new String(CellUtil.cloneValue(cell)));                System.out.println(cell.getTimestamp());                System.out.println("----------------------------");            }        }        scanner.close();        table.close();    }    // 数据获取 - 行键    public static void getDataRow() throws IOException {        Table table = connection.getTable(TableName.valueOf("stu"));        Get get = new Get(Bytes.toBytes("row1"));        Result result = table.get(get);        for (Cell cell : result.rawCells()) {            System.out.println(CellUtil.getCellKeyAsString(cell));            System.out.println(new String(CellUtil.cloneQualifier(cell)));            System.out.println(new String(CellUtil.cloneValue(cell)));            System.out.println(cell.getTimestamp());            System.out.println("----------------------------");        }        table.close();    }    // 使用ColumnPrefixFilter过滤器 查询特定列前缀的列    public static void getDataWithColumnPrefixFilter() throws IOException {        Table table = connection.getTable(TableName.valueOf("stu"));        Filter filter = new ColumnPrefixFilter(Bytes.toBytes("na"));        Scan scan = new Scan();        scan.setFilter(filter);        ResultScanner scanner = table.getScanner(scan);        for (Result result : scanner) {            for (Cell cell : result.rawCells()) {                System.out.println(CellUtil.getCellKeyAsString(cell));                System.out.println(new String(CellUtil.cloneQualifier(cell)));                System.out.println(new String(CellUtil.cloneValue(cell)));                System.out.println(cell.getTimestamp());                System.out.println("----------------------------");            }        }        scanner.close();        table.close();    }    public static void main(String[] args) throws IOException {        // 创建命名空间//        createNameSpace("test");        // 表的创建和删除//        createTable();        // 数据插入//        addData();        // 数据获取//        getDataRow();        // 全部查询//        getDataAll();        // 使用PrefixFilter过滤器查询//        getDataWithColumnPrefixFilter();    }}
复制代码

@鲨鱼爱兜兜

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4