使用hadoop hbase的spring boot rest

y53ybaqx  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(460)

我希望构建一个简单的restfullapi来访问hbase。我看起来很开心,但我的集群是kerberised。现在我进入了Spring。
我曾经用solr cloud和spring boot制作简单的api rest。
hbase也可以这样做吗?
我不知道我是否必须使用spring boot‘Yarn应用程序’=>https://spring.io/guides/gs/yarn-basic/
或spring hadoop。=>https://projects.spring.io/spring-hadoop/
只需要一个非常简单的api。
谢谢你的帮助。

j13ufse2

j13ufse21#

我编写了一个简单的演示项目,用于在spring boot restful应用程序中使用hbase而不使用xml。
这个演示主要依赖于spring数据hadoop和hbase客户端。
渐变相关性:

compile('org.springframework.boot:spring-boot-starter-data-rest')
compile('org.springframework.boot:spring-boot-starter-web')
compile 'org.springframework.data:spring-data-hadoop:2.5.0.RELEASE'
compile('org.apache.hbase:hbase-client:1.3.1'){
    exclude group :'log4j',module:'log4j'
    exclude group :'org.slf4j',module:'slf4j-log4j12'
    exclude group: 'javax.servlet', module: 'servlet-api'
}
compile('org.springframework.boot:spring-boot-configuration-processor')
providedRuntime('org.springframework.boot:spring-boot-starter-tomcat')

在spring boot的application.properties(没有xml!)中配置hbase连接参数:

spring.data.hbase.zkQuorum=192.168.0.109:2181
spring.data.hbase.zkBasePath=/hbase
spring.data.hbase.rootDir=file:///home/hbase-1.2.2

类hbaseproperties.java:

@ConfigurationProperties(prefix = "spring.data.hbase")
public class HbaseProperties {
    // Addresses of all registered ZK servers.
    private String zkQuorum;

    // Location of HBase home directory
    private String rootDir;

    // Root node of this cluster in ZK.
    private String zkBasePath;

    // getters and setters...

}

hbaseconfig.java,将配置注入hbasetemplate:

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.hadoop.hbase.HbaseTemplate;

@Configuration
@EnableConfigurationProperties(HbaseProperties.class)
public class HbaseConfig {

    @Autowired
    private HbaseProperties hbaseProperties;

    @Bean
    public HbaseTemplate hbaseTemplate() {
        org.apache.hadoop.conf.Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", this.hbaseProperties.getZkQuorum());
        configuration.set("hbase.rootdir", this.hbaseProperties.getRootDir());
        configuration.set("zookeeper.znode.parent", this.hbaseProperties.getZkBasePath());
        return new HbaseTemplate(configuration);
    }

}

服务类,我们现在可以使用配置的hbasetemplate:

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.hadoop.hbase.HbaseTemplate;
import org.springframework.stereotype.Service;

import com.zql.hbasedemo.vo.Quote;

@Service
public class FeedService {
    @Autowired
    private HbaseTemplate hbaseTemplate;

    @PostConstruct
    public void test(){
        Quote quote = new Quote();
        quote.setEventType("ft");
        quote.setHandicap("4");
        quote.setMarket("OU");
        quote.setMatchId("27350208");
        quote.setSelection("OVER");
        quote.setPrice("1.93");
        saveQuote(quote);
    }

    public Quote saveQuote(Quote quote) {
        hbaseTemplate.put("quotes", quote.getMatchId(), "data", quote.getMarket() + ":" + quote.getSelection(),
            quote.getPrice().getBytes());
        return quote;
    }
}

休息控制器。

@RestController
public class FeedController {
    @Autowired
    private FeedService feedService;

    @SuppressWarnings({ "unchecked", "rawtypes" })
    @PostMapping(value = "/feed/quote", consumes = "application/json", produces = "application/json")
    public ResponseEntity<Quote> saveQuote(@RequestBody Quote quote) {
        Quote result = feedService.saveQuote(quote);
        return new ResponseEntity(result, new HttpHeaders(), HttpStatus.OK);
    }
}

相关问题