开发准备&＃xff1a;
jdk1.8.45
hbase-1.2.2&＃xff08;windows下和linux个留一份&＃xff09;
hadoop-2.7.2&＃xff08;linux一份&＃xff09;
Linux系统&＃xff08;centos或其它&＃xff09;
Hadoop安装环境
HBase安装环境
具体操作步骤如下&＃xff1a;
1. Eclipse中新建Maven项目&＃xff0c; type为maven-archetype-quickstart&＃xff0c;工程名为MyHBase
2. 将hadoop集群和hbase集群的配置文件放到如下路径:
/src/main/resources/hadoop
/src/main/resources/hbase
3. 将配置路径加入到classpath中&＃xff1a;
4. 最终的目录结构
5. 编辑hbase-site.xml文件内容为&＃xff1a;
6. 将Linux下部署的HBase集群下的lib目录拷贝到Windows下&＃xff0c;并在eclipse中将lib&＃xff08;里面的hadoop库可能与安装的hadoop版本不一致&＃xff0c;后续可以考虑版本统一&＃xff09;下的所有库添加到工程&＃xff1a;
7. 新建类HBaseTest &＃xff0c;内容如下&＃xff1a;
package com.hbase.demo;
//package com.eric.hbase;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.MasterNotRunningException;
import org.apache.hadoop.hbase.ZooKeeperConnectionException;
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 HBaseTest {private static final String TABLE_NAME &＃61; "demo_table";public static Configuration conf &＃61; null;public HTable table &＃61; null;public HBaseAdmin admin &＃61; null;static {conf &＃61; HBaseConfiguration.create();System.out.println(conf.get("hbase.zookeeper.quorum"));}/*** 创建一张表*/public static void creatTable(String tableName, String[] familys)throws Exception {HBaseAdmin admin &＃61; new HBaseAdmin(conf);if (admin.tableExists(tableName)) {System.out.println("table already exists!");} else {HTableDescriptor tableDesc &＃61; new HTableDescriptor(tableName);for (int i &＃61; 0; i ) {tableDesc.addFamily(new HColumnDescriptor(familys[i]));}admin.createTable(tableDesc);System.out.println("create table " &＃43; tableName &＃43; " ok.");}}/*** 删除表*/public static void deleteTable(String tableName) throws Exception {try {HBaseAdmin admin &＃61; new HBaseAdmin(conf);admin.disableTable(tableName);admin.deleteTable(tableName);System.out.println("delete table " &＃43; tableName &＃43; " ok.");} catch (MasterNotRunningException e) {e.printStackTrace();} catch (ZooKeeperConnectionException e) {e.printStackTrace();}}/*** 插入一行记录*/public static void addRecord(String tableName, String rowKey,String family, String qualifier, String value) throws Exception {try {HTable table &＃61; new HTable(conf, tableName);Put put &＃61; new Put(Bytes.toBytes(rowKey));put.add(Bytes.toBytes(family), Bytes.toBytes(qualifier),Bytes.toBytes(value));table.put(put);System.out.println("insert recored " &＃43; rowKey &＃43; " to table "&＃43; tableName &＃43; " ok.");} catch (IOException e) {e.printStackTrace();}}/*** 删除一行记录*/public static void delRecord(String tableName, String rowKey)throws IOException {HTable table &＃61; new HTable(conf, tableName);List list &＃61; new ArrayList();Delete del &＃61; new Delete(rowKey.getBytes());list.add(del);table.delete(list);System.out.println("del recored " &＃43; rowKey &＃43; " ok.");}/*** 查找一行记录*/public static void getOneRecord(String tableName, String rowKey)throws IOException {HTable table &＃61; new HTable(conf, tableName);Get get &＃61; new Get(rowKey.getBytes());Result rs &＃61; table.get(get);for (KeyValue kv : rs.raw()) {System.out.print(new String(kv.getRow()) &＃43; " ");System.out.print(new String(kv.getFamily()) &＃43; ":");System.out.print(new String(kv.getQualifier()) &＃43; " ");System.out.print(kv.getTimestamp() &＃43; " ");System.out.println(new String(kv.getValue()));}}/*** 显示所有数据*/public static void getAllRecord(String tableName) {try {HTable table &＃61; new HTable(conf, tableName);Scan s &＃61; new Scan();ResultScanner ss &＃61; table.getScanner(s);for (Result r : ss) {for (KeyValue kv : r.raw()) {System.out.print(new String(kv.getRow()) &＃43; " ");System.out.print(new String(kv.getFamily()) &＃43; ":");System.out.print(new String(kv.getQualifier()) &＃43; " ");System.out.print(kv.getTimestamp() &＃43; " ");System.out.println(new String(kv.getValue()));}}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) {// TODO Auto-generated method stubtry {String tablename &＃61; "scores";String[] familys &＃61; { "grade", "course" };HBaseTest.creatTable(tablename, familys);// add record zkbHBaseTest.addRecord(tablename, "zkb", "grade", "", "5");HBaseTest.addRecord(tablename, "zkb", "course", "", "90");HBaseTest.addRecord(tablename, "zkb", "course", "math", "97");HBaseTest.addRecord(tablename, "zkb", "course", "art", "87");// add record baoniuHBaseTest.addRecord(tablename, "baoniu", "grade", "", "4");HBaseTest.addRecord(tablename, "baoniu", "course", "math", "89");System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;get one record&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");HBaseTest.getOneRecord(tablename, "zkb");System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;show all record&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");HBaseTest.getAllRecord(tablename);System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;del one record&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");HBaseTest.delRecord(tablename, "baoniu");HBaseTest.getAllRecord(tablename);System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;show all record&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");HBaseTest.getAllRecord(tablename);} catch (Exception e) {e.printStackTrace();}}}
8. 如果报错查看日志&＃xff0c;修改C:\Windows\System32\drivers\etc\HOSTS:
112.120.41.159 hadoop
9. 右键-->Run as -->java application.
京公网安备 11010802041100号