HBase安装配置以及Java操做hbase

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的问题

一、配置Linux的hostname

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

这里配置的hostname要Linux重启才生效，为了避免重启就生效，咱们能够执行：hostname CentOS124命令，暂时设置hostname

二、配置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

三、配置访问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("建立成功");
    } 
}

demo地址 https://gitee.com/qinxuewu/spring-cloud/tree/master/kafka-demo