1. import com.desheng.bigdata.personas.common.time.DateUtils;
  2. import org.apache.hadoop.conf.Configuration;
  3. import org.apache.hadoop.hbase.HBaseConfiguration;
  4. import org.apache.hadoop.hbase.client.Connection;
  5. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import java.io.IOException;
  8. import java.util.LinkedList;
  10. public class HBaseUtils {
  13.     private static LinkedList<Connection> pool = new LinkedList<>();
  16.     static {
  17.         try {
  18.             Configuration conf = HBaseConfiguration.create();
  19.             for(int i = 0; i < 10; i++) {
  20.                 pool.push(ConnectionFactory.createConnection(conf));
  21.             }
  22.         } catch (IOException e) {
  23.             e.printStackTrace();
  24.         }
  25.     }
  28.     public static Connection getHBaseConnection() {
  29.         while (pool.isEmpty()) {
  30.             DateUtils.sleep(1000);
  31.         }
  32.         return pool.poll();
  33.     }
  36.     public static void release(Connection connection) {
  37.         pool.push(connection);
  38.     }
  39. }

 

版权声明：本文为zhangxiaofan原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/zhangxiaofan/p/14267301.html