Springboot2整合Redis以及jackson序列化
阿新 • • 發佈:2018-12-31
pom.xml
<!--redis--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
application.yml:
redis: #資料庫索引 database: 0 host: 47.101.172.217 port: 6379 password: lettuce: pool: #最大連線數 max-active: 8 #最大阻塞等待時間(負數表示沒限制) max-wait: -1 #最大空閒 max-idle: 8 #最小空閒 min-idle: 0 #連線超時時間 timeout: 10000
RedisConfig.java:
@Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport { /** * json序列化 * @return */ @Bean public RedisSerializer<Object> jackson2JsonRedisSerializer() { //使用Jackson2JsonRedisSerializer來序列化和反序列化redis的value值 Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper mapper = new ObjectMapper(); mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); serializer.setObjectMapper(mapper); return serializer; } @Bean public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) { //StringRedisTemplate的構造方法中預設設定了stringSerializer RedisTemplate<String, Object> template = new RedisTemplate<>(); //set key serializer StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); template.setKeySerializer(stringRedisSerializer); template.setHashKeySerializer(stringRedisSerializer); //set value serializer template.setDefaultSerializer(jackson2JsonRedisSerializer()); template.setConnectionFactory(lettuceConnectionFactory); template.afterPropertiesSet(); return template; } @Bean public StringRedisTemplate stringRedisTemplate(LettuceConnectionFactory lettuceConnectionFactory) { StringRedisTemplate template = new StringRedisTemplate(); template.setConnectionFactory(lettuceConnectionFactory); return template; } /** * 在使用@Cacheable時,如果不指定key,則使用找個預設的key生成器生成的key * */ @Override @Bean public SimpleKeyGenerator keyGenerator() { return new SimpleKeyGenerator() { @Override public Object generate(Object target, Method method, Object... params) { StringBuilder sb = new StringBuilder(); sb.append(target.getClass().getName()); sb.append(".").append(method.getName()); StringBuilder paramsSb = new StringBuilder(); for (Object param : params) { // 如果不指定,預設生成包含到鍵值中 if (param != null) { paramsSb.append(param.toString()); } } if (paramsSb.length() > 0) { sb.append("_").append(paramsSb); } return sb.toString(); } }; } /** * 管理快取 * * @param lettuceConnectionFactory * @return */ //快取管理器 @Bean public CacheManager cacheManager(LettuceConnectionFactory lettuceConnectionFactory) { // 生成一個預設配置,通過config物件即可對快取進行自定義配置 RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig(); // 設定快取的預設過期時間,也是使用Duration設定 config = config.entryTtl(Duration.ofMinutes(1)) // 設定 key為string序列化 .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer())) // 設定value為json序列化 .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer() )) // 不快取空值 .disableCachingNullValues(); // 設定一個初始化的快取空間set集合 Set<String> cacheNames = new HashSet<>(); cacheNames.add("company_goods_info"); // 對每個快取空間應用不同的配置 Map<String, RedisCacheConfiguration> configMap = new HashMap<>(); configMap.put("company_goods_info", config); // 使用自定義的快取配置初始化一個cacheManager RedisCacheManager cacheManager = RedisCacheManager.builder(lettuceConnectionFactory) // 一定要先呼叫該方法設定初始化的快取名,再初始化相關的配置 .initialCacheNames(cacheNames) .withInitialCacheConfigurations(configMap) .build(); return cacheManager; } }