SpringBoot与Redis缓存

浅浅的花香味﹌ 2022-04-25 01:42 216阅读 0赞

SpringBoot与Redis缓存：

## 准备 ##

在Docker安装Redis

![ATwKnP.png][]

![ATw8hQ.png][]

连接成功

![ATw639.png][]

对于Redis不熟悉的同学可以在本站搜索Redis的文章阅读。

## 整合Redis ##

在pom文件中加入

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre> &lt;!--引入Redis--&gt; &lt;dependency&gt; &lt;groupId&gt;org.springframework.boot&lt;/groupId&gt; &lt;artifactId&gt;spring-boot-starter-data-redis&lt;/artifactId&gt; &lt;/dependency&gt; </pre></td> 
 </tr> 
 </tbody> 
</table>

## 准备 ##

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 </pre></td> 
 <td><pre>package com.hph.cache; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.test.context.junit4.SpringRunner; @RunWith(SpringRunner.class) @SpringBootTest public class SpringbootCacheApplicationTests {
 @Autowired StringRedisTemplate stringRedisTemplate; @Autowired RedisTemplate redisTemplate; /** * Redis常用的数据类型 * String(字符串)、List(列表)、Set(集合)、Hash(散列)、(有序集合) * String（字符串）、List（列表）、Set（集合）、Hash（散列）、ZSet（有序集合） * stringRedisTemplate.opsForValue()[String（字符串）] * stringRedisTemplate.opsForList()[List（列表）] * stringRedisTemplate.opsForSet()[Set（集合）] * stringRedisTemplate.opsForHash()[Hash（散列）] * stringRedisTemplate.opsForZSet()[ZSet（有序集合）] */ @Test public void redis() {
 stringRedisTemplate.opsForValue().append("msg","hello"); } } </pre></td> 
 </tr> 
 </tbody> 
</table>

![ATsOk6.png][]

### 读取数据 ###

更新原有数据

![ATyCnA.png][]

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre>@Test public void getmesg() {
 String msg = stringRedisTemplate.opsForValue().get("msg"); System.out.println(msg); } </pre></td> 
 </tr> 
 </tbody> 
</table>

![ATyMBn.png][]

![ATyRud.png][]

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre>@Test public void cachObject(){
 Employee empById = employeeMapper.getEmpById(1); redisTemplate.opsForValue().set("emp-001",empById); } </pre></td> 
 </tr> 
 </tbody> 
</table>

![AT6K2D.png][]

### 序列化 ###

报错Employee需要序列化。

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 </pre></td> 
 <td><pre>public class Employee implements Serializable </pre></td> 
 </tr> 
 </tbody> 
</table>

![AT6Dqs.md.png][]

RedisTemplate默认的是JdkSerializationRedisSerializer的序列化器。

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 </pre></td> 
 <td><pre>if (defaultSerializer == null) {
 		defaultSerializer = new JdkSerializationRedisSerializer( 				classLoader != null ? classLoader : this.getClass().getClassLoader()); 	} </pre></td> 
 </tr> 
 </tbody> 
</table>

我们可以使用RedisSerializer的序列化器设置默认的序列化器。

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 </pre></td> 
 <td><pre>public void setDefaultSerializer(RedisSerializer&lt;?&gt; serializer) {
 	this.defaultSerializer = serializer; } </pre></td> 
 </tr> 
 </tbody> 
</table>

![ATcs6e.png][]

