ToB企服应用市场:ToB评测及商务社交产业平台

标题: springboot+redis+缓存 [打印本页]
作者: 大连全瓷种植牙齿制作中心    时间: 2024-9-24 21:51
标题: springboot+redis+缓存
整合

添加依赖
  1. <dependency>
  2.       <groupId>org.springframework.boot</groupId>
  3.       <artifactId>spring-boot-starter-data-redis</artifactId>
  4. </dependency>
复制代码
连接redis，设置yml文件
主机
端口号
数据库是哪一个
暗码

设置类
  1. package com.aaa.config;
  3. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  4. import com.fasterxml.jackson.annotation.PropertyAccessor;
  5. import com.fasterxml.jackson.databind.ObjectMapper;
  6. import org.springframework.cache.CacheManager;
  7. import org.springframework.cache.annotation.CachingConfigurerSupport;
  8. import org.springframework.cache.annotation.EnableCaching;
  9. import org.springframework.context.annotation.Bean;
  10. import org.springframework.context.annotation.Configuration;
  11. import org.springframework.data.redis.cache.RedisCacheConfiguration;
  12. import org.springframework.data.redis.cache.RedisCacheManager;
  13. import org.springframework.data.redis.connection.RedisConnectionFactory;
  14. import org.springframework.data.redis.core.RedisTemplate;
  15. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
  16. import org.springframework.data.redis.serializer.RedisSerializationContext;
  17. import org.springframework.data.redis.serializer.RedisSerializer;
  18. import org.springframework.data.redis.serializer.StringRedisSerializer;
  20. import java.time.Duration;
  22. @Configuration
  24. public class RedisTemplateConfig  {
  27.     // 工具   redisTemplate
  28.     @Bean
  29.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
  30.         // 创建一个redisTemplate
  31.         RedisTemplate<String, Object> template = new RedisTemplate<>();
  32.         // redis 序列化
  33.         RedisSerializer<String> redisSerializer = new StringRedisSerializer();
  34.         // 序列化的对象
  35.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  37.         ObjectMapper om = new ObjectMapper();
  38.         // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
  39.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  40.         // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会抛出异常
  41.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  42.         jackson2JsonRedisSerializer.setObjectMapper(om);
  43.         template.setConnectionFactory(factory);
  44.         //key序列化方式
  45.         template.setKeySerializer(redisSerializer);
  46.         //value序列化
  47.         template.setValueSerializer(jackson2JsonRedisSerializer);
  48.         //value hashmap序列化
  49.         template.setHashValueSerializer(jackson2JsonRedisSerializer);
  50.         return template;
  51.     }
  52. }
复制代码
调用类方法举行操作redis
  1. package com.aaa;
  3. import junit.framework.TestCase;
  4. import junit.framework.TestSuite;
  5. import org.junit.jupiter.api.Test;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.boot.test.context.SpringBootTest;
  8. import org.springframework.data.redis.core.RedisTemplate;
  10. import java.util.HashMap;
  11. import java.util.Map;
  12. import java.util.concurrent.TimeUnit;
  14. @SpringBootTest
  15. public class AppTest {
  18.     @Autowired
  19.     private RedisTemplate redisTemplate;
  22.     @Test
  23.     public void testString(){
  24.         // 添加一个数据
  25.         redisTemplate.opsForValue().set("test","test1");
  26.     }
  29. }
复制代码
缓存

我们预备springboot+mybatis来使用缓存
流程

当我们实行增删改查的时候会大量的访问数据库，为了减缓数据库的压力或其他题目，我们使用缓存来解决，如果缓存中没有我们需要的数据时，我们将会访问数据库，但是如果缓存中有我们需要的数据，我们就不用再访问数据库了，而是直接拿到缓存即可
缓存穿透:

业务体系要查询的数据根本就不存在！当业务体系发起查询时，按照上述流程，起首会前去缓存中查询，由于缓存中不存在，然后再前去数据库中查询。由于该数据压根就不存在，因此数据库也返回空。这就是缓存穿透。
  综上所述：业务体系访问压根就不存在的数据，就称为缓存穿透。
危害

  如果存在海量哀求查询压根就不存在的数据，那么这些海量哀求都会落到数据库中，数据库压力剧增，大概会导致体系瓦解（你要知道，目前业务体系中最脆弱的就是 IO，轻微来点压力它就会瓦解，以是我们要想种种办法保护它）。
解决

