Hbase的安装与测试

实验环境

虚拟机伪分布式

Ubuntu 17.10

JDK 1.8

Hadoop 2.7.6

Hbase 1.3.3

①安装和配置HBase。

首先从官网http://archive.apache.org/dist/hbase/下载HBase安装包，为了兼容性，这里选择HBase-1.3.3。然后解压到文件夹。

②配置环境变量

将hbase下的bin目录添加到path中

编辑~/.bashrc文件添加 export PATH=$PATH:bin路径

 

③伪分布式模式配置

配置hbase/conf/hbase-env.sh

 

配置hbase/conf/hbase-site.xml

假设当前Hadoop集群运行在伪分布式模式下，在本机上运行，且NameNode运行在9000端口。

 

④启动Hadoop

 

启动Hbase

 

⑤根据表格，用Hbase Shell命令模式设计student学生表格。

 

⑥查询zhangsan 的Computer成绩。

 

⑦修改lisi的Math成绩，改为95。

 

⑧根据上面的student表，用Hbase Java API编程

新建一个工程，将hbase/lib中的所有jar包添加到项目

a)    添加数据：English:45 Math:89  Computer:100

import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;

public class Hbase {
    public static Configuration configuration;
    public static Connection connection;
    public static Admin admin;

    public static void main(String[] args) {
        configuration = HBaseConfiguration.create();
        configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");
        try {
            connection = ConnectionFactory.createConnection(configuration);
            admin = connection.getAdmin();
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            insertRow("student", "scofield", "score", "English", "45");
            insertRow("student", "scofield", "score", "Math", "89");
            insertRow("student", "scofield", "score", "Computer", "100");
        } catch (IOException e) {
            e.printStackTrace();
        }
        close();
    }

    public static void insertRow(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 close() {
        try {
            if (admin != null) {
                admin.close();
            }
            if (null != connection) {
                connection.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

b)    获取scofield的English成绩信息

import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;

public class GetScofieid {
    public static Configuration configuration;
    public static Connection connection;
    public static Admin admin;

    public static void main(String[] args) {
        configuration = HBaseConfiguration.create();
        configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase");
        try {
            connection = ConnectionFactory.createConnection(configuration);
            admin = connection.getAdmin();
            getData("student", "scofield", "score", "English");
        } catch (IOException e) {
            e.printStackTrace();
        }
        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);
        Cell[] cells = result.rawCells();
        for (Cell cell : cells) {
            System.out.println("RowName:" + new String(CellUtil.cloneRow(cell)));
            System.out.println("timestamp:" + cell.getTimestamp());
            System.out.println("column Family:" + new String(CellUtil.cloneFamily(cell)));
            System.out.println("row Name:" + new String(CellUtil.cloneQualifier(cell)));
            System.out.println("value:" + new String(CellUtil.cloneValue(cell)));
        }
        table.close();
    }

    public static void close() {
        try {
            if (admin != null) {
                admin.close();
            }
            if (null != connection) {
                connection.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

⑨关闭所有服务