#### 自定义序列化器 ####

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 </pre></td> 
 <td><pre>@Autowired RedisTemplate&lt;Object, Employee&gt; empRedisTemplate; @Test public void ObjectToJsonRedis(){
 Employee empById = employeeMapper.getEmpById(1); //默认保存对象使用jdk序列化机制，序列化的数据保存在redis中 empRedisTemplate.opsForValue().set("emp-001",empById); } </pre></td> 
 </tr> 
 </tbody> 
</table>

成功

![ATg63T.png][]

好的我们开始运行以下看看使用Redis缓存的效果。

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 </pre></td> 
 <td><pre>package com.hph.cache.service; import com.hph.cache.bean.Employee; import com.hph.cache.mapper.EmployeeMapper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CachePut; import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Caching; import org.springframework.stereotype.Service; @Service public class EmployeeService {
 @Autowired EmployeeMapper employeeMapper; //condition = "#a0&gt;1 第一个参数的值&gt;&gt;1的时候可以进行缓存 除非a0参数是2 @Cacheable(cacheNames = {
 "emp"},keyGenerator = "myKeyGenerator") public Employee getEmp(Integer id) {
 System.out.println("查询" + id + "号员工"); Employee emp = employeeMapper.getEmpById(id); return emp; } /** * @CachePut即调用方法,又更新缓存数据 修改了数据库的某个数据, 同时更新缓存 * 运行时机:先调用目标方法,现将目标方法的结果缓存起来 */ @CachePut(value = "emp", key = "#result.id ") public Employee updateEmp(Employee employee) {
 System.out.println("updateEmp" + employee); employeeMapper.updateEmp(employee); return employee; } /** * @Cachevict :缓存清除 * key: 指定要清除的数据 */ //缓存默认清除才足在方法执行之后执行;如果出现异常缓存不会被清除 @CacheEvict(value = "emp", beforeInvocation = true) public void deleteEmp(Integer id) {
 System.out.println("deletEmp" + id); // employeeMapper.deleteEmpById(id); int i = 10 / 0; } } </pre></td> 
 </tr> 
 </tbody> 
</table>

### 流程分析 ###

原理：CacheManager==某一个Cache缓存组件来给实际给缓存中存取得数据，比如我们使用Redis缓存，那么SimpleCacheManager就不匹配进而不能使用，从而使用Redis

![ATbUJg.png][]

![ATb6oT.png][]

引入Redis的starter，容器中保存的是RedisCcheManager；

RedisCacheManager帮我们创建RedisCache作为缓存组件，RedisCache通过Redis缓存数据。

![ATq81J.png][]

我们可以看到SQL只执行了一次。

![ATqtn1.png][]

Redis中已经缓存我们查询过的数据。

默认保留数据的K-V都是Object；利用序列化保存可以保存为Json。

引入了redis的stater，cacheManager变为RedisCacheManager；默认创建的RedisCacheManager

RedisCacheManager操作Redis使用的是RedisTemplate默认使用的是JdkSerializationRedisSerializer

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre>if (defaultSerializer == null) {
 		defaultSerializer = new JdkSerializationRedisSerializer( 				classLoader != null ? classLoader : this.getClass().getClassLoader()); 	} </pre></td> 
 </tr> 
 </tbody> 
</table>

### 缓存管理器 ###

接下来我们定制以下缓存管理器。

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 </pre></td> 
 <td><pre>package com.hph.cache.config; import com.hph.cache.bean.Employee; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import java.net.UnknownHostException; @Configuration public class MyRedisConfig {
 @Bean public RedisTemplate&lt;Object, Employee&gt; empRedisTemplate( RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
 RedisTemplate&lt;Object, Employee&gt; template = new RedisTemplate&lt;Object, Employee&gt;(); template.setConnectionFactory(redisConnectionFactory); Jackson2JsonRedisSerializer&lt;Employee&gt; ser = new Jackson2JsonRedisSerializer&lt;Employee&gt;(Employee.class); template.setDefaultSerializer(ser); return template; } //CacheManagerCustomizers可以定制缓存的一些规则。 @Bean public RedisCacheManager employeeCacheManager(RedisTemplate&lt;Object, Employee&gt; empRedisTemplate){
 RedisCacheManager cacheManager = new RedisCacheManager(empRedisTemplate); cacheManager.setUsePrefix(true); return cacheManager; } } </pre></td> 
 </tr> 
 </tbody> 
</table>

而创建缓存管理器的条件是。

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre>@AutoConfigureAfter(RedisAutoConfiguration.class) @ConditionalOnBean(RedisTemplate.class) @ConditionalOnMissingBean(CacheManager.class) //没有CacheManager的时候创建RedisCacheConfiguration @Conditional(CacheCondition.class) class RedisCacheConfiguration {
 </pre></td> 
 </tr> 
 </tbody> 
