日常开发中,大家经常使用缓存,但是你知道大型的互联网公司面对高并发流量,要注意缓存穿透问题吗!!!    本文会介绍布隆过滤器,空间换时间,以较低的内存空间、高效解决这个问题。

本篇文章的目录:

1、性能不够,缓存来凑

现在的年轻人都喜欢网购,没事就逛逛淘宝,剁剁手,买些自己喜欢的东西,释放下工作压力。

地址:

https://detail.tmall.com/item.htm?id=628993216729

上图是一个天猫 iphone12 的商品详情页,id表示商品的编号

我们都知道淘宝的访问量是非常高的,为了提升系统的吞吐量,做了很多性能优化,其中非常重要一点是将信息异构到缓存中。

有句话说的好:性能不够,缓存来凑。

但是,使用缓存时,我们要关注一个重要问题,如果缓存没有命中怎么办?

2、缓存没有命中,怎么办?

  • ①我们先查询缓存,判断缓存中是否有数据

  • ②如果有数据,直接返回

  • ③如果缓存为空,我们需要再查一次数据库,并将数据格式异构化,然后预热到缓冲中,然后将结果返回

注意:

步骤 ③ 存在风险漏洞,如果缓存中数据不存在,压力会转嫁给数据库。假如被竞争对手利用,搞无效请求流量攻击,瞬间大量请求打到数据库中,对系统性能产生很大影响,很容易把数据库打挂,这种现象称为缓存穿透。

3、那么如何处理缓存穿透?

我们的思路是,缓存中能不能判断这个数据库值的存在性,如果真的不存在,直接返回,也避免一次数据库查询。

由于不存在是个无限边界,所以,我们采用反向策略,将存在的值建立一个高效的检索。每次缓存取值时,先走一次判空检索。

简单归纳下,这个框架的要求:

  • 快速检索

  • 内存空间要非常小

经调研,我们发现布隆过滤器具备以上两个条件。

4、什么是布隆过滤器?

布隆过滤器(Bloom Filter)是1970年由布隆提出的。它实际上是一个很长的二进制向量和一系列随机映射函数。布隆过滤器可以用于检索一个元素是否在一个集合中。

  • 优点:空间效率和查询时间都远远超过一般的算法。

  • 缺点:有一定的误识别率,删除困难。

5、布隆过滤器如何构建?

布隆过滤器本质上是一个 n 位的二进制数组,用0和1表示。

假如我们以商品为例,有三件商品,商品编码分别为,id1id2id3

a)首先,对id1,进行三次哈希,并确定其在二进制数组中的位置。

三次哈希,对应的二进制数组下标分别是 2、5、8,将原始数据从 0 变为 1。

b)对id2,进行三次哈希,并确定其在二进制数组中的位置。

三次哈希,对应的二进制数组下标分别是 2、7、98,将原始数据从 0 变为 1。

下标 2,之前已经被操作设置成 1,则本次认为是哈希冲突,不需要改动。

Hash 规则:如果在 Hash 后,原始位它是 0 的话,将其从 0 变为 1;如果本身这一位就是 1 的话,则保持不变。

6、布隆过滤器如何使用?

跟初始化的过程有点类似,当查询一件商品的缓存信息时,我们首先要判断这件商品是否存在。

  • 通过三个哈希函数对商品id计算哈希值

  • 然后,在布隆数组中查找访问对应的位值,0或1

  • 判断,三个值中,只要有一个不是1,那么我们认为数据是不存在的。

注意:布隆过滤器只能精确判断数据不存在情况,对于存在我们只能说是可能,因为存在Hash冲突情况,当然这个概率非常低。

7、如何减少布隆过滤器的误判?

a)增加二进制位数组的长度。这样经过hash后数据会更加的离散化,出现冲突的概率会大大降低

b)增加Hash的次数,变相的增加数据特征,特征越多,冲突的概率越小

8、布隆过滤器会不会很费内存?

带着疑问,我们来做个实验

假设有1千万个数据,我们需要记录其是否存在。存在的话标记1,不存在标记为0。技术选型,框架采用Redis的BitMap存储。

数据初始化预热代码:

redisTemplate.executePipelined(new RedisCallback<Long>() {@Nullable@Overridepublic Long doInRedis(RedisConnection connection) throws DataAccessException {connection.openPipeline();for (int offset = 10000000; offset >= 0; offset--) {boolean value = offset % 2 == 0 ? true : false;connection.setBit("bloom-filter-data-1".getBytes(), offset, value);}connection.closePipeline();return null;}
});
System.out.println("数据预热完成");

性能有点慢,我们也可以采用分组形式,10000个数一组,多批次提交。

数据上传完了后,大小 1.19M,跟我们设想的一样。

计算公式: 10000000/8/1024/1024=1.19M

9、Java应用中,如何使用布隆过滤器?代码实例

Java语言的生态非常繁荣,提供了很多开箱即用的开源框架供我们使用。布隆过滤器也不例外,Java 中提供了一个 Redisson 的组件,它内置了布隆过滤器。

首先引入依赖包

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

代码示例:

/*** @author 微信公众号:微观技术*/
@Test
public void test5() {Config config = new Config();config.useSingleServer().setAddress("redis://172.16.67.37:6379");RedissonClient cient = Redisson.create(config);RBloomFilter<String> bloomFilter = cient.getBloomFilter("test5-bloom-filter");// 初始化布隆过滤器,数组长度100W,误判率 1%bloomFilter.tryInit(1000000L, 0.01);// 添加数据bloomFilter.add("Tom哥");// 判断是否存在System.out.println(bloomFilter.contains("微观技术"));System.out.println(bloomFilter.contains("Tom哥"));
}

运行结果:

