七十七、HBase客户端的群集连接

HBase客户端群集连接

##

API在HBase 1.0中进行了更改。有关连接配置信息,请参阅连接到HBase群集的客户端配置和依赖关系。

HBase 1.0.0的API

它已被清理并且用户被返回接口来处理而不是特定的类型。在HBase的1.0,从ConnectionFactory获得Connection对象,在需要的基础上从Table,Admin以及RegionLocator获取它的实例。完成后关闭获取的实例。最后,确保在退出之前清理您的Connection实例。 Connections是重量级的对象,但线程安全,所以你可以为你的应用程序创建一个并保持实例。 Table,Admin和RegionLocator实例是轻量级的。随时创建,然后在关闭它们后立即放手。

HBase 1.0.0之前的API

实例HTable是与1.0.0之前的HBase集群版本进行交互的方式。表实例不是线程安全的。在任何给定的时间,只有一个线程可以使用Table的一个实例。在创建Table实例时,建议使用相同的HBaseConfiguration实例。这将确保将ZooKeeper和套接字实例共享到RegionServers,而这通常是您想要的。例如,这是首选:

HBaseConfiguration conf = HBaseConfiguration.create();
HTable table1 = new HTable(conf, "myTable");
HTable table2 = new HTable(conf, "myTable");

与此相反:

HBaseConfiguration conf1 = HBaseConfiguration.create();
HTable table1 = new HTable(conf1, "myTable");
HBaseConfiguration conf2 = HBaseConfiguration.create();
HTable table2 = new HTable(conf2, "myTable");

有关如何在HBase客户端中处理连接的更多信息,请参阅ConnectionFactory。

连接池

对于需要高端多线程访问的应用程序(例如,可在单个JVM中为多个应用程序线程提供服务的Web服务器或应用程序服务器),可以预先创建一个Connection,如以下示例所示:

例子:预先创建一个Connection

// Create a connection to the cluster.
Configuration conf = HBaseConfiguration.create();
try (Connection connection = ConnectionFactory.createConnection(conf);
     Table table = connection.getTable(TableName.valueOf(tablename))) {
  // use table as needed, the table returned is lightweight

HTablePool已弃用

本指南的以前版本讨论了HTablePool,它在HBase 0.94、0.95和0.96中被否决, 并在0.98.1、HBASE-6580 或 HConnection 中删除, 这在 HBase 1.0 中被弃用连接。请改用连接,请改用Connection。

文章永久链接:https://ddkk.com/?p=12556