$ cd  ~/下载     # 进入下载目录
$ wget  http://10.132.239.12:8000/file/hbase-1.1.5-bin.tar.gz     # 下载HBase软件

$ sudo tar -zxf ~/下载/hbase-1.1.5-bin.tar.gz -C /usr/local

$ sudo mv /usr/local/hbase-1.1.5 /usr/local/hbase

$ vim ~/.bashrc

export PATH=$PATH:/usr/local/hadoop/sbin:/usr/local/hadoop/bin

export PATH=$PATH:/usr/local/hadoop/sbin:/usr/local/hadoop/bin:/usr/local/hbase/bin

$ source ~/.bashrc

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

## 7.2 HBase的配置

​ HBase有三种运行模式，即单机模式、伪分布式模式和分布式模式：

单机模式：采用本地文件系统存储数据；
伪分布式模式：采用伪分布式模式的HDFS存储数据；
分布式模式：采用分布式模式的HDFS存储数据。
本教程仅介绍单机模式和伪分布式模式。

在进行HBase配置之前，需要确认已经安装了三个组件：JDK、Hadoop、SSH。HBase单机模式不需要安装Hadoop，伪分布式模式和分布式模式需要安装Hadoop。

### 7.2.1 单机模式配置

#### 配置hbase-env.sh文件

使用vim编辑器打开“/usr/local/hbase/conf/hbase-env.sh”，命令如下：

​ 打开hbase-env.sh文件以后，需要在hbase-env.sh文件中配置JAVA环境变量，此前在安装Hadoop的环节，已经配置了JAVA环境变量，比如，“JAVA_HOME=/usr/lib/jvm/java-7-openjdk-amd64”，这里可以直接复制该配置信息到hbase-env.sh文件中。此外，还需要添加Zookeeper配置信息，配置HBASE_MANAGES_ZK为true，表示由HBase自己管理Zookeeper，不需要单独的Zookeeper，由于hbase-env.sh文件中本来就存在这些变量的配置，因此，只需要删除前面的注释“#”符号并修改配置内容即可，修改后的hbase-env.sh文件应该包含如下两行信息：

 ```
export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64
export HBASE_MANAGES_ZK=true

​ 在hbase-site.xml文件中，需要设置属性hbase.rootdir，用于指定HBase数据的存储位置，如果没有设置，则hbase.rootdir默认为/tmp/hbase-${user.name}，这意味着每次重启系统都会丢失数据。这里把hbase.rootdir设置为HBase安装目录下的hbase-tmp文件夹，即“/usr/local/hbase/hbase-tmp”，修改后的hbase-site.xml文件中的配置信息如下：

 ```
<configuration>
        <property>
                <name>hbase.rootdir</name>
                <value>file:///usr/local/hbase/hbase-tmp</value>
        </property>
</configuration>

​ 进入HBase Shell命令行模式以后，用户可以通过输入Shell命令操作HBase数据库。

​ 后，可以使用如下命令停止HBase运行：

### 7.2.2 伪分布式配置

配置hbase-env.sh文件

使用vim编辑器打开“/usr/local/hbase/conf/hbase-env.sh”，命令如下：

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

​ 修改完成以后，保存hbase-env.sh文件并退出vim编辑器。

#### 配置hbase-site.xml文件

使用vim编辑器打开并编辑“/usr/local/hbase/conf/hbase-site.xml”文件，命令如下：

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

​ 保存hbase-site.xml文件，并退出vim编辑器。

启动运行HBase

首先登陆SSH，由于之前在“Hadoop的安装和使用”中已经设置了无密码登录，因此这里不需要密码。然后，切换至“/usr/local/hadoop”，启动Hadoop，让HDFS进入运行状态，从而可以为HBase存储数据，具体命令如下：

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

​ 输入命令jps，如果出现以下进程，则说明HBase启动成功：

​ 现在就可以进入HBase Shell模式，命令如下：

​ 进入HBase shell命令行模式以后，用户可以通过输入shell命令操作HBase数据库。

