缓存-缓存的使用与基本详解

news/2024/12/23 7:10:21/

1.缓存使用

为了系统性能的提升,我们一般都会将部分数据放入缓存中,加速访问。而db承担数据落盘工作。

哪些数据适合放入缓存

  • 即时性、数据一致性要求不高的
  • 访问量大且更新频率不高的数据(读多,写少)

举例:

电商类应用,商品分类,商品列表等适合缓存并加一个失效时间(根据数据更新频率来定),后台如果发布了一个商品,买家需要5分钟才能看到新的商品一般还是可以接受的

2.本地缓存 

最简单的加入缓存

 

 吞吐量大大提升

这样的方式称作本地缓存

弊端 在单体应用没有问题,分布式项目问题如下

  1. 缓存不在同一个服务里,导致第一个查数据库得到缓存放入本地,然后又来一个请求负载均衡到第二个服务,没有缓存,导致又去查一遍数据库
  2. 假设一个数据库的数据修改了需要修改缓存,那么它只会更新操作数据库的那个服务,其他服务的缓存就会导致数据大量不一致。

分布式系统下应该使用分布式缓存

3.Redis缓存

1.导入依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>

2.application.yml

spring:redis:host: 192.168.232.209port: 6379database: 0

3.优化三级分类 

   @Autowiredprivate RedisTemplate<String,Object> redisTemplate;
//    private Map<String,Object> cacheMap = new HashMap<>();private static final String CATALOG_JSON="CATALOG_JSON";@Overridepublic Map<String, List<Catelog2Vo>> getCatalogJson() {Object result = redisTemplate.opsForValue().get(CATALOG_JSON);if(result!=null){return (Map<String, List<Catelog2Vo>>) result;}Map<String, List<Catelog2Vo>> map = getCatalogJsonFromDB();redisTemplate.opsForValue().set(CATALOG_JSON,map);return map;}public Map<String, List<Catelog2Vo>> getCatalogJsonFromDB() {//1.查出所有1级分类List<CategoryEntity> selectList = baseMapper.selectList(null);/*** 将数据库的多次查询变成一次*///2. 封装数据List<CategoryEntity> level1Category = selectList.stream().filter(s->s.getParentCid().equals(0L)).collect(Collectors.toList());Map<String, List<Catelog2Vo>> map = level1Category.stream().collect(Collectors.toMap(k -> k.getCatId().toString(), v -> {//1.每一个的一级分类,查到1级分类的所有二级分类List<CategoryEntity> categoryEntities = selectList.stream().filter(s->s.getParentCid().equals(v.getCatId())).collect(Collectors.toList());List<Catelog2Vo> catelog2VoList = categoryEntities.stream().map(c -> {Catelog2Vo catelog2Vo = new Catelog2Vo();catelog2Vo.setId(c.getCatId().toString());catelog2Vo.setName(c.getName());catelog2Vo.setCatalog1Id(v.getCatId().toString());List<CategoryEntity> categoryEntities1 = selectList.stream().filter(s->s.getParentCid().equals(c.getCatId())).collect(Collectors.toList());List<Catelog2Vo.Catelog3Vo> collect = categoryEntities1.stream().map(c3 -> {Catelog2Vo.Catelog3Vo catelog3Vo = new Catelog2Vo.Catelog3Vo();catelog3Vo.setId(c3.getCatId().toString());catelog3Vo.setName(c3.getName());catelog3Vo.setCatalog2Id(c.getCatId().toString());return catelog3Vo;}).collect(Collectors.toList());catelog2Vo.setCatalog3List(collect);return catelog2Vo;}).collect(Collectors.toList());return catelog2VoList;}));return map;}

4.进行压力测试

会有异常

1.第一种异常

 连接量太大

2.第二种异常

很重要 堆外内存溢出  OutOfDirectMemoryError

分析源码

 

 这是 

lettuce-core 老版本报的错  就是内存没有及时释放,导致内存泄漏,是新来的空间大于最大空间,就会抛出堆外内存溢出

