线程池的方式构建hbase的connection，hbaseconnection

线程池的方式构建hbase的connection，hbaseconnection

package normal.dao;

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HConnection;
import org.apache.hadoop.hbase.client.HConnectionManager;

/*通过线程池的方式来获取hbase的connection；这样做的好处是在创建的时候就有一定数量
 * 的connection，每次使用的時候直接去線程池中取就可以了，不需要每次都创建connection
 * 。connection是一个比较重的对象，可以节约很多系统的资源。（2017.05.04修改：使用单利模式创造HConneciton的作用是整个应用使用一个HConnection实例，

这里的线程池指的是该connection在批处理请求时所使用的线程数，如一楼的哥们儿所说。）*/

public class HbaseConnectionGenerator {  
private static final Object lock=new Object();  
  
private HbaseConnectionGenerator() {//私有化构造方法，让用户不能new这个类的对象  
  
}  
  
private static HConnection connection = null;//要创建的connection  
  
public static HConnection getConnection() { 
if (null == connection){
synchronized (lock) {
        if (null == connection) {//空的时候创建，不为空就直接返回；典型的单例模式  
            Configuration conf = HBaseConfiguration.create();  
            String zkHost = "mpc5:2181,mpc6:2181,mpc7:2181";  
            conf.set("hbase.zookeeper.quorum", zkHost);  
            ExecutorService pool = Executors.newFixedThreadPool(10);//建立一个数量为10的线程池  
            try {  
                connection = HConnectionManager.createConnection(conf, pool);//用线程池创建connection  
            } catch (IOException e) {  
                e.printStackTrace();  
            }  
        }
		}
		}  
        return connection;  
    }  
}