霏霏暮雨 eclipse+HBASE开发环境搭建（已实践

客官°小女子只卖身不卖艺 2022-05-26 08:49 139阅读 0赞

**开发准备：**

jdk1.8.45

hbase-1.2.2（windows下和linux个留一份）

hadoop-2.7.2（linux一份）

Linux系统（centos或其它）

Hadoop安装环境

HBase安装环境

**具体操作步骤如下：**

**1. Eclipse中新建Maven项目， type为maven-archetype-quickstart，工程名为MyHBase**

**2. 将hadoop集群和hbase集群的配置文件放到如下路径:**

/src/main/resources/hadoop

/src/main/resources/hbase

**3. 将配置路径加入到classpath中：**

![526228-20160829144629965-1303301749.png][]

**4. 最终的目录结构**

**![526228-20160829144734605-1533491197.png][]**

**5. 编辑hbase-site.xml文件内容为：**

![526228-20160829144916324-1429154177.png][]

**6. 将Linux下部署的HBase集群下的lib目录拷贝到Windows下，并在eclipse中将lib（里面的hadoop库可能与安装的hadoop版本不一致，后续可以考虑版本统一）下的所有库添加到工程：**

![526228-20160829145128058-1948018993.png][]

**7. 新建类HBaseTest ，内容如下：**

![复制代码][copycode.gif]

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 = "demo_table"; public static Configuration conf = null; public HTable table = null; public HBaseAdmin admin = null; static { conf = HBaseConfiguration.create(); System.out.println(conf.get("hbase.zookeeper.quorum")); } /** * 创建一张表 */
          public static void creatTable(String tableName, String[] familys) throws Exception { HBaseAdmin admin = new HBaseAdmin(conf); if (admin.tableExists(tableName)) { System.out.println("table already exists!"); } else { HTableDescriptor tableDesc = new HTableDescriptor(tableName); for (int i = 0; i < familys.length; i++) { tableDesc.addFamily(new HColumnDescriptor(familys[i])); } admin.createTable(tableDesc); System.out.println("create table " + tableName + " ok."); } } /** * 删除表 */
          public static void deleteTable(String tableName) throws Exception { try { HBaseAdmin admin = new HBaseAdmin(conf); admin.disableTable(tableName); admin.deleteTable(tableName); System.out.println("delete table " + tableName + " 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 = new HTable(conf, tableName); Put put = new Put(Bytes.toBytes(rowKey)); put.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(value)); table.put(put); System.out.println("insert recored " + rowKey + " to table "
                  + tableName + " ok."); } catch (IOException e) { e.printStackTrace(); } } /** * 删除一行记录 */
          public static void delRecord(String tableName, String rowKey) throws IOException { HTable table = new HTable(conf, tableName); List list = new ArrayList(); Delete del = new Delete(rowKey.getBytes()); list.add(del); table.delete(list); System.out.println("del recored " + rowKey + " ok."); } /** * 查找一行记录 */
          public static void getOneRecord(String tableName, String rowKey) throws IOException { HTable table = new HTable(conf, tableName); Get get = new Get(rowKey.getBytes()); Result rs = table.get(get); for (KeyValue kv : rs.raw()) { System.out.print(new String(kv.getRow()) + " "); System.out.print(new String(kv.getFamily()) + ":"); System.out.print(new String(kv.getQualifier()) + " "); System.out.print(kv.getTimestamp() + " "); System.out.println(new String(kv.getValue())); } } /** * 显示所有数据 */
          public static void getAllRecord(String tableName) { try { HTable table = new HTable(conf, tableName); Scan s = new Scan(); ResultScanner ss = table.getScanner(s); for (Result r : ss) { for (KeyValue kv : r.raw()) { System.out.print(new String(kv.getRow()) + " "); System.out.print(new String(kv.getFamily()) + ":"); System.out.print(new String(kv.getQualifier()) + " "); System.out.print(kv.getTimestamp() + " "); System.out.println(new String(kv.getValue())); } } } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { // TODO Auto-generated method stub
             try { String tablename = "scores"; String[] familys = { "grade", "course" }; HBaseTest.creatTable(tablename, familys); // add record zkb
                  HBaseTest.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 baoniu
                  HBaseTest.addRecord(tablename, "baoniu", "grade", "", "4"); HBaseTest .addRecord(tablename, "baoniu", "course", "math", "89"); System.out.println("===========get one record========"); HBaseTest.getOneRecord(tablename, "zkb"); System.out.println("===========show all record========"); HBaseTest.getAllRecord(tablename); System.out.println("===========del one record========"); HBaseTest.delRecord(tablename, "baoniu"); HBaseTest.getAllRecord(tablename); System.out.println("===========show all record========"); HBaseTest.getAllRecord(tablename); } catch (Exception e) { e.printStackTrace(); } } }

![复制代码][copycode.gif]

**8. 如果报错查看日志，修改C:\\Windows\\System32\\drivers\\etc\\HOSTS:**

112.120.41.159 hadoop

**9. 右键-->Run as -->java application.**

[526228-20160829144629965-1303301749.png]: /images/20220526/303d3b6df33e429da9c3e72bfcc265be.png
[526228-20160829144734605-1533491197.png]: /images/20220526/8a96667865cd4958a0bb87dc852be6a2.png
[526228-20160829144916324-1429154177.png]: /images/20220526/db9c22ef65f446e28cbe15452ba1ac60.png
[526228-20160829145128058-1948018993.png]: /images/20220526/fa32e786f0d641409adf407c31420d67.png
[copycode.gif]: /images/20220526/c4a489436534438abf18a0ae5bc16dca.png