hbase在springboot中怎样配置

在Spring Boot中配置HBase，你需要遵循以下步骤：

1. 添加依赖

在你的pom.xml文件中，添加HBase和Spring Data HBase的依赖：

    
    
        org.springframework.boot
        spring-boot-starter-data-hbase
    

    
    
        org.apache.hbase
        hbase-client
        2.4.9
    

    
    
        commons-codec
        commons-codec
        1.15
    

2. 配置application.properties

在你的application.properties文件中，添加HBase的连接信息：

# HBase连接信息
spring.data.hbase.host=localhost
spring.data.hbase.port=9090
spring.data.hbase.keyspace=my_keyspace

# HBase扫描配置
spring.data.hbase.table.scan=my_table

3. 创建配置类

创建一个配置类，用于初始化HBase的ConnectionFactory和Template：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class HBaseConfig {

    @Value("${spring.data.hbase.host}")
    private String host;

    @Value("${spring.data.hbase.port}")
    private int port;

    @Value("${spring.data.hbase.keyspace}")
    private String keyspace;

    @Bean
    public ConnectionFactory connectionFactory() {
        Configuration config = new Configuration(false);
        config.set("hbase.zookeeper.quorum", host + ":" + port);
        return ConnectionFactory.createConnection(config);
    }

    @Bean
    public Table table(ConnectionFactory connectionFactory) throws Exception {
        Connection connection = connectionFactory.createConnection();
        return connection.getTable(Bytes.toBytes(keyspace));
    }
}

4. 使用HBase

在你的服务类中，使用@Autowired注解注入Table对象，然后进行HBase操作：

import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Table;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MyService {

    @Autowired
    private Table table;

    public void putData(String rowKey, String value) throws Exception {
        Put put = new Put(Bytes.toBytes(rowKey));
        put.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("column"), Bytes.toBytes(value));
        table.put(put);
    }
}

现在你已经成功地在Spring Boot中配置了HBase，并可以使用MyService类进行HBase操作。