hbase3.0.0连接demo

以下是一个简单的HBase 3.0.0连接示例：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;

public class HBaseConnection {

    private static Connection connection = null;

    public static Connection getConnection() throws Exception {
        if (connection == null || connection.isClosed()) {
            Configuration config = new Configuration();
            config.set("hbase.zookeeper.quorum", "zk1.example.com,zk2.example.com,zk3.example.com");
            config.set("hbase.zookeeper.property.clientPort", "2181");
            connection = ConnectionFactory.createConnection(config);
        }
        return connection;
    }
}

在上面的示例中，我们使用HBase的Java API创建了一个连接对象。该连接对象可用于执行HBase数据库操作，例如读取或写入数据。我们使用了HBase的ConnectionFactory类创建连接。ConnectionFactory使用Hadoop的Configuration类配置连接参数。在上面的示例中，我们设置了HBase的zookeeper节点列表和端口号。这些参数可用于连接到HBase集群。getConnection()方法返回连接对象，如果连接对象不存在或已关闭，则创建一个新的连接对象。