java - Hbase 1.0.0连接池

Question

由于 Hbase 1.0+ API 未使用 HConnection 处理连接池，我想知道创建连接池的最佳实践是什么？

到目前为止，我已经创建了一个 Connection对象为 ThreadLocal ，但我不确定这是否是个好主意。

一般来说，既然连接对象这么重，创建一个连接池是个好主意吗？

有人知道吗？

Answer 1

您可以为每个应用程序使用一个连接，因为创建它很繁重并且它是线程安全的。但是请确保关闭从 Connection

获取的 Table 和 Admin

private static class ConnectionHolder{
  private final Connection connection;

  private ConnectionHolder(){
   connection = ConnectionFactory.createConnection(config); 
  }

 Connection getConnection(){
  return connection;
  }
}

如果您使用这种方法，请不要公开连接，这样调用者就不会意外关闭它。但请记住关闭 Tables 和 ResultScanners

Table getTable(String name){
  Table table = connection.getTable(TableName.valueOf(name));
  return table;
}

try(Table table = getTable("tableName")){
  ...
}