布隆過(guò)濾器:解決Redis緩存穿透的問(wèn)題

本文僅作為筆者學(xué)習(xí)記錄之用,侵刪
原文:https://www.cnblogs.com/CodeBear/p/10911177.html

緩存穿透

我們經(jīng)常會(huì)把一部分?jǐn)?shù)據(jù)放在Redis等緩存,比如產(chǎn)品詳情。這樣有查詢(xún)請(qǐng)求進(jìn)來(lái),我們可以根據(jù)產(chǎn)品Id直接去緩存中取數(shù)據(jù),而不用讀取數(shù)據(jù)庫(kù),這是提升性能最簡(jiǎn)單,最普遍,也是最有效的做法。一般的查詢(xún)請(qǐng)求流程是這樣的:先查緩存,有緩存的話直接返回,如果緩存中沒(méi)有,再去數(shù)據(jù)庫(kù)查詢(xún),然后再把數(shù)據(jù)庫(kù)取出來(lái)的數(shù)據(jù)放入緩存,一切看起來(lái)很美好。

如果現(xiàn)在有大量請(qǐng)求進(jìn)來(lái),而且都在請(qǐng)求一個(gè)不存在的產(chǎn)品Id,會(huì)發(fā)生什么?既然產(chǎn)品Id都不存在,那么肯定沒(méi)有緩存,沒(méi)有緩存,那么大量的請(qǐng)求都懟到數(shù)據(jù)庫(kù),數(shù)據(jù)庫(kù)的壓力一下子就上來(lái)了,還有可能把數(shù)據(jù)庫(kù)打死。這也是一種黑客攻擊方法。

雖然有很多辦法都可以解決這問(wèn)題,但是我們的主角是“布隆過(guò)濾器”,沒(méi)錯(cuò),“布隆過(guò)濾器”就可以解決(緩解)緩存穿透問(wèn)題。至于為什么說(shuō)是“緩解”,看下去你就明白了。

大量數(shù)據(jù),判斷給定的是否在其中

現(xiàn)在有大量的數(shù)據(jù),而這些數(shù)據(jù)的大小已經(jīng)遠(yuǎn)遠(yuǎn)超出了服務(wù)器的內(nèi)存,現(xiàn)在再給你一個(gè)數(shù)據(jù),如何判斷給你的數(shù)據(jù)在不在其中。如果服務(wù)器的內(nèi)存足夠大,那么用HashMap是一個(gè)不錯(cuò)的解決方案,理論上的時(shí)間復(fù)雜度可以達(dá)到O(1),但是現(xiàn)在數(shù)據(jù)的大小已經(jīng)遠(yuǎn)遠(yuǎn)超出了服務(wù)器的內(nèi)存,所以無(wú)法使用HashMap,這個(gè)時(shí)候就可以使用“布隆過(guò)濾器”來(lái)解決這個(gè)問(wèn)題。但是還是同樣的,會(huì)有一定的“誤判率”。

什么是布隆過(guò)濾器

布隆過(guò)濾器是一個(gè)叫“布隆”的人提出的,它本身是一個(gè)很長(zhǎng)的二進(jìn)制向量,既然是二進(jìn)制的向量,那么顯而易見(jiàn)的,存放的不是0,就是1。

現(xiàn)在我們新建一個(gè)長(zhǎng)度為16的布隆過(guò)濾器,默認(rèn)值都是0,就像下面這樣:


現(xiàn)在需要添加一個(gè)數(shù)據(jù):

我們通過(guò)某種計(jì)算方式,比如Hash1,計(jì)算出了Hash1(數(shù)據(jù))=5,我們就把下標(biāo)為5的格子改成1,就像下面這樣:

我們又通過(guò)某種計(jì)算方式,比如Hash2,計(jì)算出了Hash2(數(shù)據(jù))=9,我們就把下標(biāo)為9的格子改成1,就像下面這樣:


還是通過(guò)某種計(jì)算方式,比如Hash3,計(jì)算出了Hash3(數(shù)據(jù))=2,我們就把下標(biāo)為2的格子改成1,就像下面這樣:


這樣,剛才添加的數(shù)據(jù)就占據(jù)了布隆過(guò)濾器“5”,“9”,“2”三個(gè)格子。

可以看出,僅僅從布隆過(guò)濾器本身而言,根本沒(méi)有存放完整的數(shù)據(jù),只是運(yùn)用一系列隨機(jī)映射函數(shù)計(jì)算出位置,然后填充二進(jìn)制向量。

這有什么用呢?比如現(xiàn)在再給你一個(gè)數(shù)據(jù),你要判斷這個(gè)數(shù)據(jù)是否重復(fù),你怎么做?

