Apache HBase

• Apache HBase™是Hadoop資料庫，是一個分散式，可擴充套件的大資料儲存。
• 當您需要對大資料進行隨機，實時讀/寫訪問時，請使用Apache HBase™。該專案的目標是託管非常大的表 - 數十億行X百萬列 - 在商品硬體叢集上。Apache HBase是一個開源的，分散式的，版本化的非關係資料庫

特徵

• 線性和模組化可擴充套件性。
• 嚴格一致的讀寫操作。
• 表的自動和可配置分片
• RegionServers之間的自動故障轉移支援。
• 方便的基類，用於使用Apache HBase表支援Hadoop MapReduce作業。
• 易於使用的Java API，用於客戶端訪問。
• 阻止快取和布隆過濾器以進行實時查詢。
• 查詢謂詞通過伺服器端過濾器下推
• Thrift閘道器和REST-ful Web服務，支援XML，Protobuf和二進位制資料編碼選項
• 可擴充套件的基於jruby（JIRB）的外殼
• 支援通過Hadoop指標子系統將指標匯出到檔案或Ganglia; 或通過JMX

安裝 獨立HBase

HBase要求安裝JDK。有關支援的JDK版本的資訊

從此Apache下載映象列表中選擇一個下載站點。單擊建議的頂部連結。這將帶您進入HBase版本的映象。單擊名為stable的資料夾，然後將以.tar.gz結尾的二進位制檔案下載到本地檔案系統。暫時不要下載以src.tar.gz結尾的檔案。

解壓縮下載的檔案，然後切換到新建立的目錄。

$ tar -xzvf hbase-1.2.6.1-bin.tar.gz

為HBase設定Java目錄，並從conf資料夾開啟hbase-env.sh檔案。編輯JAVA_HOME環境變數，改變路徑到當前JAVA_HOME變數

#編輯/home/hbase-1.2.6.1/conf/hbase-env.sh
#配置hbase-env.sh檔案：把29行的註釋取消，配置虛擬機器上面的Java地址
export JAVA_HOME=/usr/local/java/jdk1.7.0_79

編輯conf/hbase-site.xml，這是主要的HBase配置檔案

<configuration>
    <property>
    <!--  配置hbase存在位置-->
        <name>hbase.rootdir</name>
        <value>file:///home/pflm/HBase/HFiles</value>
      </property>
      <property>
        <!--  配置hbase檔案儲存路徑-->
        <name>hbase.zookeeper.property.dataDir</name>
        <value>/home/pflm/HBase/zookeeper</value>
      </property>
</configuration>

到此 HBase 的安裝配置已成功完成。可以通過使用 HBase 的 bin 資料夾中提供 start-hbase.sh 指令碼啟動 HBase

$ ./bin/start-hbase.sh

執行HBase啟動指令碼，它會提示一條訊息：HBase has started

starting master, logging to /usr/local/HBase/bin/../logs/hbase-tpmaster-localhost.localdomain.out

• 該./start-hbase.sh指令碼是作為啟動HBase的一種便捷方式。發出命令，如果一切順利，將在標準輸出中記錄一條訊息，顯示HBase已成功啟動。您可以使用該jps命令驗證是否有一個正在執行的程序HMaster。在獨立模式下，HBase執行此單個JVM中的所有守護程式，即HMaster，單個HRegionServer和ZooKeeper守護程式。轉到http：// localhost：16010以檢視HBase Web UI。

HBase Shell

要訪問HBase shell，必須導航進入到HBase的主資料夾。

#進入shell
/bin/hbase shell

#列出HBase的所有表。
hbase(main):001:0> list
TABLE

通用命令

status: 提供HBase的狀態，例如，伺服器的數量。
version: 提供正在使用HBase版本。
table_help: 表引用命令提供幫助
whoami: 提供有關使用者的資訊。

HBase在表中操作的命令。

create: 建立一個表。
list: 列出HBase的所有表。
disable: 禁用表。
is_disabled: 驗證表是否被禁用。
enable: 啟用一個表。
is_enabled: 驗證表是否已啟用。
describe: 提供了一個表的描述。
alter: 改變一個表。
exists: 驗證表是否存在。
drop: 從HBase中刪除表。
drop_all: 丟棄在命令中給出匹配“regex”的表

資料操縱語言

put: 把指定列在指定的行中單元格的值在一個特定的表。
get: 取行或單元格的內容。
delete: 刪除表中的單元格值。
deleteall: 刪除給定行的所有單元格。
scan: 掃描並返回表資料。
count: 計數並返回表中的行的數目。
truncate: 禁用，刪除和重新建立一個指定的表。

解決Java API不能遠端訪問HBase的問題

1、配置Linux的hostname

[root@CentOS124 hbase-1.2.6.1]# vie /etc/sysconfig/network
NETWORKING=yes
HOSTNAME=CentOS124   #名字隨便

這裡配置的hostname要Linux重啟才生效，為了不重啟就生效，我們可以執行：hostname CentOS124命令，暫時設定hostname

2、配置Linux的hosts，對映ip的hostname的關係

#對映ip的hostname的關係
[root@CentOS124 hbase-1.2.6.1]# vim /etc/host

#檢視hbase ip繫結是否成功
[root@CentOS124 hbase-1.2.6.1]# netstat -anp|grep 16010

3、配置訪問windows的hosts

#hbase
192.168.10.124  CentOS124

Java 操作遠端hbase

public class HbaseTest {
    public static  Connection connection;
    public static Configuration configuration; 
    static { 

        configuration = HBaseConfiguration.create(); 
        // 設定連線引數：HBase資料庫使用的埠
        configuration.set("hbase.zookeeper.property.clientPort", "2181"); 
        // 設定連線引數：HBase資料庫所在的主機IP
        configuration.set("hbase.zookeeper.quorum", "192.168.10.124"); 
        // configuration.addResource("hbase-site.xml");
        try {
             // 取得一個數據庫連線物件
            connection = ConnectionFactory.createConnection(configuration);
        } catch (IOException e) {
            e.printStackTrace();
        }

    } 
    public static void main(String[] args) throws Exception {
        createTable("gazw", "id","name");
//      deleteTable("gazw");
    }

    public static void createTable(String tableName,String... cf1) throws IOException { 
        Admin admin = connection.getAdmin();
        //HTD需要TableName型別的tableName，建立TableName型別的tableName
        TableName tbName = TableName.valueOf(tableName);
        //判斷表述否已存在，不存在則建立表
        if(admin.tableExists(tbName)){
            System.err.println("表" + tableName + "已存在！");
            return;
        }
        //通過HTableDescriptor建立一個HTableDescriptor將表的描述傳到createTable引數中
        HTableDescriptor HTD = new HTableDescriptor(tbName);
        //為描述器新增表的詳細引數
        for(String cf : cf1){
            // 建立HColumnDescriptor物件新增表的詳細的描述
            HColumnDescriptor HCD =new HColumnDescriptor(cf);
            HTD.addFamily(HCD);
        }
        //呼叫createtable方法建立表
        admin.createTable(HTD);
        System.out.println("建立成功");
    } 
}