導航:首頁 > 凈水問答 > java布隆過濾器使用

java布隆過濾器使用

發布時間:2025-07-13 12:14:23

Ⅰ 布隆過濾

[TOC]

通過解決方案:

Java中如將數據存儲在內存中,最簡單的演算法結構是HashMap。通過HashMap判斷key是否存在,來判斷數據是否存在。通過hash演算法查找元素,時間復雜度基本是 O(1) (可能存在hash沖突後轉換成鏈表或紅黑樹的情況,時間復雜度的影響可以忽略)。

使用HashMap速度很快,存儲簡單,絕大部分場景可以使用。但是HashMap 佔用的空間比較大 :

為什麼出現布隆過濾器:

舉例:

如1000萬個Integer存儲在內存中,佔用空間為:4x32x10000000位,即1220兆。如布隆過濾器通過4位元組存儲(布隆過濾器通過多次hash對數據計算後-->幾次hash根據數據量指定,得到多個數據, 佔用多個位 ),則佔用空間為610M。比原有空間少一半。

個人覺得,此比較在字元等的比較中尤為有效。
一個字元串多個字元,根據編碼方式,一個字元兩個或三個位元組,如10個字元,字元串存儲佔用20個位元組,還有相關字元串相關的類信息的內存佔用。
位存儲,根據數據量的大小,hash的位數,靈活計算。如4個位元組,則是原hashMap佔用空間的五分之一。

(1)定義位元組向量

先定義一個指定長度的位元組數組(位元組數組,數組內每個元素的值)。

如長度為8(一個位元組大小),默認所有元素值均為0,如下:

(2)計算哈希值

將要寫入過濾器的數據,根據一定數量的哈希函數,得到多個哈希值,再依次判斷每個哈希值對應的索引。

如使用3個哈希函數,計算得到3個哈希值,判定哈希值對應的位元組向量為為1,3,7。

(3)更新位元組向量

將計算出的位元組向量的索引, 對應的位元組向量中的元素值更高為1 (無論之前為0或者為1,均更改為1)。如下:

(1)計算哈希值

將要判斷過濾器中是否存在的數據,根據一定數量的哈希函數,得到多個哈希值,再依次判斷每個哈希值對應的索引。

如使用3個哈希函數,計算得到3個哈希值,判定哈希值對應的位元組向量為為1,3,7。

注意:哈希函數的判斷方式和計算索引的方式,需和寫入數據時完全一致。

(2)判斷是否存在

如原位元組數組中,對應1,3,7中存在的元素的值都為1。則判定為此元素 可能存在 ,但凡有一個元素的值不為1,則判定此元素 一定不存在 。

布隆過濾器,主要需實現的目標是, 在指定的數據個數范圍內,滿足誤判率在設定的范圍內 ,誤判率太高的話,無法起到過濾數據的情況,誤判率不能為0。

因此需要計算兩個數據來滿足 存儲數據的個數 和 誤判率 :

使用布隆過濾器的決定性因素之一,就是此演算法插入數據和查詢數據的速度必須非常快。因此在對數據進行哈希運算的時候, 需選擇計算快的哈希演算法 。

而且, 寫入數據以及查詢數據的哈希演算法,順序和演算法都需完全一致 。

待完善。。。。。

可以通過google的 guava ,在內存中輕松實現布隆過濾器。

無需手動計算滿足位元組數組的長度和哈希個數,只需要輸入 擬輸入數據的個數 和 期望誤判率 即可。

不輸入期望誤判率的情況下,誤判率為0.03,即100個非范圍內的數據進行校驗時,約三個數據會判定為存在。

多次執行,結果一致,根據結果判定:

內存的存儲存在局限性,可以使用redis中的bitMap來實現位元組數組的存儲。

使用redis實現布隆過濾器。需要根據公式,手動計算位元組數組的長度和哈希的個數。

實現過程,待完善。。。。。。

Ⅱ 如何使用bloomfilter構建大型Java緩存系統

在如今的軟體當中,緩存是解決很多問題的一個關鍵概念。你的應用可能會進行CPU密集型運回算。你當然答不想讓這些運算一邊又一邊的重復執行,相反,你可以只執行一次, 把這個結果放在內存中作為緩存。有時系統的瓶頸在I/O操作上,比如你不想重復的查...

Ⅲ 【面試深度解析】滴滴Java後端一面:JDK源碼、RocketMQ分布式事務、布隆過濾器

面試深度解析答案