把所有大概访问的值全部放到布隆过滤器内里 如果布隆过滤器中没有你要查询的值就直接返回null
缓存击穿:

访问的这个热点数据恰好过期了，将会产生大量的哀求访问数据库，给数据库带来巨大的压力
解决：
加锁
缓存雪崩：

缓存给数据库抵抗了大量的查询哀求，但是一旦缓存宕机了，那么原本被缓存抵抗的海量查询哀求就会像疯狗一样涌向数据库。此时数据库如果抵抗不了这巨大的压力，它就会瓦解。

设置类:

  1. package com.aaa.config;
  3. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  4. import com.fasterxml.jackson.annotation.PropertyAccessor;
  5. import com.fasterxml.jackson.databind.ObjectMapper;
  6. import org.springframework.cache.CacheManager;
  7. import org.springframework.cache.annotation.CachingConfigurerSupport;
  8. import org.springframework.cache.annotation.EnableCaching;
  9. import org.springframework.context.annotation.Bean;
  10. import org.springframework.context.annotation.Configuration;
  11. import org.springframework.data.redis.cache.RedisCacheConfiguration;
  12. import org.springframework.data.redis.cache.RedisCacheManager;
  13. import org.springframework.data.redis.connection.RedisConnectionFactory;
  14. import org.springframework.data.redis.core.RedisTemplate;
  15. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
  16. import org.springframework.data.redis.serializer.RedisSerializationContext;
  17. import org.springframework.data.redis.serializer.RedisSerializer;
  18. import org.springframework.data.redis.serializer.StringRedisSerializer;
  20. import java.time.Duration;
  22. @Configuration
  23. // 开启缓存
  24. @EnableCaching
  25. public class RedisTemplateConfig  {
  28.     // 工具   redisTemplate
  29.     @Bean
  30.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
  31.         // 创建一个redisTemplate
  32.         RedisTemplate<String, Object> template = new RedisTemplate<>();
  33.         // redis 序列化
  34.         RedisSerializer<String> redisSerializer = new StringRedisSerializer();
  35.         // 序列化的对象
  36.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  38.         ObjectMapper om = new ObjectMapper();
  39.         // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
  40.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  41.         // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会抛出异常
  42.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  43.         jackson2JsonRedisSerializer.setObjectMapper(om);
  44.         template.setConnectionFactory(factory);
  45.         //key序列化方式
  46.         template.setKeySerializer(redisSerializer);
  47.         //value序列化
  48.         template.setValueSerializer(jackson2JsonRedisSerializer);
  49.         //value hashmap序列化
  50.         template.setHashValueSerializer(jackson2JsonRedisSerializer);
  51.         return template;
  52.     }
  55.     // 注入缓存的bean
  56.     @Bean
  57.     public CacheManager cacheManager(RedisConnectionFactory factory) {
  58.         RedisSerializer<String> redisSerializer = new StringRedisSerializer();
  59.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  60. //解决查询缓存转换异常的问题
  61.         ObjectMapper om = new ObjectMapper();
  62.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  63.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  64.         jackson2JsonRedisSerializer.setObjectMapper(om);
  65. // 配置序列化（解决乱码的问题）,过期时间600秒
  67.         RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
  68.                 .entryTtl(Duration.ofSeconds(600)) //
  69.                 .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
  70.                 .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
  71.                 .disableCachingNullValues();
  72.         RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
  73.                 .cacheDefaults(config)
  74.                 .build();
  75.         return cacheManager;
  76.     }
  77. }
复制代码
开启缓存

  1. @EnableCaching
复制代码
我们的设置类上面必须要加上这个注解不加 就没有办法使用缓存
缓存一样寻常是加在service层
@Cacheable

对应的value值或者是cachename的值必须要写

查询


用我们的工具就可以看到


如果redis里没有这个数据，它会先访问数据库，然后把我们访问的这个数据添加到缓存里，下次查询的时候由于我们缓存里已经有了我们需要的数据，以是就不会再去访问数据库了，而是直接访问缓存

@CachePut

不管数据内里有没有   都会加到缓存中

添加或修改


我们可以本身去设置缓存的key名


@CacheEvict

删除

清除缓存
@CacheEvict是用来标注在需要清除缓存元素的方法或类上的

allEntries = true：代表清除value对应的值下面的所有的缓存，false：只清楚对应key的缓存

如果不写allEntries：也只会清楚对应key的缓存




免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4