使用concurrentHashMap如何实现缓存
更新时间：2025年02月19日 11:27:39 作者：蜗牛^^O^
文章介绍了使用ConcurrentHashMap实现缓存的线程安全性和初始化方法,以及如何处理高并发场景下的缓存清理和数据一致性问题,包括分桶、使用ConcurrentLinkedQueue以及使用CountDownLatch来确保缓存数据的不丢失
使用concurrentHashMap实现缓存
1、concurrentHashMap本身是线程安全的
2、使用@PostConstruct注解init函数，在生成bean的时候会调用init函数。init函数进行concurrenthashMap的初始化，分配初始空间大小。并且开启线程每隔一段时间处理清空缓存，flushAlll。
3、如果一个key需要存多条消息，并发很高，可以考虑分桶，使用多个concurrentHashMap，根据key来决定放到那个Map保存，Map里面使用另外的key进行散列。
4、add向缓存添加元素，map元素个数大于阈值，则进行缓存处理清理
难点一
- 缓存需要读多写多，高并发。
- 使用concurrentHashMap比较合适，根据id来散列，id相同的消息多个，所以concurrentHashMap的val应该是一个线程安全，并且并发效率好的集合。
- 使用ConcurrentLinkedQueue。
难点二
上线发布，需要重启机器，缓存实例被销毁，怎么做到缓存的不丢失？
场景：
- 消费mq，放到缓存。
- 使用@BeforeDestory，void destory函数中，将flag置成flase，缓存添加函数add，先判断flag如果为flase,直接抛出异常，mq不确认ack。
- flag应该是volatile的。
难点三
- destory函数将flag置成flase，add函数根据flag判断，add是高并发的。可能add判断为true之后，正要放入缓存，destory才将flag置成flase，也会丢失少量消息。
- 如果使用CountDownLatch,等add把消息全部放入缓存之后，再执行uploadAll，把缓存全部刷，进行清理。关键是把countDownLatch的初始值设为多少呢？
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
SpringBoot 配置文件中配置的中文,程序读取出来是乱码的解决
这篇文章主要介绍了SpringBoot 配置文件中配置的中文,程序读取出来是乱码的解决，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-09-09
异常就是不正常，比如当我们身体出现了异常我们会根据身体情况选择喝开水、吃药、看病、等 异常处理方法。 java异常处理机制是我们java语言使用异常处理机制为程序提供了错误处理的能力，程序出现的错误，程序可以安全的退出，以保证程序正常的运行等2022-03-03
所谓代码块是指用"{}"括起来的一段代码，根据其位置和声明的不同，可以分为普通代码块、构造块、静态块、和同步代码块。如果在代码块前加上synchronized关键字，则此代码块就成为同步代码块2022-07-07
本文介绍了如何通过SpringBoot工程引入SpringDataJPA,并通过实体类自动生成数据库表的过程,包括常见问题解决方法,感兴趣的可以了解一下2024-09-09
我们在实际开发中，肯定会用到树结构，如部门树、菜单树等等。Java后台利用递归思路进行构建树形结构数据，返回给前端，能以下拉菜单等形式进行展示。今天，咱们就来说说怎么样将List集合转换成TreeList2022-11-11
这篇文章主要介绍了Spring AOP定义Before增加,结合实例形式详细分析了Spring面向切面AOP定义Before增加相关定义与使用技巧,需要的朋友可以参考下2020-01-01
这篇文章主要给大家介绍了关于SpringBoot打印系统执行的sql语句及日志配置的相关资料,在Java SpringBoot项目中如果使用了Mybatis框架,默认情况下执行的所有SQL操作都不会打印日志,需要的朋友可以参考下2023-10-10
SpringCloud Eureka Provider及Consumer的实现
这篇文章主要介绍了SpringCloud Eureka 提供者及调用者的实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-10-10
解决springboot自定义配置Boolean属性不能生效的问题
这篇文章主要介绍了解决springboot自定义配置Boolean属性不能生效的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-05-05
这篇文章主要介绍了JAVA面试题 启动线程是start()还是run()？为什么？,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-07-07
最新评论