• 專案背景
• 程式碼
• 打包
• 使用方式
  • 依賴
  • 整合

專案背景

1. 公司越來越多的專案採用spring-boot+hbase的查詢，由於公司的hbase版本為1.x的CDH版本，本身沒有spring-boot的starter，故寫出一個spring-boot-starter-hbase提供給各方專案使用。
2. 自定義的spring-boot的hbase starter，為hbase的query和更新等操作提供簡易的api並整合spring-boot的auto configuration。

程式碼

程式碼較多，見github，參考了spring-data-hadoop中hbase的api設計

github地址

打包

修改相關的maven私服地址

gradle clean install uploadArchives

使用方式

依賴

compile "jthink:spring-boot-starter-hbase:0.0.1"

整合

在spring-boot專案的application.properties檔案中加入spring.data.hbase.quorum配置項，並賦予正確的值

使用

query

1. 將上述配置項賦予正確的值
2. dto定義

public class PeopleDto {

  private
 
 String name;

  private int age;

  public String getName() {
  return name;
  }

  public PeopleDto setName(String name) {
  this.name = name;
  return this;
  }

  public int getAge() {
  return age;
  }

  public PeopleDto setAge(int age) {
  this.age = age;
  return this;
  }
}

1. RowMapper定義

import
 
 com.jthink.skyeye.data.hbase.api.RowMapper;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.util.Bytes;

public class PeopleRowMapper implements RowMapper<PeopleDto> {

  private static byte[] COLUMNFAMILY = "f".getBytes();
  private static byte[] NAME = "name".getBytes();
  private static byte[] AGE = "age".getBytes();

  @Override
  public PeopleDto mapRow(Result result, int rowNum) throws Exception {
  PeopleDto dto = new PeopleDto();
  // TODO: 設定相關的屬性值
  String name = Bytes.toString(result.getValue(COLUMNFAMILY, NAME));
  int age = Bytes.toInt(result.getValue(COLUMNFAMILY, AGE));

  return dto.setName(name).setAge(age);
  }
}

1. query操作

import com.jthink.skyeye.data.hbase.api.HbaseTemplate;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

public class QueryService {

  @Autowired
  private HbaseTemplate hbaseTemplate;

  public List<PeopleDto> query(String startRow, String stopRow) {
  Scan scan = new Scan(Bytes.toBytes(startRow), Bytes.toBytes(stopRow));
  scan.setCaching(5000);
  List<PeopleDto> dtos = this.hbaseTemplate.find("people_table", scan, new PeopleRowMapper());
  return dtos;
  }

  public PeopleDto query(String row) {
  PeopleDto dto = this.hbaseTemplate.get("people_table", row, new PeopleRowMapper());
  return dto;
  }
}

update等

1. 將上述配置項賦予正確的值
2. update、delete、put操作

import com.jthink.skyeye.data.hbase.api.HbaseTemplate;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Mutation;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

@Service
public class QueryService {

  @Autowired
  private HbaseTemplate hbaseTemplate;

  public List<PeopleDto> query(String startRow, String stopRow) {
  Scan scan = new Scan(Bytes.toBytes(startRow), Bytes.toBytes(stopRow));
  scan.setCaching(5000);
  List<PeopleDto> dtos = this.hbaseTemplate.find("people_table", scan, new PeopleRowMapper());
  return dtos;
  }

  public PeopleDto query(String row) {
  PeopleDto dto = this.hbaseTemplate.get("people_table", row, new PeopleRowMapper());
  return dto;
  }

  public void saveOrUpdates() {
  List<Mutation> puts = new ArrayList<>();
  // 設值
  this.hbaseTemplate.saveOrUpdates("people_table", puts);
  }

  public void saveOrUpdate() {
  Mutation delete = new Delete(Bytes.toBytes(""));
  this.hbaseTemplate.saveOrUpdate("people_table", delete);
  }
}

其他

不可以滿足需求的可以使用hbaseTemplate暴露出來的getConnection()方法