平时在开发的过程中，都是将hbase的环境装在虚拟机或者双系统上的，开发是直接在unix或者linux上进行的，这样对于使用上，有些繁琐。
下面我将介绍我在使用windows远程开发过程中的一些总结：
1，环境
开发环境： windows下的 idea (或者eclipse等)
hbase环境: VMware 下的虚拟机 Ubuntu server 16.04
（我这里是伪分布式环境，用于程序的开发环境）
版本：hadoop: 2.7.4
版本：hbase 1.2.6
2，配置
1），虚拟机配置
主机名：zhoujun
** 配置网络ip信息：
sudo vim /etc/hosts
这里我的ip是 192.168.27.132，不同的虚拟机根据不同的ip进行配置
** ip 地址通过 ifconfig来查看
** 修改主机名 ：
sudo vim /etc/hostname 这里就设置成你的主机名就可以了，我这里是：zhoujun
2) 配置 hadoop
将 hadoop 的配置文件中的所有的关于ip地址，都配置成自己的对应主机的 i p ，（建议用自己的主机名就行）
3) 配置 hbase
进入到自己的hbase 的安装目录，进入/conf配置目录下，我这里的hbase安装在 /opt目录下
这里一样的把对应使用到了主机或者ip地址的地方都改成自己主机对应的 ip ,例如：
然后重启自己的服务器:
sudo reboot now
3） 重新配置 ssh 密钥
cd ~/.ssh/ # 若没有该目录，请先执行一次ssh localhost ssh-keygen -t rsa # 会有提示，都按回车就可以 cat ./id_rsa.pub >> ./authorized_keys # 加入授权4）配置 windows ：
进入 C:\Windows\System32\drivers\etc 的文件夹下， 打开 hosts文件。在文件的末尾添加
192.168.27.132 zhoujun # 注意这里的 主机名，是你虚拟机的主机名，而不是用户名5 ) 进入到服务武器的终端，开启对应的服务：
start-all.sh # 开启 hadoop 服务 start-hbase.sh # 开启 hbase 服务3，编写例子测试：
import org.apache.commons.io.IOUtils; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.*; import org.apache.hadoop.hbase.client.*; import java.io.IOException; import java.util.Arrays; /** * Created by zhoujun on 2017/8/31. */ public class HbaseConection { /** * 连接池对象 */ protected static Connection connection; private static final String ZK_QUORUM = "hbase.zookeeper.quorum"; private static final String ZK_CLIENT_PORT = "hbase.zookeeper.property.clientPort"; /** * HBase位置 */ private static final String HBASE_POS = "192.168.27.132"; /** * ZooKeeper位置 */ private static final String ZK_POS = "192.168.27.132"; /** * zookeeper服务端口 */ private final static String ZK_PORT_VALUE = "2181"; /** * 静态构造，在调用静态方法时前进行运行 * 初始化连接对象． * */ static{ Configuration configuration = HBaseConfiguration.create(); configuration.set("hbase.rootdir", "hdfs://" + HBASE_POS + ":9000/hbase"); configuration.set(ZK_QUORUM, ZK_POS); configuration.set(ZK_CLIENT_PORT, ZK_PORT_VALUE); try { connection = ConnectionFactory.createConnection(configuration); } catch (IOException e) { e.printStackTrace(); }// 创建连接池 } /** * @param tableName 创建一个表 tableName 指定的表名 * @param seriesStr 以字符串的形式指定表的列族，每个列族以逗号的形式隔开,(例如：＂f1,f2＂两个列族，分别为f1和f2) **/ public static boolean createTable(String tableName, String seriesStr) { boolean isSuccess = false;// 判断是否创建成功！初始值为false Admin admin = null; TableName table = TableName.valueOf(tableName); try { admin = connection.getAdmin(); if (!admin.tableExists(table)) { System.out.println("INFO:Hbase:: " + tableName + "原数据库中表不存在！开始创建..."); HTableDescriptor descriptor = new HTableDescriptor(table); Arrays.asList(seriesStr.split(",")) .forEach(s -> descriptor.addFamily(new HColumnDescriptor(s.getBytes()))); admin.createTable(descriptor); System.out.println("INFO:Hbase:: "+tableName + "新的" + tableName + "表创建成功！"); isSuccess = true; } else { System.out.println("INFO:Hbase:: 该表已经存在，不需要在创建！"); } } catch (Exception e) { e.printStackTrace(); } finally { IOUtils.closeQuietly(admin); } return isSuccess; } /** * 插入数据 * @param tableName 表名 * @param rowkey 行健 * @param family 列族 * @param qualifier 列描述符 * @param value 值 * @throws IOException 异常信息 */ public static void putDataH(String tableName, String rowkey, String family, String qualifier, Object value) throws IOException { Admin admin = null; TableName tN = TableName.valueOf(tableName); admin = connection.getAdmin(); if (admin.tableExists(tN)) { try (Table table = connection.getTable(TableName.valueOf(tableName .getBytes()))) { Put put = new Put(rowkey.getBytes()); put.addColumn(family.getBytes(), qualifier.getBytes(), value.toString().getBytes()); table.put(put); } catch (Exception e) { e.printStackTrace(); } } else { System.out.println("插入数据的表不存在，请指定正确的tableName ! "); } } /** * 根据table查询表中的所有数据 无返回值，直接在控制台打印结果 * */ @SuppressWarnings("deprecation") public static void getValueByTable(String tableName) throws Exception { Table table = null; try { table = connection.getTable(TableName.valueOf(tableName)); ResultScanner rs = table.getScanner(new Scan()); rs.forEach(r -> { System.out.println("获得到rowkey:" + new String(r.getRow())); Arrays.stream(r.raw()).forEach(keyValue -> { System.out.println("列：" + new String(keyValue.getFamily()) + ":" + new String(keyValue.getQualifier()) + "====值:" + new String(keyValue.getValue())); }); }); } finally { IOUtils.closeQuietly(table); } } public static void main(String[] args) throws Exception { System.out.println(createTable("learmTest","f1")); System.out.println("***************插入一条数据："); putDataH("learmTest","test1","f1","name","4545"); System.out.println("****************打印表中的数据："); getValueByTable("learmTest"); } }
运行结果：
