springboot配置RedisTemplate和RedisCacheManager

古城微笑少年丶 2022-10-14 12:51 169阅读 0赞

# 1、项目目录结构： #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70]

# 2、application.properties配置文件： #

> 我这里redis连的是虚拟机上面的，你改下host地址就行

spring.datasource.url=jdbc:mysql://localhost:3306/spring_cache
    spring.datasource.username=root
    spring.datasource.password=123456
    spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.datasource.type=org.springframework.jdbc.datasource.DriverManagerDataSource
    
    
    #开启驼峰命名匹配规则
    mybatis.configuration.map-underscore-to-camel-case=true
    
    logging.level.com.atguigu.springcache.mapper=debug
    
    #debug=true
    
    #配置redis
    spring.redis.host=192.168.56.101

# 3、**MyRedisConfig** #

package com.atguigu.springcache.config;
    
    import com.atguigu.springcache.bean.Department;
    import com.atguigu.springcache.bean.Employee;
    import com.fasterxml.jackson.annotation.JsonAutoDetect;
    import com.fasterxml.jackson.annotation.PropertyAccessor;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnSingleCandidate;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.data.redis.cache.RedisCacheConfiguration;
    import org.springframework.data.redis.cache.RedisCacheManager;
    import org.springframework.data.redis.cache.RedisCacheWriter;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
    import org.springframework.data.redis.serializer.RedisSerializationContext;
    import org.springframework.data.redis.serializer.RedisSerializer;
    import org.springframework.data.redis.serializer.StringRedisSerializer;
    
    import java.net.UnknownHostException;
    
    @Configuration
    public class MyRedisConfig { 
    
        /*@Bean public RedisTemplate<Object, Employee> empRedisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<Object, Employee> template = new RedisTemplate(); template.setConnectionFactory(redisConnectionFactory); Jackson2JsonRedisSerializer<Employee> ser = new Jackson2JsonRedisSerializer<Employee>(Employee.class); template.setDefaultSerializer(ser); return template; }*/
        //CacheManagerCustomizers可以来定制缓存的一些规则
      /* @Primary //将某个缓存管理器作为默认的 @Bean public RedisCacheManager employeeCacheManager(RedisTemplate<Object, Employee> empRedisTemplate){ RedisCacheManager cacheManager = new RedisCacheManager(empRedisTemplate); //key多了一个前缀 //使用前缀，默认会将CacheName作为key的前缀 // cacheManager.setUsePrefix(true); return cacheManager; } @Bean public RedisCacheManager deptCacheManager(RedisTemplate<Object, Department> deptRedisTemplate){ RedisCacheManager cacheManager = new RedisCacheManager(deptRedisTemplate); //key多了一个前缀 //使用前缀，默认会将CacheName作为key的前缀 // cacheManager.setUsePrefix(true); return cacheManager; } */
        /** * 往容器中添加RedisTemplate对象，设置序列化方式 * @param redisConnectionFactory * @return * @throws UnknownHostException */
        @Bean
        public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException { 
            RedisTemplate<String, Object> template = new RedisTemplate();
            template.setConnectionFactory(redisConnectionFactory);
            template.setKeySerializer(new StringRedisSerializer());
            template.setValueSerializer(valueSerializer());
            template.setHashKeySerializer(new StringRedisSerializer());
            template.setHashValueSerializer(valueSerializer());
            template.afterPropertiesSet();
            return template;
        }
    
        /** * 往容器中添加RedisCacheManager容器，并设置序列化方式 * @param redisConnectionFactory * @return */
        @Primary    //将某个缓存管理器作为默认使用的
        @Bean
        public RedisCacheManager redisCacheManager(RedisConnectionFactory redisConnectionFactory) { 
            RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory);
            RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
                    .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(valueSerializer()));
            redisCacheConfiguration.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()));
            return new RedisCacheManager(redisCacheWriter, redisCacheConfiguration);
        }
        /** * 使用Jackson序列化器 * @return */
        private RedisSerializer<Object> valueSerializer() { 
            Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            /** * 这一句必须要，作用是序列化时将对象全类名一起保存下来 * 设置之后的序列化结果如下： * [ * "com.dxy.cache.pojo.Dept", * { * "pid": 1, * "code": "11", * "name": "财务部1" * } * ] * * 不设置的话，序列化结果如下，将无法反序列化 * * { * "pid": 1, * "code": "11", * "name": "财务部1" * } */
    // objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            //因为上面那句代码已经被标记成作废，因此用下面这个方法代替，仅仅测试了一下，不知道是否完全正确
            objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
            serializer.setObjectMapper(objectMapper);
            return serializer;
        }
    
    
    }

# 4、DeptController: #

package com.atguigu.springcache.controller;
    
    import com.atguigu.springcache.bean.Department;
    import com.atguigu.springcache.service.DeptService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class DeptController { 
        @Autowired
        DeptService deptService;
    
    
        @GetMapping("/dept/{id}")
        public Department getDept(@PathVariable("id") Integer id){ 
            Department deptById = deptService.getDeptById(id);
            return deptById;
        }
    }

# 5、**DeptService:** #

package com.atguigu.springcache.service;
    
    import com.atguigu.springcache.bean.Department;
    import com.atguigu.springcache.mapper.DepartmentMapper;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.cache.Cache;
    import org.springframework.cache.annotation.Cacheable;
    import org.springframework.data.redis.cache.RedisCacheManager;
    import org.springframework.stereotype.Service;
    
    @Service
    public class DeptService { 
        @Autowired
        DepartmentMapper departmentMapper;
    
        @Qualifier("redisCacheManager")
        @Autowired
        RedisCacheManager redisCacheManager;
        /** * 缓存的数据能存入redis * 注解方式存数据 */
        @Cacheable(cacheNames = "dept")
        public Department getDeptById(Integer id){ 
            System.out.println("查询部门"+id);
            Department department=departmentMapper.getDeptById(id);
           return department;
        }
    
    	
    }

# 6、DeptMapper: #

package com.atguigu.springcache.mapper;
    
    import com.atguigu.springcache.bean.Department;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Select;
    
    @Mapper
    public interface DepartmentMapper { 
    
        @Select("select * from department where id=#{id}")
        Department getDeptById(Integer id);
    }

# 7、测试： #

先清空redis数据库，否则会报错  
![在这里插入图片描述][20210521152436494.png]  
启动项目，访问：`localhost:8080/dept/1`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][20210521152631200.png]

查看redis数据库：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 2]

再查一次部门1，控制台并没有打印sql语句，而是从缓存中取![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 3][]

[MyRedisConfig配置类的参考链接][MyRedisConfig]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70]: /images/20221014/567d8c116b0a4210a398fe0283b00529.png
[20210521152436494.png]: /images/20221014/707d8ede8fe94ab980f333d157082c76.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 1]: /images/20221014/ddf65f0f00014fc98849e924c8607889.png
[20210521152631200.png]: /images/20221014/e642bf6221c64f848f7aa5e78d4ebc7a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 2]: /images/20221014/58c9797c5cfa47779d2b5bed33bfa1a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 3]: /images/20221014/f5996e7927a6460db47c2d6067dff64a.png
[MyRedisConfig]: https://blog.csdn.net/eric520zenobia/article/details/103286011?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522162157845916780264025786%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fall.%2522%257D&request_id=162157845916780264025786&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~first_rank_v2~rank_v29-11-103286011.first_rank_v2_pc_rank_v29&utm_term=springboot2%E9%85%8D%E7%BD%AEcachemanager&spm=1018.2226.3001.4187