springboot整合hbase

在Spring Boot中整合HBase，你可以按照以下步骤进行操作：

1. 添加HBase依赖：在`pom.xml`文件中添加HBase的依赖。

<dependency>
    <groupId>org.apache.hbase</groupId>
    <artifactId>hbase-client</artifactId>
    <version>版本号</version>
</dependency>

2. 配置HBase连接：在`application.properties`（或`application.yml`）文件中添加HBase的连接配置。

# HBase连接配置
hbase.zookeeper.quorum=ZooKeeper地址
hbase.zookeeper.property.clientPort=ZooKeeper端口号

3. 创建HBase连接配置类：创建一个Java类，用于配置HBase连接。

@Configuration
public class HBaseConfiguration {

    @Value("${hbase.zookeeper.quorum}")
    private String quorum;

    @Value("${hbase.zookeeper.property.clientPort}")
    private String clientPort;

    @Bean
    public Configuration configuration() {
        Configuration config = HBaseConfiguration.create();
        config.set("hbase.zookeeper.quorum", quorum);
        config.set("hbase.zookeeper.property.clientPort", clientPort);
        return config;
    }

    @Bean
    public Connection connection() throws IOException {
        return ConnectionFactory.createConnection(configuration());
    }
}

4. 创建HBase操作类：创建一个Java类，用于封装HBase的操作方法。

@Repository
public class HBaseRepository {

    @Autowired
    private Connection connection;

    public void putData(String tableName, String rowKey, String columnFamily, String column, String value) throws IOException {
        TableName tName = TableName.valueOf(tableName);
        Table table = connection.getTable(tName);

        Put put = new Put(Bytes.toBytes(rowKey));
        put.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(value));

        table.put(put);
        table.close();
    }

    public String getData(String tableName, String rowKey, String columnFamily, String column) throws IOException {
        TableName tName = TableName.valueOf(tableName);
        Table table = connection.getTable(tName);

        Get get = new Get(Bytes.toBytes(rowKey));
        Result result = table.get(get);

        byte[] valueBytes = result.getValue(Bytes.toBytes(columnFamily), Bytes.toBytes(column));
        String value = Bytes.toString(valueBytes);

        table.close();
        return value;
    }
}

这里只提供了示例的插入和查询操作方法，你可以根据实际需求扩展其他操作。

现在，你可以在Spring Boot应用程序中使用`HBaseRepository`类来执行HBase的操作了。