SpringBoot 中項(xiàng)目中使用Habse

引入POM

<dependency>

 <groupId>org.apache.hbase</groupId>

 <artifactId>hbase-client</artifactId>

 <version>1.1.3</version>

 <exclusions>

 <exclusion>

 <groupId>org.slf4j</groupId>

 <artifactId>slf4j-log4j12</artifactId>

 </exclusion>

 <exclusion>

 <groupId>org.mortbay.jetty</groupId>

 <artifactId>servlet-api-2.5</artifactId>

 </exclusion>

 <exclusion>

 <groupId>org.mortbay.jetty</groupId>

 <artifactId>servlet-api-2.5-6.1.14</artifactId>

 </exclusion>

 <exclusion>

 <groupId>com.google.guava</groupId>

 <artifactId>guava</artifactId>

 </exclusion>

 </exclusions>

 </dependency>

 <dependency>

 <groupId>org.springframework.data</groupId>

 <artifactId>spring-data-hadoop-boot</artifactId>

 <version>[2.5.0.RELEASE](2.5.0.RELEASE)</version>

 <exclusions>

 <exclusion>

 <groupId>javax.servlet</groupId>

 <artifactId>servlet-api</artifactId>

 </exclusion>

 </exclusions>

 </dependency>

 <dependency>

 <groupId>org.springframework.data</groupId>

 <artifactId>spring-data-hadoop</artifactId>

 <version>[2.5.0.RELEASE](2.5.0.RELEASE)</version>

 <exclusions>

 <exclusion>

 <groupId>org.slf4j</groupId>

 <artifactId>slf4j-log4j12</artifactId>

 </exclusion>

 <exclusion>

 <groupId>log4j</groupId>

 <artifactId>log4j</artifactId>

 </exclusion>

 <exclusion>

 <groupId>javax.servlet</groupId>

 <artifactId>servlet-api</artifactId>

 </exclusion>

 </exclusions>

 </dependency>

 <dependency>

 <groupId>com.google.guava</groupId>

 <artifactId>guava</artifactId>

 <version>22.0</version>

 </dependency>

配置文件中 加入

hbase.config.hbase.zookeeper.quorum: XXX hbase.config.hbase.zookeeper.property.clientPort: XXXX

因?yàn)?pom Hbase引入了Guava 是13 的低版本 如果項(xiàng)目中引入了Guava 高版本的 需要在項(xiàng)目中重寫一個(gè)類 Stopwatch

package com.google.common.base;

package com.google.common.base;

/*

Copyright (C) 2008 The Guava Authors
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

import com.google.common.annotations.GwtCompatible;

import com.google.common.annotations.Beta;
import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.base.Ticker;

import java.util.concurrent.TimeUnit;

import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;
import static java.util.concurrent.TimeUnit.*;

/**
 * An object that measures elapsed time in nanoseconds. It is useful to measure
 * elapsed time using this class instead of direct calls to {@link
 * System#nanoTime} for a few reasons:
 * An alternate time source can be substituted, for testing or performance
 * reasons.
 * As documented by {@code nanoTime}, the value returned has no absolute
 * meaning, and can only be interpreted as relative to another timestamp
 * returned by {@code nanoTime} at a different time. {@code Stopwatch} is a
 * more effective abstraction because it exposes only these relative values,
 * not the absolute ones.
 * Basic usage:
 * <p>
 * Stopwatch stopwatch = Stopwatch.{@link #createStarted createStarted}();
 * doSomething();
 * stopwatch.{@link #stop stop}(); // optional
 * long millis = stopwatch.elapsed(MILLISECONDS);
 * log.info("time: " + stopwatch); // formatted string like "12.3 ms"
 * Stopwatch methods are not idempotent; it is an error to start or stop a
 * <p>
 * stopwatch that is already in the desired state.
 * When testing code that uses this class, use
 * <p>
 * {@link #createUnstarted(Ticker)} or {@link #createStarted(Ticker)} to
 * supply a fake or mock ticker.
 * This allows you to
 * simulate any valid behavior of the stopwatch.
 * Note: This class is not thread-safe.
 *
 * @author Kevin Bourrillion
 * @SInCE 10.0
 */
@Beta
@GwtCompatible(emulated = true)
public final class Stopwatch {
    private final Ticker ticker;
    private boolean isRunning;
    private long elapsedNanos;
    private long startTick;

    /**
     * Creates (but does not start) a new stopwatch using {@link System#nanoTime}
     * as its time source.
     *
     * @SInCE 15.0
     */
    public static com.google.common.base.Stopwatch createUnstarted() {
        return new com.google.common.base.Stopwatch();
    }