</table>

运行结果。

![ATX81g.png][]

我们在创建一个关于Department的缓存查询。

![ATjaKH.png][]

![ATjBVI.png][]

然而当我们再次请求缓存的时候。

![ATjDat.png][]

5个属性要映射，这是因为我们自定义的那个缓存管理器是属于员工的而不是部门，因此字段对应不上去。同时我们也发现了缓存数据第一次可以存入Redis，第二次从缓存中查询就不能够反序列化回来了。这是因为当我们存储dept的json数据时，CacheManager默认使用的是RedisTemplate<Object,Employee>操作Redis，只能将Employee数据反序列化。

我们需要配置以下缓存管理器。

给Employee Dept分别指定缓存类别

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 </pre></td> 
 <td><pre>@CacheConfig(cacheNames = "emp",cacheManager = "employeeCacheManager") @Service public class EmployeeService {
 @Autowired EmployeeMapper employeeMapper; .... } </pre></td> 
 </tr> 
 </tbody> 
</table>

![ATzTit.png][]

在MyRedisConfig中指定一个主类

我们把Rdis的数据清空下

![A79E5R.png][]

由于默认指定的是employeeCacheManager我们可以在

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre>@CacheConfig(cacheNames = "emp")EmployeeService上省略。 @Service public class EmployeeService {
 @Autowired EmployeeMapper employeeMapper; </pre></td> 
 </tr> 
 </tbody> 
</table>

在实际开发中不应该将employeeCacheManager作为默认指定，应该将RedisCacheManager作为默认指定。@Primary将某个缓存管理器作为默认的

另外我们可以选择编码的方式l来配置缓存管理器。

在DeptService中。

![A7Ptu8.png][]

[ATwKnP.png]: /images/20220210/12baaf1c4c6947e8a45863c637a931b4.png
[ATw8hQ.png]: /images/20220210/5b0242c93133458b9d1c07d87254802e.png
[ATw639.png]: /images/20220210/ca7a80b1aa144376924fe00de49e015a.png
[ATsOk6.png]: /images/20220210/fc5af61eb3b74e01b91bad1310e33c00.png
[ATyCnA.png]: /images/20220210/f46f7be02c1348b3b8b42824b9bf906f.png
[ATyMBn.png]: /images/20220210/9b4644bbc9cb41459c70001f6af0bb02.png
[ATyRud.png]: /images/20220210/233ced5a55754cda9aa3d5acabb1bccd.png
[AT6K2D.png]: /images/20220210/bbefb4df812f49438ed03d21b0e8e5f7.png
[AT6Dqs.md.png]: /images/20220210/ddb7ddbac02947858c68f109b8900dc1.png
[ATcs6e.png]: /images/20220210/6f9c5823f5e245f68ec538e5cf12e4bc.png
[ATg63T.png]: /images/20220210/aa75e60f83ab4e549cea883921188b9b.png
[ATbUJg.png]: /images/20220210/3efe53b0a8214767a449be3675633fcc.png
[ATb6oT.png]: /images/20220210/0a1fdce55f704bacb4e47a61abd938ab.png
[ATq81J.png]: /images/20220210/67baf8fdc32f41a1ab326a8d17e72fb5.png
[ATqtn1.png]: /images/20220210/9b092b4b2cb147aaa35d7f68c9288613.png
[ATX81g.png]: /images/20220210/01dd2b984e7b48289633e1e1f8b89540.png
[ATjaKH.png]: /images/20220210/8e538dfd81914235b77aefbbd7c047ce.png
[ATjBVI.png]: /images/20220210/ad61c2d4bd3942f8bc98d53c254bb732.png
[ATjDat.png]: /images/20220210/54d6bc1fbc264c67b2a29a97da391bef.png
[ATzTit.png]: /images/20220210/2d03b9c4bfb64027bd93164b9b465c1c.png
[A79E5R.png]: /images/20220210/ebd387beb8a54e519f0686b97a4dce5a.png
[A7Ptu8.png]: /images/20220210/180132342a134be496d7e5818b241e04.png