# 下載
wget https://codeload.github.com/RedisBloom/RedisBloom/tar.gz/refs/tags/v2.2.18
# 解壓
tar -zxvf v2.2.18

# 進入到解壓目錄
cd RedisBloom-2.2.18/
# 編譯
make

# vim查看redis.conf
vim /opt/redis-stable/redis.conf
# 在文件后面加上如下配置
loadmodule /opt/RedisBloom-2.2.18/redisbloom.so

# 關(guān)閉redis
ps -ef | grep redis | awk -F" " '{print $2;}' | xargs kill -9
# 啟動redis
/opt/redis-stable/src/redis-server redis.conf
# 連接客戶端
/opt/redis-stable/src/redis-cli -c -h 127.0.0.1 -p 6379 -a 123456

127.0.0.1:6379> bf.add spider:url www.baidu.net
(integer) 1
127.0.0.1:6379> bf.exists spider:url www.baidu.net
(integer) 1
127.0.0.1:6379> bf.madd spider:url www.taobao.com www.123qq.com
1) (integer) 1
2) (integer) 1
127.0.0.1:6379> bf.mexists spider:url www.jd.com www.taobao.com
1) (integer) 0
2) (integer) 1

<dependency>
	<groupId>redis.clients</groupId>
	<artifactId>jedis</artifactId>
	<version>3.9.0</version>
</dependency>
<dependency>
	<groupId>com.redislabs</groupId>
	<artifactId>jrebloom</artifactId>
	<version>2.2.2</version>
</dependency>

import io.rebloom.client.Client;
import redis.clients.jedis.Jedis;
public class JrebloomDemo {
    public static void main(String[] args) {
        //連接本地的 Redis 服務(wù)
        Jedis jedis = new Jedis("192.168.115.239", 6379);
        //jedis.auth("123456");
        //創(chuàng)建client也支持連接池的:public Client(Pool<Jedis> pool)
        Client client = new Client(jedis);
        // 測試數(shù)據(jù)
        int capacity = 10000;
        // 容錯率,只能設(shè)置0 < error rate range < 1  不然直接會異常！
        double errorRate = 0.01;
        // 測試的key值
        String key = "ceshi";
        // 創(chuàng)建過濾器:可以創(chuàng)建指定位數(shù)和容錯率的布隆過濾器,如果過濾器已經(jīng)存在創(chuàng)建的話就會異常
        if (!jedis.exists(key)) {
            client.createFilter(key, capacity, errorRate);
        }
        for (int i = 0; i < capacity; i++) {
            client.bfInsert(key, String.valueOf(i));
        }
        System.out.println("存入元素為=={" + capacity + "}");
        // 統(tǒng)計誤判次數(shù)
        int count = 0;
        // 我在數(shù)據(jù)范圍之外的數(shù)據(jù)，測試相同量的數(shù)據(jù)，判斷錯誤率是不是符合我們當(dāng)時設(shè)定的錯誤率
        for (int i = capacity; i < capacity * 2; i++) {
            if (client.exists(key, String.valueOf(i))) {
                count++;
            }
        }
        System.out.println("誤判元素為=={" + count + "}");
        // 刪除過濾器
        client.delete(key);
    }
}

<dependency>
	<groupId>org.redisson</groupId>
	<artifactId>redisson</artifactId>
	<version>3.22.1</version>
</dependency>

import org.redisson.Redisson;
import org.redisson.api.RBloomFilter;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
public class RedissonBloomFilter {
    public static void main(String[] args) {
        Config config = new Config();
        config.useSingleServer()
                .setAddress("redis://127.0.0.1:6379")
                //.setPassword("123456")
                .setDatabase(0);
        //獲取客戶端
        RedissonClient redissonClient = Redisson.create(config);
        // 測試數(shù)據(jù)
        int capacity = 10000;
        // 容錯率,只能設(shè)置0 < error rate range < 1  不然直接會異常！
        double errorRate = 0.01;
        // 測試的key值
        String key = "ceshi";
        RBloomFilter<String> bloomFilter = redissonClient.getBloomFilter(key);
        // 初始化布隆過濾器，預(yù)計統(tǒng)計元素數(shù)量為10000，期望誤差率為0.01
        bloomFilter.tryInit(capacity, errorRate);
        for (long i = 0; i < capacity; i++) {
            bloomFilter.add(String.valueOf(i));
        }
        System.out.println("存入元素為=={" + capacity + "}");
        // 統(tǒng)計誤判次數(shù)
        int count = 0;
        // 我在數(shù)據(jù)范圍之外的數(shù)據(jù)，測試相同量的數(shù)據(jù)，判斷錯誤率是不是符合我們當(dāng)時設(shè)定的錯誤率
        for (int i = capacity; i < capacity * 2; i++) {
            if (bloomFilter.contains(String.valueOf(i))) {
                count++;
            }
        }
        System.out.println("誤判元素為=={" + count + "}");
        // 刪除過濾器
        // bloomFilter.delete();
    }
}