你只需利用上面的三種固定的計(jì)算方式,計(jì)算出這個(gè)數(shù)據(jù)占據(jù)哪些格子,然后看看這些格子里面放置的是否都是1,如果有一個(gè)格子不為1,那么就代表這個(gè)數(shù)字不在其中。這很好理解吧,比如現(xiàn)在又給你了剛才你添加進(jìn)去的數(shù)據(jù),你通過(guò)三種固定的計(jì)算方式,算出的結(jié)果肯定和上面的是一模一樣的,也是占據(jù)了布隆過(guò)濾器“5”,“9”,“2”三個(gè)格子。

但是有一個(gè)問(wèn)題需要注意,如果這些格子里面放置的都是1,不一定代表給定的數(shù)據(jù)一定重復(fù),也許其他數(shù)據(jù)經(jīng)過(guò)三種固定的計(jì)算方式算出來(lái)的結(jié)果也是相同的。這也很好理解吧,比如我們需要判斷對(duì)象是否相等,是不可以?xún)H僅判斷他們的哈希值是否相等的。

也就是說(shuō)布隆過(guò)濾器只能判斷數(shù)據(jù)是否一定不存在,而無(wú)法判斷數(shù)據(jù)是否一定存在。

按理來(lái)說(shuō),介紹完了新增、查詢(xún)的流程,就要介紹刪除的流程了,但是很遺憾的是布隆過(guò)濾器是很難做到刪除數(shù)據(jù)的,為什么?你想想,比如你要?jiǎng)h除剛才給你的數(shù)據(jù),你把“5”,“9”,“2”三個(gè)格子都改成了0,但是可能其他的數(shù)據(jù)也映射到了“5”,“9”,“2”三個(gè)格子啊,這不就亂套了嗎?

相信經(jīng)過(guò)我這么一介紹,大家對(duì)布隆過(guò)濾器應(yīng)該有一個(gè)淺顯的認(rèn)識(shí)了,至少你應(yīng)該清楚布隆過(guò)濾器的優(yōu)缺點(diǎn)了:

  • 優(yōu)點(diǎn):由于存放的不是完整的數(shù)據(jù),所以占用的內(nèi)存很少,而且新增,查詢(xún)速度夠快;
  • 缺點(diǎn): 隨著數(shù)據(jù)的增加,誤判率隨之增加;無(wú)法做到刪除數(shù)據(jù);只能判斷數(shù)據(jù)是否一定不存在,而無(wú)法判斷數(shù)據(jù)是否一定存在。

可以看到,布隆過(guò)濾器的優(yōu)點(diǎn)和缺點(diǎn)一樣明顯。

在上文中,我舉的例子二進(jìn)制向量長(zhǎng)度為16,由三個(gè)隨機(jī)映射函數(shù)計(jì)算位置,在實(shí)際開(kāi)發(fā)中,如果你要添加大量的數(shù)據(jù),僅僅16位是遠(yuǎn)遠(yuǎn)不夠的,為了讓誤判率降低,我們還可以用更多的隨機(jī)映射函數(shù)、更長(zhǎng)的二進(jìn)制向量去計(jì)算位置。

guava實(shí)現(xiàn)布隆過(guò)濾器

現(xiàn)在相信你對(duì)布隆過(guò)濾器應(yīng)該有一個(gè)比較感性的認(rèn)識(shí)了,布隆過(guò)濾器核心思想其實(shí)并不難,難的在于如何設(shè)計(jì)隨機(jī)映射函數(shù),到底映射幾次,二進(jìn)制向量的長(zhǎng)度設(shè)置為多少比較好,這可能就不是一般的開(kāi)發(fā)可以駕馭的了,好在Google大佬給我們提供了開(kāi)箱即用的組件,來(lái)幫助我們實(shí)現(xiàn)布隆過(guò)濾器,現(xiàn)在就讓我們看看怎么Google大佬送給我們的“禮物”吧。

首先在pom引入“禮物”:

        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>19.0</version>
        </dependency>

然后就可以測(cè)試?yán)玻?/p>

    private static int size = 1000000;//預(yù)計(jì)要插入多少數(shù)據(jù)

    private static double fpp = 0.01;//期望的誤判率

    private static BloomFilter<Integer> bloomFilter = BloomFilter.create(Funnels.integerFunnel(), size, fpp);

    public static void main(String[] args) {
        //插入數(shù)據(jù)
        for (int i = 0; i < 1000000; i++) {
            bloomFilter.put(i);
        }
        int count = 0;
        for (int i = 1000000; i < 2000000; i++) {
            if (bloomFilter.mightContain(i)) {
                count++;
                System.out.println(i + "誤判了");
            }
        }
        System.out.println("總共的誤判數(shù):" + count);
    }

