JAVA API 连接Hbase

点这里

点这里

点这里

start-all.sh

zkServer.sh start

start-hbase.sh

zookeeper需要三台都输入命令，其他两个只需要在master输入即可。
关闭顺序，先关hbase，然后zk，hadoop。

修改

C:WindowsSystem32driversetc

hosts文件

添加这三行

下载hbase的安装目录下的lib文件夹
导入jar包，就是把这个文件夹中的jar导入（最好就直接用本机的）

测试连接代码

import java.io.IOException;
 
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.HbaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
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.TableName;
 
 
public class testHbase 
{
	public static void main(String[] args) throws IOException
	{
		//调用HbaseConfiguration类的create静态方法，创建一个Configuration类的对象
		Configuration configuration = HbaseConfiguration.create();
		
		//加载需要连接Hbase的各项配置参数，记得在开发机win7的hosts文件中增加虚拟机的主机名和IP地址的对应关系
		configuration.set("hbase.zookeeper.quorum", "master");
        //configuration.set("hbase.rootdir", "hdfs://hadoop:8020/hbase");	
		//configuration.set("hbase.zookeeper.property.clientPort", "2181");
		
		//调用ConnectionFactory类的createConnection静态方法，创建一个Connection类的对象，用于连接Hbase
		Connection  connection = ConnectionFactory.createConnection(configuration);
		
		//调用connection对象的getAdmin方法，获取一个Admin类的对象，用于执行Hbase的管理操作
		Admin admin = connection.getAdmin();
		
		//调用TableName类的valueOf静态方法，得到一个TableName类的对象，tableName对象是表的名字
		TableName tableName = TableName.valueOf("testTable");
	
		//调用admin对象的tableExists方法，判断Hbase中是否存在tableName这张表，存在则返回True
		boolean isExists = admin.tableExists(tableName);	
		
		if(isExists) 
		{
			System.out.println("Table exists");
		}
		else 
		{
			System.out.println("Table dose not exists");
		}	
	}
}