1. 创建 hbase 连接池

  1. import org.apache.hadoop.conf.Configuration
  2. import org.apache.hadoop.hbase.client.{Connection, ConnectionFactory}
  3. import org.apache.hadoop.hbase.HBaseConfiguration
  4. import org.slf4j.{Logger, LoggerFactory}
  6. object HbaseConnectionPool {
  7.     private var conn: Connection = _
  8.     private var index: Int = _
  9.     private val logger: Logger = LoggerFactory.getLogger(this.getClass)
  11.     def getConnection: Connection = {
  12.         if (conn == null) {
  13.             this.synchronized {
  14.                 if (conn == null) {
  15.                     createConnection()
  16.                 }
  17.             }
  18.         }
  19.         conn
  20.     }
  22.     private def createConnection(): Unit = {
  23.         index += 1
  24.         logger.warn(s"------------hbase connection created for the ${index} time ---------------")
  25.         val hbaseConf: Configuration = HBaseConfiguration.create()
  26.         hbaseConf.set("hbase.zookeeper.quorum", "hbase01:2181")
  27.         hbaseConf.set("zookeeper.znode.parent", "/hbase")
  28.         //hbaseConf.set("hbase.zookeeper.property.clientPort", "2181")
  29.         conn = ConnectionFactory.createConnection(hbaseConf)
  30.     }
  31. }

https://blog.csdn.net/ycf921244819/article/details/81706119