代碼簡(jiǎn)單分析:
我們定義了一個(gè)布隆過(guò)濾器,有兩個(gè)重要的參數(shù),分別是 我們預(yù)計(jì)要插入多少數(shù)據(jù),我們所期望的誤判率,誤判率不能為0。
我向布隆過(guò)濾器插入了0-1000000,然后用1000000-2000000來(lái)測(cè)試誤判率。

運(yùn)行結(jié)果:

1999501誤判了
1999567誤判了
1999640誤判了
1999697誤判了
1999827誤判了
1999942誤判了
總共的誤判數(shù):10314

現(xiàn)在總共有100萬(wàn)數(shù)據(jù)是不存在的,誤判了10314次,我們計(jì)算下誤判率


和我們定義的期望誤判率0.01相差無(wú)幾。

redis實(shí)現(xiàn)布隆過(guò)濾器

上面使用guava實(shí)現(xiàn)布隆過(guò)濾器是把數(shù)據(jù)放在本地內(nèi)存中,無(wú)法實(shí)現(xiàn)布隆過(guò)濾器的共享,我們還可以把數(shù)據(jù)放在redis中,用 redis來(lái)實(shí)現(xiàn)布隆過(guò)濾器,我們要使用的數(shù)據(jù)結(jié)構(gòu)是bitmap,你可能會(huì)有疑問(wèn),redis支持五種數(shù)據(jù)結(jié)構(gòu):String,List,Hash,Set,ZSet,沒(méi)有bitmap呀。沒(méi)錯(cuò),實(shí)際上bitmap的本質(zhì)還是String。

可能有小伙伴會(huì)說(shuō),納尼,布隆過(guò)濾器還沒(méi)介紹完,怎么又出來(lái)一個(gè)bitmap,沒(méi)事,你可以把bitmap就理解為一個(gè)二進(jìn)制向量。

要用redis來(lái)實(shí)現(xiàn)布隆過(guò)濾器,我們需要自己設(shè)計(jì)映射函數(shù),自己度量二進(jìn)制向量的長(zhǎng)度,這對(duì)我來(lái)說(shuō),無(wú)疑是一個(gè)不可能完成的任務(wù),只能借助搜索引擎,下面直接放出代碼把。

public class RedisMain {
    static final int expectedInsertions = 1000;//要插入多少數(shù)據(jù)
    static final double fpp = 0.01;//期望的誤判率

    //bit數(shù)組長(zhǎng)度
    private static long numBits;

    //hash函數(shù)數(shù)量
    private static int numHashFunctions;

    static {
        numBits = optimalNumOfBits(expectedInsertions, fpp);
        numHashFunctions = optimalNumOfHashFunctions(expectedInsertions, numBits);
    }

    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost", 6379);
        for (int i = 0; i < 1000; i++) {
            long[] indexArray = getIndexArray(String.valueOf(i));
            for (long index : indexArray) {
                jedis.setbit("codebear:bloom", index, true);
            }
        }
        int num = 0;
        for (int i = 1000; i < 2000; i++) {
            long[] indexArray = getIndexArray(String.valueOf(i));
            for (long index : indexArray) {
                if (!jedis.getbit("codebear:bloom", index)) {
                    System.out.println(i + "一定不存在");
                    num++;
                    break;
                }
            }
        }
        System.out.println("一定不存在的有" + num + "個(gè)");
    }

    /**
     * 根據(jù)key獲取bitmap下標(biāo)
     */
    private static long[] getIndexArray(String key) {
        long hash1 = hash(key);
        long hash2 = hash1 >>> 16;
        long[] result = new long[numHashFunctions];
        for (int i = 0; i < numHashFunctions; i++) {
            long combinedHash = hash1 + i * hash2;
            if (combinedHash < 0) {
                combinedHash = ~combinedHash;
            }
            result[i] = combinedHash % numBits;
        }
        return result;
    }

    private static long hash(String key) {
        return Hashing.MURMUR_HASH.hash(key);
    }

    //計(jì)算hash函數(shù)個(gè)數(shù)
    private static int optimalNumOfHashFunctions(long n, long m) {
        return Math.max(1, (int) Math.round((double) m / n * Math.log(2)));
    }

    //計(jì)算bit數(shù)組長(zhǎng)度
    private static long optimalNumOfBits(long n, double p) {
        if (p == 0) {
            p = Double.MIN_VALUE;
        }
        return (long) (-n * Math.log(p) / (Math.log(2) * Math.log(2)));
    }
}

運(yùn)行結(jié)果:

1997一定不存在
1998一定不存在
1999一定不存在
一定不存在的有989個(gè)

最后給出結(jié)論:

布隆過(guò)濾器判定某個(gè)值不存在,則必定不存在;
判定某個(gè)值存在,則大概率存在

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

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