新版本可以不用解决

  1. springboot2.0 以后默认使用lettuce作为操作 redis的客户端。它使用netty进行网络通信。
  2. lettuce 的bug导致netty 堆外内存溢出,-Xmx300m; netty如果没有指定堆外内存,默认是使用-Xms300m
  3. 可以通过 -Dio.netty.maxDirectMemory进行设置
  4. 但是不能只是用 -Dio.netty.maxDirectMemory进行设置
  5. 可以升级lettuce客户端版本解决
  6. 可以使用jedis

3.来整合jedis

没玩过,试试,虽然这个Bug新版本解决了,但是想多学一点就来整合一下

1.导入依赖 
 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><exclusions><exclusion><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId></exclusion></exclusions></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId></dependency>

补充:lettuce、jedis操作redis的底层客户端。spring再次封装redisTemplate

 


http://www.ppmy.cn/news/1473640.html

相关文章

Springboot项目接入支付宝SDK

源码下载 config import java.io.FileWriter; import java.io.IOException;public class AlipayConfig {// 应用ID,您的APPID&#xff0c;收款账号既是您的APPID对应支付宝账号public static String app_id "";// 商户私钥&#xff0c;您的PKCS8格式RSA2私钥publi…

uni-app-H5页面调用设备摄像头扫描二维码

应用场景&#xff1a;APK里面webView&#xff0c;访问用uniapp写的H5页面&#xff0c;需要调用设备摄像头扫描二维码 首先下载导入扫描插件&#xff1a;H5调用摄像头识别二维码&#xff08;原生H5调用&#xff0c;不需要任何sdk&#xff0c;本地扫描识别&#xff0c;不需要后端…

实现浏览器语音呼起及语音录入及下载

主要分布三部分: 第一部分:开始录音 ;第二部分:停止录音;第三部分:静默监听。 一、开始录音 代码如下: document.getElementById(startRecording).onclick = async function() {if (navigator.mediaDevices && navigator.mediaDevices.getUserMedia) {try {au…

【代码随想录算法训练营第六十天|并查集、卡码网107.寻找可能存在的路径】

文章目录 卡码网107.寻找可能存在的路径 并查集基础内容还是看代码随想录 并查集 卡码网107.寻找可能存在的路径 纯并查集的基础应用&#xff0c;并查集只是看元素是否在同一个集合中&#xff0c;因此在加入的时候需要先查看两个元素是否已经在一个并查集中&#xff0c;如果不…

大数据处理系统架构特征

Storm之父Nathan Marz在《大数据系统构建&#xff1a;可扩展实时数据系统构建原理与最佳实践》一书中&#xff0c;提出了他认为大数据系统应该具有的属性。 1.鲁棒性和容错性&#xff08;Robust and Fault-tolerant&#xff09; 对大规模分布式系统来说&#xff0c;机器是不可…

golang线程池ants-实现架构

1、总体架构 ants协程池&#xff0c;在使用上有多种方式(使用方式参考这篇文章&#xff1a;golang线程池ants-四种使用方法)&#xff0c;但是在实现的核心就一个&#xff0c;如下架构图&#xff1a; 总的来说&#xff0c;就是三个数据结构&#xff1a; Pool、WorkerStack、goW…

基于深度学习LightWeight的人体姿态检测跌倒系统源码

一. LightWeight概述 light weight openpose是openpose的简化版本&#xff0c;使用了openpose的大体流程。 Light weight openpose和openpose的区别是&#xff1a; a 前者使用的是Mobilenet V1&#xff08;到conv5_5&#xff09;&#xff0c;后者使用的是Vgg19&#xff08;前10…

论文阅读之旋转目标检测ARC:《Adaptive Rotated Convolution for Rotated Object Detection》

论文link&#xff1a;link code&#xff1a;code ARC是一个改进的backbone&#xff0c;相比于ResNet&#xff0c;最后的几层有一些改变。 Introduction ARC自适应地旋转以调整每个输入的条件参数&#xff0c;其中旋转角度由路由函数以数据相关的方式预测。此外&#xff0c;还采…