缓存1.3

为了系统性能的提升我们一般都会将部分数据放入缓存中加速访问。

而

哪些数据适合放入缓存

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

举例电商类应用商品分类商品列表等适合缓存并加一个失效时间(根据数据更新频率来定)后台如果发布一个商品买家需要

伪代码

redisTemplate.opsForValue().get(redisKey);//从缓存加载数据

If(data

中redisTemplate.opsForValue().set(redisKey,data);

return

数据是存储与内存的相比于数据库查询要从磁盘加载到内存有着更高的效率。

1.3

但是在分布式情况下这种情况就不再适用了每个微服务可能部署在多台机器上每个机器上有各自的缓存

Map

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-redis/artifactId

/dependency2.2

{//存储redisTemplate.opsForValue().set(HELLO_REDIS,

value

redisTemplate.opsForValue().get(HELLO_REDIS);System.out.println(value);

}三、改造三级分类业务

{//给缓存中放json字符串拿出的json字符串还用逆转为能用的对象类型:【序列化与反序列化】/***

1、空结果缓存解决缓存穿透*

3、加锁解决缓存击穿*///1、加入缓存逻辑,缓存中存的数据是json字符串。

//JSON跨语言跨平台兼容。

String

catalogJSON

redisTemplate.opsForValue().get(catalogJSON);if

(StringUtils.isEmpty(catalogJSON))

{//2、缓存中没有,查询数据库//保证数据库查询完成以后,将数据放在redis中,这是一个原子操作。

log.info(缓存不命中....将要查询数据库...);MapString,

ListCatelog2Vo

JSON.toJSONString(catalogJsonFromDb);redisTemplate.opsForValue().set(catalogJSON,result);}log.info(缓存命中....直接返回....);//转为我们指定的对象。

return

new

redisTemplate.opsForValue().get(redisKey);

If(data

中redisTemplate.opsForValue().set(redisKey,null,300,TimeUnit.SECONDS);}else

{//保存到

中redisTemplate.opsForValue().set(redisKey,data);}

return

这种技术在缓存之前再加一层屏障里面存储目前数据库中存在的所有key。

当业务系统有查询请求的时候首先去BloomFilter中查询该key是否存在。

若不存在则说明数据库中也不存在该数据因此缓存都不要查了直接返回null。

若存在则继续执行后续的流程先前往缓存中查询缓存中没有的话再前往数据库中的查询。

伪代码如下

String

{if(!bloomfilter.mightContain(key)){//不存在则返回return

null;

{//给缓存中放json字符串拿出的json字符串还用逆转为能用的对象类型:【序列化与反序列化】/***

1、空结果缓存解决缓存穿透*

3、加锁解决缓存击穿*///1、加入缓存逻辑,缓存中存的数据是json字符串。

//JSON跨语言跨平台兼容。

String

catalogJSON

redisTemplate.opsForValue().get(catalogJSON);if

(StringUtils.isEmpty(catalogJSON))

{//2、缓存中没有,查询数据库//保证数据库查询完成以后,将数据放在redis中,这是一个原子操作。

log.info(缓存不命中....将要查询数据库...);MapString,

ListCatelog2Vo

catalogJsonFromDb;}log.info(缓存命中....直接返回....);//转为我们指定的对象。

return

new

}查询数据库后将结果放入缓存保证这是一个原子性操作防止多个线程查询数据库而导致日志输出多个查询了数据库…

//从数据库查询并封装分类数据

{//只要同一把锁,就能锁住需要这个锁的所有线程//synchronized

(this)springBoot所有组件在容器中都是单实例的//TODO

本地锁synchronized

在分布式情况下只能使用分布式锁才能锁住资源synchronized

(this)

{//得到锁以后,我们应该再去缓存中确定一次,如果没有才需要继续查询String

catalogJSON

redisTemplate.opsForValue().get(catalogJSON);if

(!StringUtils.isEmpty(catalogJSON))

{return

{});}log.info(查询了数据库....);//1、将数据库的多次查询变为一次,查询所有分类信息ListCategoryEntity

selectList

baseMapper.selectList(null);//1、查出所有1级分类ListCategoryEntity

level1Categorys

level1Categorys.stream().collect(Collectors.toMap(k

{//1、每一个的一级分类,查到这个一级分类的二级分类ListCategoryEntity

categoryEntities

v.getCatId());//2、封装上面的结果ListCatelog2Vo

catelog2Vos

categoryEntities.stream().map(l2

{Catelog2Vo

Catelog2Vo(v.getCatId().toString(),

null,

l2.getName());//1、找当前二级分类的三级分类封装成voListCategoryEntity

level3Catelog

{//2、封装成指定格式Catelog2Vo.Catelog3Vo

catelog3Vo

Catelog2Vo.Catelog3Vo(l2.getCatId().toString(),

l3.getName());return

catelog3Vo;}).collect(Collectors.toList());catelog2Vo.setCatalog3List(collect);}return

catelog2Vo;}).collect(Collectors.toList());}return

result

JSON.toJSONString(parent_cid);redisTemplate.opsForValue().set(catalogJSON,result,1,TimeUnit.DAYS);return

parent_cid;}

}压力测试结果日志只输出一个查询了数据库…表面只有一个线程查询了数据库。