JDK源碼部分ArrayList與LinkedList的區別:ArrayList基於數組實現,訪問速度快,但在插入和刪除元素時可能需要移動大量元素,效率較低;LinkedList基於雙向鏈表實現,插入和刪除操作效率較高,但訪問速度較慢。 ArrayList擴容機制:ArrayList的擴容是動態的,當添加元素時,如果當前數組已滿,會進行擴容操作,擴容後的數組大小通常是原來的1.5倍。 HashMap的線程安全問題:在JDK1.8中,HashMap在多線程環境下進行put操作時可能存在線程安全問題,因為多個線程可能同時插入元素並覆蓋彼此的數據。JDK1.8使用尾插法解決哈希沖突,並通過CAS操作和synchronized鎖保證線程安全。

RocketMQ分布式事務部分實現原理:RocketMQ通過半消息和消息回查機制實現分布式事務的原子性。服務A完成操作並發送半消息至MQ,服務B監聽並完成自己的資料庫操作後,MQ確認消息完成,確保事務的一致性。 MQ的作用:在項目中,MQ主要用於削峰填谷、非同步優化和高擴展性。通過MQ,可以減少消費者線程數或限制消費能力,實現系統負載的穩定;同時,MQ可以將耗時任務從主流程中剝離,不幹擾主流程的執行;此外,MQ還允許在創建訂單後將取消訂單的邏輯非同步處理,簡化了取消訂單操作與其他業務的耦合。

布隆過濾器部分基本概念:布隆過濾器是一種空間效率極高的概率型數據結構,用於快速判斷元素是否存在於集合中。 工作原理:布隆過濾器通過一組哈希函數將元素映射到一個位數組中,當需要判斷元素是否存在時,只需檢查對應的位是否全為1即可。但布隆過濾器不支持刪除元素,因為刪除一個元素可能會誤刪其他元素。 布穀鳥過濾器的改進:布穀鳥過濾器在布隆過濾器的基礎上增加了刪除元素的功能,適用於需要頻繁進行元素添加和刪除的場景。

Ⅳ 布隆過濾器

布隆過濾器 (英語:Bloom Filter)是 1970 年由布隆提出的。它實際上是一個很長的二進制向量和一系列隨機映射函數。主要用於判斷一個元素是否在一個集合中。

通常我們會遇到很多要判斷一個元素是否在某個集合中的業務場景,一般想到的是將集合中所有元素保存起來,然後通過比較確定。鏈表、樹、散列表(又叫哈希表,Hash table)等等數據結構都是這種思路。但是隨著集合中元素的增加,我們需要的存儲空間也會呈現線性增長,最終達到瓶頸。同時檢索速度也越來越慢,上述三種結構的檢索時間復雜度分別為,,。

這個時候,布隆過濾器(Bloom Filter)就應運而生。

了解布隆過濾器原理之前,先回顧下 Hash 函數原理。

哈希函數的概念是:將任意大小的輸入數據轉換成特定大小的輸出數據的函數,轉換後的數據稱為哈希值或哈希編碼,也叫散列值。下面是一幅示意圖:

所有散列函數都有如下基本特性:

但是用 hash表存儲大數據量時,空間效率還是很低,當只有一個 hash 函數時,還很容易發生哈希碰撞。

BloomFilter 是由一個固定大小的二進制向量或者點陣圖(bitmap)和一系列映射函數組成的。

在初始狀態時,對於長度為 m 的位數組,它的所有位都被置為0,如下圖所示:

[圖片上傳失敗...(image-303c04-1595324887187)]

當有變數被加入集合時,通過 K 個映射函數將這個變數映射成點陣圖中的 K 個點,把它們置為 1(假定有兩個變數都通過 3 個映射函數)。

查詢某個變數的時候我們只要看看這些點是不是都是 1 就可以大概率知道集合中有沒有它了

為什麼說是可能存在,而不是一定存在呢?那是因為映射函數本身就是散列函數,散列函數是會有碰撞的。

布隆過濾器的誤判是指多個輸入經過哈希之後在相同的bit位置1了,這樣就無法判斷究竟是哪個輸入產生的,因此誤判的根源在於相同的 bit 位被多次映射且置 1。

這種情況也造成了布隆過濾器的刪除問題,因為布隆過濾器的每一個 bit 並不是獨占的,很有可能多個元素共享了某一位。如果我們直接刪除這一位的話,會影響其他的元素。(比如上圖中的第 3 位)

相比於其它的數據結構,布隆過濾器在空間和時間方面都有巨大的優勢。布隆過濾器存儲空間和插入/查詢時間都是常數 ,另外,散列函數相互之間沒有關系,方便由硬體並行實現。布隆過濾器不需要存儲元素本身,在某些對保密要求非常嚴格的場合有優勢。