停止 运行HBase
后，可以使用如下命令停止HBase运行：

 ```
$ bin/stop-hbase.sh

后需要注意的是，启动关闭Hadoop和HBase的顺序一定是：启动Hadoop—>启动HBase—>关闭HBase—>关闭Hadoop。



## 7.3 HBase常用Shell命令

​ 在使用具体的Shell命令操作HBase数据之前，需要首先启动Hadoop，然后再启动HBase，并且启动HBase Shell，进入Shell命令提示符状态，具体命令如下：

 ```
$ cd /usr/local/hadoop
$ ./sbin/start-dfs.sh
$ cd /usr/local/hbase
$ ./bin/start-hbase.sh
$ ./bin/hbase shell

对于HBase而言，在创建HBasae表时，不需要自行创建行健，系统会默认一个属性作为行键，通常是把put命令操作中跟在表名后的个数据作为行健。

​ 创建完“student”表后，可通过describe命令查看“student”表的基本信息，命令如下：

​ 可以使用list命令查看当前HBase数据库中已经创建了哪些表，命令如下：

​

### 7.3.2 添加数据

​ HBase使用put命令添加数据，一次只能为一个表的一行数据的一个列（也就是一个单元格，单元格是HBase中的概念）添加一个数据，所以，直接用Shell命令插入数据效率很低，在实际应用中，一般都是利用编程操作数据。因为这里只要插入1条学生记录，所以，我们可以用Shell命令手工插入数据，命令如下：

​ 上面的put命令会为student表添加学号为'95001'、名字为'LiYing'的一个单元格数据，其行键为95001，也就是说，系统默认把跟在表名student后面的个数据作为行健。

​ 下面继续添加4个单元格的数据，用来记录LiYing同学的相关信息，命令如下：

 ```
hbase> put 'student','95001','Ssex','male'
hbase> put 'student','95001','Sage','22'
hbase> put 'student','95001','Sdept','CS'
hbase> put 'student','95001','course:math','80'

hbase> get 'student','95001'

hbase> scan 'student'

hbase > delete 'student','95001','Ssex'

hbase> deleteall 'student','95001'

### 7.3.6 查询历史数据

​ 在添加数据时，HBase会自动为添加的数据添加一个时间戳。在修改数据时，HBase会为修改后的数据生成一个新的版本（时间戳），从而完成“改”操作，旧的版本依旧保留，系统会定时回收垃圾数据，只留下新的几个版本，保存的版本数可以在创建表的时候指定。

​ 为了查询历史数据，这里创建一个teacher表，首先，在创建表的时候，需要指定保存的版本数（假设指定为5），命令如下：

​ 然后，插入数据，并更新数据，使其产生历史版本数据，需要注意的是，这里插入数据和更新数据都是使用put命令，具体如下：

 ```
hbase> put 'teacher','91001','username','Mary'
hbase> put 'teacher','91001','username','Mary1'
hbase> put 'teacher','91001','username','Mary2'
hbase> put 'teacher','91001','username','Mary3'
hbase> put 'teacher','91001','username','Mary4'  
hbase> put 'teacher','91001','username','Mary5'

hbase> exit

$ bin/stop-hbase.sh

### 7.4.1 在Eclipse中创建项目

​ Eclipse启动以后，会弹出如下图所示界面，提示设置工作空间（workspace）。

​ 可以直接采用默认的设置“/home/hadoop/workspace”，点击“OK”按钮。可以看出，由于当前是采用hadoop用户登录了Linux系统，因此，默认的工作空间目录位于hadoop用户目录“/home/hadoop”下。

​ Eclipse启动以后，在界面中，选择“FileàNewàJava Project”菜单，开始创建一个Java工程，弹出如下图所示界面。

​ 在“Project name”后面输入工程名称“HBaseExample”，选中“Use default location”，让这个Java工程的所有文件都保存到“/home/hadoop/workspace/HBaseExample”目录下。在“JRE”这个选项卡中，可以选择当前的Linux系统中已经安装好的JDK，比如java-8-openjdk-amd64。然后，点击界面底部的“Next>”按钮，进入下一步的设置。

### 7.4.2为项目添加需要用到的JAR包

进入下一步的设置以后，会弹出如下图所示界面。