    /**
     * Creates (but does not start) a new stopwatch, using the specified time
     * source.
     *
     * @SInCE 15.0
     */
    public static com.google.common.base.Stopwatch createUnstarted(Ticker ticker) {
        return new com.google.common.base.Stopwatch(ticker);
    }

    /**
     * Creates (and starts) a new stopwatch using {@link System#nanoTime}
     * as its time source.
     *
     * @SInCE 15.0
     */
    public static com.google.common.base.Stopwatch createStarted() {
        return new com.google.common.base.Stopwatch().start();
    }

    /**
     * Creates (and starts) a new stopwatch, using the specified time
     * source.
     *
     * @SInCE 15.0
     */
    public static com.google.common.base.Stopwatch createStarted(Ticker ticker) {
        return new com.google.common.base.Stopwatch(ticker).start();
    }

    /**
     * Creates (but does not start) a new stopwatch using {@link System#nanoTime}
     * as its time source.
     *
     * @deprecated Use {@link com.google.common.base.Stopwatch#createUnstarted()} instead.
     */
    @Deprecated
    public Stopwatch() {
        this(Ticker.systemTicker());
    }

    /**
     * Creates (but does not start) a new stopwatch, using the specified time
     * source.
     *
     * @deprecated Use {@link com.google.common.base.Stopwatch#createUnstarted(Ticker)} instead.
     */
    @Deprecated
    Stopwatch(Ticker ticker) {
        this.ticker = checkNotNull(ticker, "ticker");
    }

    /**
     * Returns {@code true} if {@link #start()} has been called on this stopwatch,
     * and {@link #stop()} has not been called since the last call to {@code
     * start()}.
     */
    public boolean isRunning() {
        return isRunning;
    }

    /**
     * Starts the stopwatch.
     *
     * @return this {@code Stopwatch} instance
     * @throws IllegalStateException if the stopwatch is already running.
     */
    public com.google.common.base.Stopwatch start() {
        checkState(!isRunning, "This stopwatch is already running.");
        isRunning = true;
        startTick = ticker.read();
        return this;
    }

    /**
     * Stops the stopwatch. Future reads will return the fixed duration that had
     * elapsed up to this point.
     *
     * @return this {@code Stopwatch} instance
     * @throws IllegalStateException if the stopwatch is already stopped.
     */
    public com.google.common.base.Stopwatch stop() {
        long tick = ticker.read();
        checkState(isRunning, "This stopwatch is already stopped.");
        isRunning = false;
        elapsedNanos += tick - startTick;
        return this;
    }

    /**
     * Sets the elapsed time for this stopwatch to zero,
     * and places it in a stopped state.
     *
     * @return this {@code Stopwatch} instance
     */
    public com.google.common.base.Stopwatch reset() {
        elapsedNanos = 0;
        isRunning = false;
        return this;
    }

    private long elapsedNanos() {
        return isRunning ? ticker.read() - startTick + elapsedNanos : elapsedNanos;
    }

    /**
     * Returns the current elapsed time shown on this stopwatch, expressed
     * in the desired time unit, with any fraction rounded down.
     * Note that the overhead of measurement can be more than a microsecond, so
     * <p>
     * it is generally not useful to specify {@link TimeUnit#NANOSECONDS}
     * precision here.
     *
     * @SInCE 14.0 (since 10.0 as {@code elapsedTime()})
     */
    public long elapsed(TimeUnit desiredUnit) {
        return desiredUnit.convert(elapsedNanos(), NANOSECONDS);
    }

    /**
     * Returns a string representation of the current elapsed time.
     */
    @GwtIncompatible("String.format()")
    @Override
    public String toString() {
        long nanos = elapsedNanos();
        TimeUnit unit = chooseUnit(nanos);
        double value = (double) nanos / NANOSECONDS.convert(1, unit);

// Too bad this functionality is not exposed as a regular method call
        return String.format("%.4g %s", value, abbreviate(unit));
    }

    private static TimeUnit chooseUnit(long nanos) {
        if (DAYS.convert(nanos, NANOSECONDS) > 0) {
            return DAYS;
        }
        if (HOURS.convert(nanos, NANOSECONDS) > 0) {
            return HOURS;
        }
        if (MINUTES.convert(nanos, NANOSECONDS) > 0) {
            return MINUTES;
        }
        if (SECONDS.convert(nanos, NANOSECONDS) > 0) {
            return SECONDS;
        }
        if (MILLISECONDS.convert(nanos, NANOSECONDS) > 0) {
            return MILLISECONDS;
        }
        if (MICROSECONDS.convert(nanos, NANOSECONDS) > 0) {
            return MICROSECONDS;
        }
        return NANOSECONDS;
    }