布隆過濾器可以表示全集,其它任何數據結構都不能;

但是布隆過濾器的缺點和優點一樣明顯。誤算率是其中之一。隨著存入的元素數量增加,誤算率隨之增加。但是如果元素數量太少,則使用散列表足矣。

另外,一般情況下不能從布隆過濾器中刪除元素。我們很容易想到把位數組變成整數數組,每插入一個元素相應的計數器加 1, 這樣刪除元素時將計數器減掉就可以了。然而要保證安全地刪除元素並非如此簡單。首先我們必須保證刪除的元素的確在布隆過濾器裡面。這一點單憑這個過濾器是無法保證的。另外計數器回繞也會造成問題。

在降低誤算率方面,有不少工作,使得出現了很多布隆過濾器的變種。

在程序的世界中,布隆過濾器是程序員的一把利器,利用它可以快速地解決項目中一些比較棘手的問題。

如網頁 URL 去重、垃圾郵件識別、大集合中重復元素的判斷和緩存穿透等問題。

布隆過濾器的典型應用有:

知道了布隆過濾器的原理和使用場景,我們可以自己實現一個簡單的布隆過濾器

分布式環境中,布隆過濾器肯定還需要考慮是可以共享的資源,這時候我們會想到 Redis,是的,Redis 也實現了布隆過濾器。

當然我們也可以把布隆過濾器通過 bloomFilter.writeTo() 寫入一個文件,放入OSS、S3這類對象存儲中。

Redis 提供的 bitMap 可以實現布隆過濾器,但是需要自己設計映射函數和一些細節,這和我們自定義沒啥區別。

Redis 官方提供的布隆過濾器到了 Redis 4.0 提供了插件功能之後才正式登場。布隆過濾器作為一個插件載入到 Redis Server 中,給 Redis 提供了強大的布隆去重功能。

在已安裝 Redis 的前提下,安裝 RedisBloom,有兩種方式

直接編譯進行安裝

使用Docker進行安裝

使用

布隆過濾器基本指令:

我們只有這幾個參數,肯定不會有誤判,當元素逐漸增多時,就會有一定的誤判了,這里就不做這個實驗了。

上面使用的布隆過濾器只是默認參數的布隆過濾器,它在我們第一次 add 的時候自動創建。

Redis 還提供了自定義參數的布隆過濾器,bf.reserve 過濾器名 error_rate initial_size

但是這個操作需要在 add 之前顯式創建。如果對應的 key 已經存在,bf.reserve 會報錯

我是一名 Javaer,肯定還要用 Java 來實現的,Java 的 Redis 客戶端比較多,有些還沒有提供指令擴展機制,筆者已知的 Redisson 和 lettuce 是可以使用布隆過濾器的,我們這里用 Redisson

為了解決布隆過濾器不能刪除元素的問題,布穀鳥過濾器橫空出世。論文《Cuckoo Filter:Better Than Bloom》作者將布穀鳥過濾器和布隆過濾器進行了深入的對比。相比布穀鳥過濾器而言布隆過濾器有以下不足:查詢性能弱、空間利用效率低、不支持反向操作(刪除)以及不支持計數。

閱讀全文

與java布隆過濾器使用相關的資料

熱點內容
電視回看用什麼軟體 瀏覽:539
空氣濾芯安裝反了有什麼後果 瀏覽:46
生產熱固性酚醛樹脂其理論計量比為多少 瀏覽:307
凈化器箱清洗價格多少 瀏覽:663
煙學網香煙過濾器有用嗎 瀏覽:924
杭州污水處理有限公司 瀏覽:167
什麼是凈水機廢水 瀏覽:930
污水處理廠生活污水處理流程 瀏覽:585
採用蒸餾方法分離焦油可採用 瀏覽:396
榮事達凈水器假的有什麼特點 瀏覽:849
10代雅閣怎麼拆空調濾芯 瀏覽:363
南方空調濾芯怎麼選 瀏覽:502
水離子去是什麼東西 瀏覽:555
怎樣給即熱式水水器除水垢 瀏覽:184
怎麼打開進水器濾芯 瀏覽:599
密胺樹脂易碎 瀏覽:374
夢幻lg的回靈有什麼用 瀏覽:337
廁所水箱水為什麼能從凈水器出來 瀏覽:695
蒸餾裝置中安全管 瀏覽:139
凈水機選什麼樣子的 瀏覽:957