​ 为了编写一个能够与HBase交互的Java应用程序，需要在这个界面中加载该Java工程所需要用到的JAR包，这些JAR包中包含了可以访问HBase的Java API。这些JAR包都位于Linux系统的HBase安装目录的lib目录下，也就是位于“/usr/local/hbase/lib”目录下。点击界面中的“Libraries”选项卡，然后，点击界面右侧的“Add External JARs…”按钮，弹出如下图所示界面。

​ 选中“/usr/local/hbase/lib”目录下的所有JAR包（但是，不要选中“ruby”文件夹），然后，点击界面右下角的“确定”按钮。

添加完毕以后，就可以点击界面右下角的“Finish”按钮，完成Java工程HBaseExample的创建。

### 7.4.3 编写Java应用程序

​ 下面编写一个Java应用程序，对HBase数据库进行操作。

​ 请在Eclipse工作界面左侧的“Package Explorer”面板中（如下图所示），找到刚才创建好的工程名称“HBaseExample”，然后在该工程名称上点击鼠标右键，在弹出的菜单中选择“NewàClass”菜单。

​ 选择“NewàClass”菜单以后会出现如下图所示界面。


​ 在该界面中，只需要在“Name”后面输入新建的Java类文件的名称，这里采用名称“HBaseOperation”，其他都可以采用默认设置，然后，点击界面右下角“Finish”按钮，出现如下图所示界面。

​ 可以看出，Eclipse自动创建了一个名为“HBaseOperation.java”的源代码文件，请在该文件中输入以下代码：

 ```
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import java.io.IOException; 
public class HBaseOperation{
    public static Configuration configuration;
    public static Connection connection;
    public static Admin admin;
    public static void main(String[] args)throws IOException{
        createTable("t2",new String[]{"cf1","cf2"});
        insertRow("t2", "rw1", "cf1", "q1", "val1");
        getData("t2", "rw1", "cf1", "q1");
        //deleteTable("t2");  //如果不想执行本行代码，可以注释掉本行代码
    } 
    //建立连接
    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 { 
        init();
        TableName tableName = TableName.valueOf(myTableName); 
        if(admin.tableExists(tableName)){
            System.out.println("talbe is exists!");
        }else {
            HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
            for(String str:colFamily){
                HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);
                hTableDescriptor.addFamily(hColumnDescriptor);
            }
            admin.createTable(hTableDescriptor);
        }
        close();
    }
    //删表
    public static void deleteTable(String tableName) throws IOException {
        init();
        TableName tn = TableName.valueOf(tableName);
        if (admin.tableExists(tn)) {
            admin.disableTable(tn);
            admin.deleteTable(tn);
        }
        close();
    } 
    //查看已有表
    public static void listTables() throws IOException {
        init();
        HTableDescriptor hTableDescriptors[] = admin.listTables();
        for(HTableDescriptor hTableDescriptor :hTableDescriptors){
            System.out.println(hTableDescriptor.getNameAsString());
        }
        close();
    }
    public static void insertRow(String tableName,String rowKey,String colFamily,String col,String val) throws IOException {
        init();
        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();
        close();
    }
    //删除数据
    public static void deleteRow(String tableName,String rowKey,String colFamily,String col) throws IOException {
        init();
        Table table = connection.getTable(TableName.valueOf(tableName));
        Delete delete = new Delete(rowKey.getBytes());
        //删除指定列族
        //delete.addFamily(Bytes.toBytes(colFamily));
        //删除指定列
        //delete.addColumn(Bytes.toBytes(colFamily),Bytes.toBytes(col));
        table.delete(delete);
        table.close();
        close();
    }
    //根据rowkey查找数据
    public static void getData(String tableName,String rowKey,String colFamily,String col)throws  IOException{
        init();
        Table table = connection.getTable(TableName.valueOf(tableName));
        Get get = new Get(rowKey.getBytes());
        get.addColumn(colFamily.getBytes(),col.getBytes());
        Result result = table.get(get);
        showCell(result);
        table.close();
        close();
    }
    //格式化输出
    public static void showCell(Result result){
        Cell[] cells = result.rawCells();
        for(Cell cell:cells){
            System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
            System.out.println("Timetamp:"+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))+" ");
        }
    }
}

$ cd /usr/local/hbase $ ./bin/hbase shell
hbase> list

​hbase> get ‘t2’,’rw1’
hbase> disable ‘t2’ hbase> drop ‘t2`