    private static String abbreviate(TimeUnit unit) {
        switch (unit) {
            case NANOSECONDS:
                return "ns";
            case MICROSECONDS:
                return "\u03bcs"; // μs
            case MILLISECONDS:
                return "ms";
            case SECONDS:
                return "s";
            case MINUTES:
                return "min";
            case HOURS:
                return "h";
            case DAYS:
                return "d";
            default:
                throw new AssertionError();
        }
    }
}

工具類

@Data
@Component
public class HbaseStorage {
    @Autowired(required = false)
    HbaseTemplate hbaseTemplate;
    private String familyName;

    public boolean save(String tableName,String rowKey,String familyName,Map<String,Object>  data) {
        if (StringUtils.isBlank(familyName)){
            throw new RuntimeException("請?jiān)O(shè)置  默認(rèn) familyName 的值");
        }

        for (Map.Entry<String, Object> entry : data.entrySet()) {
            hbaseTemplate.put(tableName,rowKey,familyName,entry.getKey(), Bytes.toBytes(String.valueOf(entry.getValue())));
        }
        return true;
    }
    public <T>boolean save(String tableName,String rowKey,String familyName,T data) {
        Map<String, Object> dataMap = BaseBeanUtils.beanToMap(data);
        return save(tableName, rowKey, familyName, dataMap);
    }
    public <T>boolean save(String tableName,String rowKey,T data) {
        return save(tableName, rowKey, familyName, data);
    }



    public <T>List<T> getByPre (String tableName,String pre,Class<T> type){
        Map<String, Map<String,String>> resultMap = Maps.newHashMap();
        Scan scan = new Scan();
        Filter filter = new PrefixFilter(Bytes.toBytes(pre));
        scan.setFilter(filter);
        hbaseTemplate.find(tableName, scan, (RowMapper) (result, rowNum) -> {
            List<Cell> ceList = result.listCells();
            if (ceList != null && ceList.size() > 0) {
                for (Cell cell : ceList) {
                    String rowKey = Bytes.toString(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength());
                    String qualifierName = Bytes.toString(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());
                    String qualifierValue = Bytes.toString(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());
                    if (!resultMap.containsKey(rowKey)){
                        resultMap.put(rowKey, Maps.newHashMap());
                    }
                    resultMap.get(rowKey).put(qualifierName, qualifierValue);
                }
            }
            return "";
        });

        List<T> list = Lists.newArrayList();
        for (Map.Entry<String, Map<String, String>> entry : resultMap.entrySet()) {
            T convert = BaseBeanUtils.convert(entry.getValue(), type);
            list.add(convert);
        }
        return list;
    }

    public static void main(String[] args) {
        Bean userContact = new Bean();
        userContact.setA("1");
        userContact.setB(1L);
        userContact.setC(1L);
        userContact.setF(1);
        userContact.setG(1);
        userContact.setH(new Object());
        userContact.setI(true);
        Map<String, String> result = Maps.newHashMap();
        Map<String, Object> stringObjectMap = BaseBeanUtils.beanToMap(userContact);
        System.out.println(stringObjectMap);
        for (Map.Entry<String, Object> entry : stringObjectMap.entrySet()) {
            byte[] bytes = Bytes.toBytes(String.valueOf(entry.getValue()));
            result.put(entry.getKey(), Bytes.toString(bytes));
        }

        Bean convert = BaseBeanUtils.convert(result, Bean.class);
        System.out.println(convert);
    }



}
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務(wù)發(fā)現(xiàn)，斷路器，智...
    卡卡羅2017閱讀 136,537評論 19贊 139
  • Spring Boot 參考指南 介紹 轉(zhuǎn)載自:https://www.gitbook.com/book/qbgb...
    毛宇鵬閱讀 47,262評論 6贊 342
  • 大學(xué)要找到自己真正感興趣的知識(shí)，然后努力學(xué)習(xí)，不管知識(shí)是本專業(yè)還是非專業(yè)，沒有任何的影響，但是關(guān)鍵點(diǎn)就是在于要學(xué)習(xí)...
    peterzyzson閱讀 286評論 0贊 1
  • 求職平臺(tái)提供的工作機(jī)會(huì)看似選擇很多，其實(shí)別無選擇。招聘方每天閱讀的簡歷目不暇接，有幸被邀請的面試，基本都會(huì)安排在第...
    d2b4348a5c47閱讀 468評論 0贊 1
  • 舅舅是鄉(xiāng)村醫(yī)生，一年四季都很忙，接到電話就要出門給別人看病。每年過年的幾天，才能休息一下。 這幾天，我在取暖屋里看...
    lucky乖乖魚閱讀 299評論 0贊 0

友情鏈接更多精彩內(nèi)容