Day413.SpringCache -谷粒商城

Posted 阿昌喜欢吃黄桃

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Day413.SpringCache -谷粒商城相关的知识,希望对你有一定的参考价值。

SpringCache

每次都那样写缓存太麻烦了,spring从3.1开始定义了Cache、CacheManager接口来统一不同的缓存技术。并支持使用JCache(JSR-107)注解简化我们的开发Cache接口的实现包括RedisCache、EhCacheCache、ConcurrentMapCache等每次调用需要缓存功能的方法时,spring会检查检查指定参数的指定的目标方法是否已经被调用过;

如果有就直接从缓存中获取方法调用后的结果,如果没有就调用方法并缓存结果后返回给用户。下次调用直接从缓存中获取。

  • 使用Spring缓存抽象时我们需要关注以下两点

1、确定方法需要缓存以及他们的缓存策略

2、从缓存中读取之前缓存存储的数据

一、配置

  • 依赖
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>

<!--使用redis作为缓存-->
<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>
  • 指定缓存类型并在主配置类上加上注解@EnableCaching
@EnableCaching//开启缓存注解
public class AchangmallProductApplication 

    public static void main(String[] args) 
        SpringApplication.run(AchangmallProductApplication.class, args);
    


spring:
  cache:
  	#指定缓存类型为redis
    type: redis
    redis:
      # 指定redis中的过期时间为1h
      time-to-live: 3600000
      key-prefix: CACHE_   #缓存key前缀
      use-key-prefix: true #是否开启缓存key前缀
      cache-null-values: true #缓存空值,解决缓存穿透问题

默认使用jdk进行序列化(可读性差),默认ttl为-1永不过期,自定义序列化方式为JSON需要编写配置类

  • 配置类

com.achang.achangmall.product.conf.MyCacheConfig

自定义缓存管理器,保存为JSON格式

