如何在Java中连接到远程HBase？

   <groupId>org.apache.hbase</groupId>
   <artifactId>hbase-client</artifactId>
   <version>2.2.3</version>
</dependency>

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

public class HBaseConnection {
    private Configuration configuration;
    private Connection connection;

    public HBaseConnection(String quorum, String port) {
        configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", quorum);
        configuration.set("hbase.zookeeper.property.clientPort", port);
        connection = ConnectionFactory.createConnection(configuration);
    }

    public Connection getConnection() {
        return connection;
    }

    public void close() {
        try {
            connection.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;

public class HBaseExample {
    private static final String TABLE_NAME = "my_table";
    private static final String COLUMN_FAMILY = "my_column_family";
    private static final String COLUMN_QUALIFIER = "my_column_qualifier";

    public static void main(String[] args) throws IOException {
        HBaseConnection hbaseConnection = new HBaseConnection("localhost", "2181");
        Connection connection = hbaseConnection.getConnection();

        // 创建表
        Admin admin = connection.getAdmin();
        TableName tableName = TableName.valueOf(TABLE_NAME);
        if (!admin.tableExists(tableName)) {
            admin.createTable(TableDescriptorBuilder.newBuilder(tableName)
                    .setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(COLUMN_FAMILY)).build())
                    .build());
        }

        // 插入数据
        Table table = connection.getTable(tableName);
        Put put = new Put(Bytes.toBytes("row1"));
        put.addColumn(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes(COLUMN_QUALIFIER), Bytes.toBytes("value1"));
        table.put(put);

        // 查询数据
        Get get = new Get(Bytes.toBytes("row1"));
        Result result = table.get(get);
        byte[] value = result.getValue(Bytes.toBytes(COLUMN_FAMILY), Bytes.toBytes(COLUMN_QUALIFIER));
        System.out.println("Value: " + Bytes.toString(value));

        // 关闭连接
        table.close();
        admin.close();
        hbaseConnection.close();
    }
}