// Path: hbase-tutorial/src/main/java/com/micmiu/bigdata/hbase/client/HBaseClientManager.java
// public class HBaseClientManager implements HBaseConnPool {
// 
// 	private static final Logger LOGGER = LoggerFactory.getLogger(HBaseClientManager.class);
// 
// 	private static final String DEF_ZNODE = "/hbase";
// 
// 	private Configuration config;
// 	private HConnection conn;
// 
// 	public HBaseClientManager() {
// 		this.config = HBaseConfiguration.create();
// 	}
// 
// 	public HBaseClientManager(Configuration config) {
// 		this.config = config;
// 	}
// 
// 	public HBaseClientManager(String quorum, int port) {
// 		//默认为 : /hbase  EDH: /hyperbase1
// 		this(quorum, port, DEF_ZNODE);
// 	}
// 
// 
// 	public HBaseClientManager(String quorum, int port, String znode) {
// 		Configuration conf = HBaseConfiguration.create();
// 		conf.set("hbase.zookeeper.property.clientPort", port + "");
// 		conf.set("hbase.zookeeper.quorum", quorum);
// 		conf.set("zookeeper.znode.parent", znode);
// 		this.config = conf;
// 	}
// 
// 	public synchronized HConnection getConn() {
// 		if (null == conn) {
// 			try {
// 				this.conn = HConnectionManager.createConnection(config);
// 			} catch (Exception ex) {
// 				LOGGER.error("create conn err:", ex);
// 			}
// 		}
// 		return conn;
// 	}
// 
// 
// 	public void closeConn() {
// 		if (null != conn) {
// 			try {
// 				conn.close();
// 			} catch (Exception ex) {
// 				ex.printStackTrace();
// 			}
// 		}
// 	}
// 
// 	public void reloadConfig() {
// 		this.closeConn();
// 		this.getConn();
// 	}
// 
// 	public void setup() {
// 
// 	}
// 
// 	public Configuration getConfig() {
// 		return config;
// 	}
// 
// 	public void setConfig(Configuration config) {
// 		this.config = config;
// 		this.reloadConfig();
// 	}
// }


import com.micmiu.bigdata.hbase.client.HBaseClientManager;
package com.micmiu.bigdata.hbase.test;


/**
 * Created
 * User: <a href="http://micmiu.com">micmiu</a>
 * Date: 8/27/2015
 * Time: 13:18
 */
public class HBaseClientMangerTest {


	public static void main(String[] args) throws Exception {
		String quorum = "192.168.0.30,192.168.0.31,192.168.0.32";
		//quorum = "192.168.8.191,192.168.1.192,192.168.1.193";
		int port = 2181;
		String znode = "/hyperbase1"; //hbase
// Path: hbase-tutorial/src/main/java/com/micmiu/bigdata/hbase/client/HBaseClientManager.java
// public class HBaseClientManager implements HBaseConnPool {
// 
// 	private static final Logger LOGGER = LoggerFactory.getLogger(HBaseClientManager.class);
// 
// 	private static final String DEF_ZNODE = "/hbase";
// 
// 	private Configuration config;
// 	private HConnection conn;
// 
// 	public HBaseClientManager() {
// 		this.config = HBaseConfiguration.create();
// 	}
// 
// 	public HBaseClientManager(Configuration config) {
// 		this.config = config;
// 	}
// 
// 	public HBaseClientManager(String quorum, int port) {
// 		//默认为 : /hbase  EDH: /hyperbase1
// 		this(quorum, port, DEF_ZNODE);
// 	}
// 
// 
// 	public HBaseClientManager(String quorum, int port, String znode) {
// 		Configuration conf = HBaseConfiguration.create();
// 		conf.set("hbase.zookeeper.property.clientPort", port + "");
// 		conf.set("hbase.zookeeper.quorum", quorum);
// 		conf.set("zookeeper.znode.parent", znode);
// 		this.config = conf;
// 	}
// 
// 	public synchronized HConnection getConn() {
// 		if (null == conn) {
// 			try {
// 				this.conn = HConnectionManager.createConnection(config);
// 			} catch (Exception ex) {
// 				LOGGER.error("create conn err:", ex);
// 			}
// 		}
// 		return conn;
// 	}
// 
// 
// 	public void closeConn() {
// 		if (null != conn) {
// 			try {
// 				conn.close();
// 			} catch (Exception ex) {
// 				ex.printStackTrace();
// 			}
// 		}
// 	}
// 
// 	public void reloadConfig() {
// 		this.closeConn();
// 		this.getConn();
// 	}
// 
// 	public void setup() {
// 
// 	}
// 
// 	public Configuration getConfig() {
// 		return config;
// 	}
// 
// 	public void setConfig(Configuration config) {
// 		this.config = config;
// 		this.reloadConfig();
// 	}
// }


// Path: hbase-tutorial/src/test/java/com/micmiu/bigdata/hbase/test/HBaseClientMangerTest.java
import com.micmiu.bigdata.hbase.client.HBaseClientManager;

package com.micmiu.bigdata.hbase.test;


/**
 * Created
 * User: <a href="http://micmiu.com">micmiu</a>
 * Date: 8/27/2015
 * Time: 13:18
 */
public class HBaseClientMangerTest {


	public static void main(String[] args) throws Exception {
		String quorum = "192.168.0.30,192.168.0.31,192.168.0.32";
		//quorum = "192.168.8.191,192.168.1.192,192.168.1.193";
		int port = 2181;
		String znode = "/hyperbase1"; //hbase
		HBaseClientManager clientManager = new HBaseClientManager(quorum, port, znode);