首先说一下我的版本
centos7
hadoop :2.6.0
java:1,7
hbase:0.98.24-hadoop2
(由于是学校老师安排的实验,我是按照他提供的教程的版本安装的,当然这也为我带了很多麻烦)

windows下的java版本1.8(版本不一致不会有影响)

一

确认hbase和windows主机能够互ping并且主机能够访问:60010端口后,将hbase下的lib下的jar包传输到主机中，即确认hbase启动

1

使用FinallShell将虚拟机中的hbasejar包传入主机

（有的教程可能会说也要导入hadoop的jar包，但我就是导了hadoopjar浪费了6个小时，期间尝试了maven然而版本过低0.98.24，导致找不到还是什么原因）

2

再将hbase下的hbase-site.xml下到主机中

二

1

首先创建一个java项目或者web项目也行
创建一个资源文件夹conf,将下载的xml文件复制粘贴

2

将下好的jar包全部导入eclipse下创建的项目中，conf也要build

这下算是配置好了

三

创建一个类,进行数据库操作
这里附上代码

</
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseJavaAPI {
// 声明静态配置
private static Configuration conf = null;

static {conf = HBaseConfiguration.create();
}//判断表是否存在
private static boolean isExist(String tableName) throws IOException {HBaseAdmin hAdmin = new HBaseAdmin(conf);return hAdmin.tableExists(tableName);
}// 创建数据库表
public static void createTable(String tableName, String[] columnFamilys)throws Exception {// 新建一个数据库管理员HBaseAdmin hAdmin = new HBaseAdmin(conf);if (hAdmin.tableExists(tableName)) {System.out.println("表 "+tableName+" 已存在！");System.exit(0);} else {// 新建一个students表的描述HTableDescriptor tableDesc = new HTableDescriptor(tableName);// 在描述里添加列族for (String columnFamily : columnFamilys) {tableDesc.addFamily(new HColumnDescriptor(columnFamily));}// 根据配置好的描述建表hAdmin.createTable(tableDesc);System.out.println("创建表 "+tableName+" 成功!");}
}// 删除数据库表
public static void deleteTable(String tableName) throws Exception {// 新建一个数据库管理员HBaseAdmin hAdmin = new HBaseAdmin(conf);if (hAdmin.tableExists(tableName)) {// 关闭一个表hAdmin.disableTable(tableName);hAdmin.deleteTable(tableName);System.out.println("删除表 "+tableName+" 成功！");} else {System.out.println("删除的表 "+tableName+" 不存在！");System.exit(0);}
}// 添加一条数据
public static void addRow(String tableName, String row,String columnFamily, String column, String value) throws Exception {HTable table = new HTable(conf, tableName);Put put = new Put(Bytes.toBytes(row));// 指定行// 参数分别:列族、列、值put.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column),Bytes.toBytes(value));table.put(put);
}// 删除一条(行)数据
public static void delRow(String tableName, String row) throws Exception {HTable table = new HTable(conf, tableName);Delete del = new Delete(Bytes.toBytes(row));table.delete(del);
}// 删除多条数据
public static void delMultiRows(String tableName, String[] rows)throws Exception {HTable table = new HTable(conf, tableName);List<Delete> delList = new ArrayList<Delete>();for (String row : rows) {Delete del = new Delete(Bytes.toBytes(row));delList.add(del);}table.delete(delList);
}// 获取一条数据
public static void getRow(String tableName, String row) throws Exception {HTable table = new HTable(conf, tableName);Get get = new Get(Bytes.toBytes(row));Result result = table.get(get);// 输出结果,raw方法返回所有keyvalue数组for (KeyValue rowKV : result.raw()) {System.out.print("行名:" + new String(rowKV.getRow()) + " ");System.out.print("时间戳:" + rowKV.getTimestamp() + " ");System.out.print("列族名:" + new String(rowKV.getFamily()) + " ");System.out.print("列名:" + new String(rowKV.getQualifier()) + " ");System.out.println("值:" + new String(rowKV.getValue()));}
}// 获取所有数据
public static void getAllRows(String tableName) throws Exception {HTable table = new HTable(conf, tableName);Scan scan = new Scan();ResultScanner results = table.getScanner(scan);// 输出结果for (Result result : results) {for (KeyValue rowKV : result.raw()) {System.out.print("行名:" + new String(rowKV.getRow()) + " ");System.out.print("时间戳:" + rowKV.getTimestamp() + " ");System.out.print("列族名:" + new String(rowKV.getFamily()) + " ");System.out.print("列名:" + new String(rowKV.getQualifier()) + " ");System.out.println("值:" + new String(rowKV.getValue()));}}
}// 主函数
public static void main(String[] args) {try {String tableName = "student1";// 第一步：创建数据库表：“student”String[] columnFamilys = { "info", "course" };HBaseJavaAPI.createTable(tableName, columnFamilys);// 第二步：向数据表的添加数据// 添加第一行数据if (isExist(tableName)) {HBaseJavaAPI.addRow(tableName, "zpc", "info", "age", "20");HBaseJavaAPI.addRow(tableName, "zpc", "info", "sex", "boy");HBaseJavaAPI.addRow(tableName, "zpc", "course", "china", "97");HBaseJavaAPI.addRow(tableName, "zpc", "course", "math", "128");HBaseJavaAPI.addRow(tableName, "zpc", "course", "english", "85");// 添加第二行数据HBaseJavaAPI.addRow(tableName, "henjun", "info", "age", "19");// HBaseJavaAPI.addRow(tableName, "<span style="font-family: Arial, Helvetica, sans-serif;">henjun</span>", "info", "sex", "boy");HBaseJavaAPI.addRow(tableName, "henjun", "course", "china","90");HBaseJavaAPI.addRow(tableName, "henjun", "course", "math","120");HBaseJavaAPI.addRow(tableName, "henjun", "course", "english","90");// 添加第三行数据HBaseJavaAPI.addRow(tableName, "niaopeng", "info", "age", "18");//  HBaseJavaAPI.addRow(tableName, "<span style="font-family: Arial, Helvetica, sans-serif;">niaopeng</span>", "info", "sex","girl");HBaseJavaAPI.addRow(tableName, "niaopeng", "course", "china","100");HBaseJavaAPI.addRow(tableName, "niaopeng", "course", "math","100");HBaseJavaAPI.addRow(tableName, "niaopeng", "course", "english","99");// 第三步：获取一条数据System.out.println("**************获取一条(zpc)数据*************");HBaseJavaAPI.getRow(tableName, "zpc");// 第四步：获取所有数据System.out.println("**************获取所有数据***************");HBaseJavaAPI.getAllRows(tableName);// 第五步：删除一条数据System.out.println("************删除一条(zpc)数据************");HBaseJavaAPI.delRow(tableName, "zpc");HBaseJavaAPI.getAllRows(tableName);// 第六步：删除多条数据System.out.println("**************删除多条数据***************");String rows[] = new String[] { "qingqing","xiaoxue" };HBaseJavaAPI.delMultiRows(tableName, rows);HBaseJavaAPI.getAllRows(tableName);// 第七步：删除数据库System.out.println("***************删除数据库表**************");//HBaseJavaAPI.deleteTable(tableName);System.out.println("表"+tableName+"存在吗？"+isExist(tableName));} else {System.out.println(tableName + "此数据库表不存在！");}} catch (Exception e) {e.printStackTrace();}
}

}

运行结果

如果出现如下问题

并不会对数据操作有影响,应该是日志部分文件的冲突,网上说是hadoop和hbase的,具体也有解决方法

今天就是弄这个,看了篇教程(我和他的大体一样,只是没有导入hadoop的jar包),但就是我先看了他的,导入了hadoopjar包导致我白白的浪费了6个小时的大好光阴,所以写博客真的是要负责任啊!(也有可能是我的hadoop版本过低)

本篇仅仅只是针对初学者,其中很多东西并不专业,