布隆过滤器及其使用场景

1. 什么是布隆过滤器?

布隆过滤器(BloomFilter)是由一个叫“布隆”的小伙子在1970年提出的，它是一个很长的二进制向量，主要用于判断一个元素是否在一个集合中。

在介绍原理之前，要先讲一下Hash函数的概念。

我们在Java中的HashMap，HashSet其实也接触过hashcode()这个函数，

哈希函数是可以将任意大小的输入数据转换成特定大小的输出数据的函数，转换后的数据称为哈希值。

哈希函数有以下特点：
a. 如果根据同一个哈希函数得到的哈希值不同，那么这两个哈希值的原始输入值肯定不同。
b. 如果根据同一个哈希函数得到的两个哈希值相等，两个哈希值的原始输入值有可能相等，有可能不相等。

布隆过滤器是由一个很长的二进制向量和一系列的哈希函数组成。那么布隆过滤器是怎么判断一个元素是否在一个集合中的呢？
假设布隆过滤器的底层存储结构是一个长度为16的位数组，初始状态时，它的所有位置都设置为0。

当有变量添加到布隆过滤器中，通过K个映射函数将变量映射到位数组的K个点，并把这K个点的值设置为1(假设有三个映射函数)。

查询某个变量是否存在的时候，我们只需要通过同样的K个映射函数，找到对应的K个点，

判断K个点上的值是否全都是1，如果全都是1则表示很可能存在，

如果K个点上有任何一个是0则表示一定不存在。

布隆过滤器存在一定的误判 

不能删除布隆过滤器里的元素

因为在位数组上的同一个点有可能有多个输入值映射，如果删除了会影响布隆过滤器里其他元素的判断结果。

2. 布隆过滤器的优缺点

优点：
在空间和时间方面，都有着巨大的优势。

因为不是存完整的数据，是一个二进制向量，能节省大量的内存空间，

时间复杂度方面，是根据映射函数查询，假设有K个映射函数，那么时间复杂度就是O(K)。
因为存的不是元素本身，而是二进制向量，所以在一些对保密性要求严格的场景有一定优势。

缺点：
存在一定的误判。

存进布隆过滤器里的元素越多，误判率越高。
不能删除布隆过滤器里的元素。

随着使用的时间越来越长，因为不能删除，存进里面的元素越来越多，占用内存越来越多，误判率越来越高，最后不得不重置。

3. 应用场景

用于缓解缓存穿透。

缓存穿透的问题主要是因为传进来的key在Redis中是不存在的，那么就会直接打在DB上，造成DB压力增大。

针对这种情况，可以在Redis前加上布隆过滤器，预先把数据库中的数据加入到布隆过滤器中，

因为布隆过滤器的底层数据结构是一个二进制向量，所以占用的空间并不是很大。

在查询Redis之前先通过布隆过滤器判断是否存在，如果不存在就直接返回，

如果存在的话，按照原来的流程还是查询Redis，Redis不存在则查询DB。

这里主要利用的是布隆过滤器判断结果是不存在的话就一定不存在这一个特点，

但是由于布隆过滤器有一定的误判，所以并不能说完全解决缓存穿透，但是能很大程度缓解缓存穿透的问题。

4. 布隆过滤器插件

在Redis4.0后，官方提供了布隆过滤器的插件功能，布隆过滤器可以作为一个插件加载到Redis服务器直接使用。

安装完Redis之后，下载插件，使用git命令拉取：

git clone https://github.com/RedisBloom/RedisBloom.git

拉取下来之后会得到一个RedisBloom的项目。

然后cd到文件夹/RedisBloom，使用make命令编译。

编译完成后生成一个redisbloom.so文件。

在启动Redis时，加载布隆过滤器模块到服务器中:

./src/redis-server --loadmodule /usr/local/RedisBloom/redisbloom.so

最后使用客户端测试一下:

$ ./src/redis-cli 

127.0.0.1:6379> bf.add user kg
(integer) 1
127.0.0.1:6379> bf.add user ak
(integer) 1
127.0.0.1:6379> bf.exists user ak
(integer) 1
127.0.0.1:6379> bf.exists user tt
(integer) 0

布隆过滤器的基本指令如下：
bf.add 添加元素到布隆过滤器
bf.exists 判断元素是否在布隆过滤器
bf.madd 添加多个元素到布隆过滤器
bf.mexists 判断多个元素是否在布隆过滤器

Java程序怎么操作

引入依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.15.0</version>
</dependency>

测试程序

public static void main(String[] args) throws Exception {
    Config config = new Config();
    config.useSingleServer().setAddress("redis://127.0.0.1:6379");
    RedissonClient client = Redisson.create(config);

    RBloomFilter<String> bloomFilter = client.getBloomFilter("user");
    //尝试初始化，预计元素55000000，期望误判率0.03
    bloomFilter.tryInit(55000000L, 0.03);
    //添加元素到布隆过滤器中
    bloomFilter.add("kg");
    bloomFilter.add("ak");
    bloomFilter.add("tk");
    bloomFilter.add("nk");
    System.out.println("布隆过滤器元素总数为：" + bloomFilter.count());//布隆过滤器元素总数为：4
    System.out.println("是否包含kg：" + bloomFilter.contains("tom"));//是否包含kg：true
    System.out.println("是否包含app：" + bloomFilter.contains("lei"));//是否包含app：false
    client.shutdown();
}