HbaseConnectionWarehouse.java 文件源码

private HbaseConnectionWarehouse() {
    conns = new LinkedList<>();
    logger = Logger.getLogger(HbaseConnectionWarehouse.class);  // logger
    conf = HBaseConfiguration.create();                         // configuration

    Properties properties = new Properties();
    try {
        properties.load(new FileInputStream("/home/xwtech/configuration/configuration.properties"));
    } catch (Exception e) {
        logger.error("读取properties文件出错！\n"+e.getMessage());
    } 
    maxSize = Integer.parseInt(properties.getProperty("hbaseConnectionMaxsize", "5"));
    String quorum = properties.getProperty("hbaseZookeeperQuorum", "n1.cluster,n2.cluster,n3.cluster");

    conf.set("hbase.zookeeper.quorum", quorum);

    currentSize = 0;
    usableSize = 0;
}