SpringBoot整合HBase

￡神魔★判官ぃ 2022-10-06 04:47 196阅读 0赞

本文演示SpringBoot整合HBase。  
一、项目搭建  
新建一个SpringBoot项目，引入依赖：

<properties>
                <java.version>1.8</java.version>
                <hbase.version>2.1.0</hbase.version>
            </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.spring4all</groupId>
                <artifactId>swagger-spring-boot-starter</artifactId>
                <version>1.8.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-validation</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.apache.hbase</groupId>
                <artifactId>hbase-server</artifactId>
                <version>${hbase.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.hbase</groupId>
                <artifactId>hbase-client</artifactId>
                <version>${hbase.version}</version>
            </dependency>
            
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            
            <dependency>
                <groupId>com.spring4all</groupId>
                <artifactId>swagger-spring-boot-starter</artifactId>
                <version>1.8.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-validation</artifactId>
            </dependency>
        </dependencies>

二、配置文件  
配置项目端口号及Hbase配置：

hbase:
      config:
        hbase:
          master: 127.0.0.1:16010
          zookeeper:
            property:
              clientPort: 2181
            quorum: 127.0.0.1
    server:
      port: 8989

三、配置类  
①Swagger配置类

@Configuration
    @EnableSwagger2
    public class Swagger2Configure {
        @Bean
        public Docket createRestApi() {
            return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo()).select()
                    .apis(RequestHandlerSelectors.basePackage("com.example.demo.controller"))
                    .paths(PathSelectors.any()).build();
        }
    
        /**
        定义展示的信息，例如标题、描述、版本等
         */
        private ApiInfo apiInfo() {
            return new ApiInfoBuilder().title("api文档").description("api文档").version("1.0").build();
        }
    }

②Hbase配置类

@org.springframework.context.annotation.Configuration
    @EnableConfigurationProperties(HbaseProperties.class)
    public class HbaseConfig {
        
        private final HbaseProperties prop;
    
        public HbaseConfig(HbaseProperties properties) {
            this.prop = properties;
        }
    
        @Bean
        public Configuration configuration() {
            Configuration configuration = HBaseConfiguration.create();
            Map<String, String> config = prop.getConfig();
            config.forEach(configuration::set);
            return configuration;
        }
        
        @Bean
        public Connection getConnection() throws IOException{
            return ConnectionFactory.createConnection(configuration());
        }
    }

③Hbase属性配置类

@ConfigurationProperties(prefix = "hbase")
    public class HbaseProperties {
    
        private Map<String, String> config;
    
        public Map<String, String> getConfig() {
            return config;
        }
    
        public void setConfig(Map<String, String> config) {
            this.config = config;
        }
    }

④Hbase客户端工具类

@Component
    @Slf4j
    public class HbaseClientUtils {
    
        private final Connection connection;
    
        public HbaseClientUtils(Connection connection) {
            this.connection = connection;
        }
    
        /**
         * 创建表
         * - 只有一个列族
         * @param tableName 表名
         * @param colFamily 列族
         * @throws IOException
         */
        public void createTable(String tableName, String colFamily) throws IOException {
            TableName table = TableName.valueOf(tableName);
            try (HBaseAdmin admin = (HBaseAdmin) connection.getAdmin()) {
                if (admin.tableExists(table)) {
                    log.warn("表[{}]已存在!", tableName);
                    return;
                }
                ColumnFamilyDescriptor cfd = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(colFamily))
                        // 设置数据版本数量
                        .setMaxVersions(1)
                        // 设置副本数，默认是3
                        .setDFSReplication((short) 2)
                        .build();
                TableDescriptor tableDes = TableDescriptorBuilder.newBuilder(table).setColumnFamily(cfd).build();
                admin.createTable(tableDes);
            }
        }
    
        /**
         * 列出hbase中所有的表
         */
        public List<String> listTables() throws IOException {
            List<String> tables = new ArrayList<>(8);
            try (HBaseAdmin admin = (HBaseAdmin) connection.getAdmin()) {
                TableName[] tableNames = admin.listTableNames();
                for (TableName tableName : tableNames) {
                    tables.add(tableName.getNameAsString());
                }
            }
            return tables;
        }
    }

四、编码实现  
①编写Controller类及测试请求方法：

@RestController
    @RequestMapping(value = "/")
    @RequiredArgsConstructor
    @Api(tags = "HBase Api")
    public class HbaseController {
    
        private final HbaseClientUtils hbaseClientUtils;
    
        @GetMapping("list")
        @ApiOperation("列出hbase中所有的表")
        public List<String> list() throws Exception{
            List<String> list = hbaseClientUtils.listTables();
            return list;
        }
    
        @PostMapping("create")
        @ApiOperation("创建表")
        public void create() throws Exception{
            hbaseClientUtils.createTable("wx666","wx666");
        }
    }

②启动类

@SpringBootApplication
    public class DemoApplication {
        public static void main(String[] args) {
            SpringApplication.run(DemoApplication.class, args);
        }
    
    }

③本地Docker启动Hbase后,启动项目并访问http://localhost:8989/swagger-ui.html：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xkbGxvdmVneWg_size_16_color_FFFFFF_t_70][]  
测试验证OK。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xkbGxvdmVneWg_size_16_color_FFFFFF_t_70]: /images/20221005/def6d999d5274b6cb0d311897f7aac87.png