false   // 肯定不存在
true    // 可能存在,有1%的误判率

注意:误判率设置过小,会产生更多次的 Hash 操作,降低系统的性能。通常我们的建议值是 1%

10、布隆过滤器二进制数组,如何处理删除?

初始化后的布隆过滤器,可以直接拿来使用了。但是如果原始数据删除了怎么办?布隆过滤器二进制数组如何维护?

直接删除不行吗?

还真不行!因为这里面有Hash冲突的可能,会导致误删。

怎么办?

方案1:开发定时任务,每隔几个小时,自动创建一个新的布隆过滤器数组,替换老的,有点CopyOnWriteArrayList的味道

方案2:布隆过滤器增加一个等长的数组,存储计数器,主要解决冲突问题,每次删除时对应的计数器减一,如果结果为0,更新主数组的二进制值为0

11、布隆过滤器的应用场景

  • 本文重点介绍的,解决缓存穿透

  • 网页爬虫对URL的去重,避免爬取相同的URL地址

  • 反垃圾邮件,从数十亿个垃圾邮件列表中判断某邮箱是否垃圾邮箱

什么是布隆过滤器?如何解决高并发缓存穿透问题?相关推荐

  1. 布隆过滤器速度_高并发系统一定要考虑的 Bloom Filter 布隆过滤器

    开篇思考 你能想到哪些方式判断一个元素是否存在集合中? 布隆过滤器并不存储数据本身,那么是怎么做到过滤的? 布隆过滤器实现?参数配置? 一般我们用来判断一个元素是否存在,会想到用 List,Map,S ...

  2. Bloom Filter布隆过滤器(解决redis缓存穿透)

    目录 1.什么是布隆过滤器: 2.用BitSet手写简单的布隆过滤器 3.redis中的缓存穿透 4.Redis中的布隆过滤器 4.1 RedisBloom 4.1.1直接编译进行安装 4.1.2使用 ...

  3. 从bitmap到布隆过滤器,再到高并发缓存设计策略

    点击关注公众号,Java干货及时送达 作者:that_is_cool blog.csdn.net/that_is_cool/article/details/91346356 前言:怎么能把风马牛不相及 ...

  4. 乐观锁 -业务判断 解决高并发问题

    在解决高并发问题时,如果是分布式系统显然我们只能够使用数据库端加锁机制来解决这个问题,但是这种同步机制或者数据库物理锁机制会牺牲一部分的性能,所以常常以另外一种方式来解决这个问题 就是乐观锁模式 银行 ...

  5. PHP使用文件锁解决高并发问题示例

    PHP使用文件锁解决高并发问题示例 参考文章: (1)PHP使用文件锁解决高并发问题示例 (2)https://www.cnblogs.com/lxwphp/p/8949518.html (3)htt ...

  6. php解决高并发问题

    php解决高并发问题 参考文章: (1)php解决高并发问题 (2)https://www.cnblogs.com/jcydd/p/10632526.html (3)https://www.javaz ...

  7. Nginx与Redis解决高并发问题

    Nginx与Redis解决高并发问题 参考文章: (1)Nginx与Redis解决高并发问题 (2)https://www.cnblogs.com/nucdy/p/5516511.html 备忘一下.

  8. python如何解决高并发_Flask 处理高并发、多线程

    前言: 使用flask做服务时,可以使用python run.py的方式运行,但是这样不能用于生产环境,可能会出现连接无响应的情况.后来通过查找资料,发现flask服务处理多线程.高并发的一下方法,主 ...

  9. asp.net怎样解决高并发问题

    队列+多线程+couchbase缓存 ,解决高并发问题. using System; using System.Collections.Generic; using System.Linq; usin ...

最新文章

  1. HashSet 详解
  2. python表单防重复提交_防止表单重复提交的几种策略
  3. 概率论与数理统计专业术语
  4. stats | nls——求解非线性回归的待定参数
  5. 山东计算机专业的在职硕士,山东轻工业学院在职研究生计算机专业如何复习
  6. 亚马逊发布新版MXNet:支持英伟达Volta和稀疏张量
  7. 易语言批量替换html,易语言实现批量文本替换操作的代码
  8. Redis入门完整教程:CacheCloud是什么?
  9. 2寸的照片长宽各是多少_1寸和2寸的照片的长和宽各是几厘米?
  10. 【程序】 一位前辈的编程经历(转)
  11. 阿里生鲜布局重要抓手!它如何解决全球生鲜商家痛点?
  12. code:block17.12汉化
  13. 人工智能写作产品解决的痛点
  14. 天载优配解读全商场亏钱效应浓郁
  15. Linux下的Html编辑器
  16. docker容器不断重启
  17. 推迟14年寿命仅10年,造价百亿美元堪比航母,这面金色镜子能干啥
  18. 25_类和面向对象的概念
  19. 协和医院(东单院区)就诊流程记录
  20. MATLAB方程式求解

热门文章

  1. python凯撒密码详解_Python基础题目集--课堂案例
  2. Ubuntu下安装Stanford CoreNLP
  3. 在 Linux 上如何安装 SoundConverter及转换音频
  4. poj2602(高精度模拟加法)
  5. 有源汇上下界最小费用可行流 ---- P4043 [AHOI2014/JSOI2014]支线剧情(模板)
  6. SDOI2015 约数个数和(莫比乌斯反演经典、双上限整除分块)超详细笔记
  7. L - Oil Deposits HDU - 1241
  8. java errorlevel_bat中errorlevel与%errorlevel%的区别
  9. linux dhcp 论文,毕业论文—基于linux的dhcp服务器配置.doc
  10. docx文件上传java_java上传文件通过mybatis存储到数据库的blob格式中.docx