@Configuration
@EnableConfigurationProperties(CacheProperties.class)//拿到Redis在配置文件的配置
public class MyCacheConfig 
    @Bean
    public RedisCacheConfiguration redisCacheConfiguration(CacheProperties cacheProperties) 
        //获取到配置文件中的配置信息
        CacheProperties.Redis redisProperties = cacheProperties.getRedis(); org.springframework.data.redis.cache.RedisCacheConfiguration config = org.springframework.data.redis.cache.RedisCacheConfiguration.defaultCacheConfig();
        //指定缓存序列化方式为json
        config = config.serializeValuesWith(
            RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
        //设置配置文件中的各项配置,如过期时间
        if (redisProperties.getTimeToLive() != null) 
            config = config.entryTtl(redisProperties.getTimeToLive());
        

        if (redisProperties.getKeyPrefix() != null) 
            config = config.prefixKeysWith(redisProperties.getKeyPrefix());
        
        if (!redisProperties.isCacheNullValues()) 
            config = config.disableCachingNullValues();
        
        if (!redisProperties.isUseKeyPrefix()) 
            config = config.disableKeyPrefix();
        
        return config;
    


二、缓存自动配置

// 缓存自动配置源码
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(CacheManager.class)
@ConditionalOnBean(CacheAspectSupport.class)
@ConditionalOnMissingBean(value = CacheManager.class, name = "cacheResolver")
@EnableConfigurationProperties(CacheProperties.class)
@AutoConfigureAfter( CouchbaseAutoConfiguration.class, HazelcastAutoConfiguration.class,
                     HibernateJpaAutoConfiguration.class, RedisAutoConfiguration.class )
@Import( CacheConfigurationImportSelector.class, // 看导入什么CacheConfiguration
         CacheManagerEntityManagerFactoryDependsOnPostProcessor.class )
public class CacheAutoConfiguration 

    @Bean
    @ConditionalOnMissingBean
    public CacheManagerCustomizers cacheManagerCustomizers(ObjectProvider<CacheManagerCustomizer<?>> customizers) 
        return new CacheManagerCustomizers(customizers.orderedStream().collect(Collectors.toList()));
    

    @Bean
    public CacheManagerValidator cacheAutoConfigurationValidator(CacheProperties cacheProperties,
                                                                 ObjectProvider<CacheManager> cacheManager) 
        return new CacheManagerValidator(cacheProperties, cacheManager);
    

    @ConditionalOnClass(LocalContainerEntityManagerFactoryBean.class)
    @ConditionalOnBean(AbstractEntityManagerFactoryBean.class)
    static class CacheManagerEntityManagerFactoryDependsOnPostProcessor
        extends EntityManagerFactoryDependsOnPostProcessor 

        CacheManagerEntityManagerFactoryDependsOnPostProcessor() 
            super("cacheManager");
        

    


    @Configuration(proxyBeanMethods = false)
    @ConditionalOnClass(RedisConnectionFactory.class)
    @AutoConfigureAfter(RedisAutoConfiguration.class)
    @ConditionalOnBean(RedisConnectionFactory.class)
    @ConditionalOnMissingBean(CacheManager.class)
    @Conditional(CacheCondition.class)
    class RedisCacheConfiguration 
        @Bean // 放入缓存管理器
        RedisCacheManager cacheManager(CacheProperties cacheProperties, 
                                       CacheManagerCustomizers cacheManagerCustomizers,
                                       ObjectProvider<org.springframework.data.redis.cache.RedisCacheConfiguration> redisCacheConfiguration,
                                       ObjectProvider<RedisCacheManagerBuilderCustomizer> redisCacheManagerBuilderCustomizers,
                                       RedisConnectionFactory redisConnectionFactory, ResourceLoader resourceLoader) 
            RedisCacheManagerBuilder builder = RedisCacheManager.builder(redisConnectionFactory).cacheDefaults(
                determineConfiguration(cacheProperties, redisCacheConfiguration, resourceLoader.getClassLoader()));
            List<String> cacheNames = cacheProperties.getCacheNames();
            if (!cacheNames.isEmpty()) 
                builder.initialCacheNames(new LinkedHashSet<>(cacheNames));
            
            redisCacheManagerBuilderCustomizers.orderedStream().forEach((customizer) -> customizer.customize(builder));
            return cacheManagerCustomizers.customize(builder.build());
        

三、缓存使用@Cacheable&@CacheEvict

  • 第一个方法存放缓存,第二个方法清空缓存
// 调用该方法时会将结果缓存,缓存名为category,key为方法名
// sync表示该方法的缓存被读取时会加锁 
// value等同于cacheNames 【缓存分区名】
// key如果是字符串"''",【请加上单引号】
@Cacheable(value = "category",key = "#root.methodName",sync = true)
public Map<String, List<Catalog2Vo>> getCatalogJsonDbWithSpringCache() 
    return getCategoriesDb();

//调用该方法会删除缓存category下的所有cache,如果要删除某个具体,用key="''"
//allEntries = true,value中分区删除里的所有数据
//更新操作
@Override
@CacheEvict(value = "category",allEntries = true)
public void updateCascade(CategoryEntity category) 
    this.updateById(category);
    if (!StringUtils.isEmpty(category.getName())) 
        categoryBrandRelationService.updateCategory(category);
    

如果要清空多个缓存,用@Caching(evict=@CacheEvict(value=""),xxxxxxxx)


四、SpringCache原理与不足

1、读模式

  • 缓存穿透

    • 查询一个null数据。解决方案:缓存空数据,可通过spring.cache.redis.cache-null-values=true
  • 缓存击穿

    • 大量并发进来同时查询一个正好过期的数据。解决方案:加锁 ? 默认是无加锁的;
      使用sync = true来解决击穿问题
  • 缓存雪崩

    • 大量的key同时过期。解决:加随机时间

2、写模式:(缓存与数据库一致)

  • 读写加锁。

  • 引入Canal,感知到mysql的更新去更新Redis

  • 读多写多,直接去数据库查询就行

3、总结

  • 常规数据(读多写少,即时性,一致性要求不高的数据,完全可以使用Spring-Cache):
    • 写模式(只要缓存的数据有过期时间就足够了)
  • 特殊数据:
    • 特殊设计(读写锁等)

以上是关于Day413.SpringCache -谷粒商城的主要内容,如果未能解决你的问题,请参考以下文章

伸手党福利文,Python入门大全

目录大纲

自学it18大数据笔记-第一阶段Java-day05-day06-day07-day08

day56(2023.4.25)

Alpha阶段 - 博客链接合集

python-第一块,笔记整理和学习内容复习(day1 - day2 - day3)