栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

SpringBoot中SpringCache整合redis实现

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

SpringBoot中SpringCache整合redis实现

结合上一篇博客来看:
SpringBoot整合Redis

开始整合 SpringCache,这里只演示如何整合:

添加 maven 依赖:

        
            com.fasterxml.jackson.core
            jackson-databind
            2.6.7
        

        
            redis.clients
            jedis
            2.9.0
        

在 RedisConfig 的配置中添加代码:

@Override
    public KeyGenerator keyGenerator() {
        return new KeyGenerator() {
            @Override
            public Object generate(Object o, Method method, Object... objects) {
                StringBuilder sb = new StringBuilder();
                sb.append(o.getClass().getName()).append(".");
                sb.append(method.getName()).append(".");
                for (Object obj : objects) {
                    sb.append(obj.toString());
                }
                System.out.println("keyGenerator=" + sb.toString());
                return sb.toString();
            }
        };
    }
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        //初始化一个RedisCacheWriter
        RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory);
        //自定义key前缀
        CacheKeyPrefix cacheKeyPrefix = new CacheKeyPrefix() {
            @Override
            public String compute(String cacheName) {
                return cacheName+":";
            }
        };
        //设置CacheManager的值序列化方式为json序列化
        RedisSerializer jsonSerializer = new GenericJackson2JsonRedisSerializer();
        RedisSerializationContext.SerializationPair pair = RedisSerializationContext.SerializationPair
                .fromSerializer(jsonSerializer);
        //生成RedisCacheConfiguration配置
        RedisCacheConfiguration defaultCacheConfig = RedisCacheConfiguration.defaultCacheConfig()
                .computePrefixWith(cacheKeyPrefix)
                .serializevaluesWith(pair);
        //设置默认超过期时间是30秒
        defaultCacheConfig.entryTtl(Duration.ofSeconds(DEFAULT_TTL));
        //初始化RedisCacheManager
        return new RedisCacheManager(redisCacheWriter, defaultCacheConfig);
    }
 

编写 service,mapper 层:这里举一个例子:

controller 层:

@RequestMapping("test")
    public ResultJson selectUser() {
        System.out.println("===========第一次调用=======");
        ResultJson resultJson2 = demoService.selectUser();
        System.out.println("===========第二次调用=======");
        ResultJson resultJson1 = demoService.selectUser();
        System.out.println(resultJson1);
        System.out.println("===========");
        System.out.println(resultJson2);
        return null;
    }

service 层接口:

public interface DemoService {
    ResultJson selectUser();
}

service 层实现类,这里需要使用 @Cacheable 注解,同时在类上添加@CacheConfig(cacheNames = {“demoService”})

 @Override
    @Cacheable
    public ResultJson selectUser() {
        return ResultJson.success(demoMapper.selectUser());
    }

mapper 层接口:

public interface DemoMapper {
    List selectUser();
}

xml:


    

运行程序,查看访问结果


很明显的看出,第一次调用去 mysql 查找了数据,而第二次没有去 mysql,而是去了 redis,去 redis 数据库查看,会有数据:



再次执行程序,查看结果


由于 redis 中存在数据,所以都去 redis 查看结果了

闭环测试结束,解释 SpringCache 几个注解的作用:

@Cacheable 触发缓存入口
@CacheEvict 触发移除缓存
@CacahePut 更新缓存
@Caching 将多种缓存操作分组
@CacheConfig 类级别的缓存注解,允许共享缓存名称

CacheConfig 该注解是可以将缓存分类,它是类级别的注解方式。

@CacheConfig

@Cacheable

一般用于查询操作,根据key查询缓存.

@CachePut

@CachePut 一般用于更新和插入操作,每次都会请求db
通过key去redis中进行操作。

  1. 如果key存在,更新内容
  2. 如果key不存在,插入内容。

@CacheEvict

根据key删除缓存中的数据。allEntries=true表示删除缓存中的所有数据。

结束闭环测试

转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号