springboot 整合redis

elarity 發(fā)布于2019-08-06 13:37 / 1485人閱讀

摘要：與整合默認(rèn)使用的是，相較于，是一個可伸縮的，線程安全的客戶端。在處理高并發(fā)方面有更多的優(yōu)勢。使用依賴主要需要的依賴為配置配置使用與整合可以在不更改現(xiàn)有代碼邏輯的基礎(chǔ)上，通過增加注解的方式，實現(xiàn)緩存。

springboot2.0 與redis整合默認(rèn)使用的是Lettuce，相較于jedis，lettuce 是一個可伸縮的，線程安全的redis客戶端。在處理高并發(fā)方面有更多的優(yōu)勢。

RedisTemplate 使用

依賴, 主要需要的依賴為

 compile("org.springframework.boot:spring-boot-starter-data-redis")
 compile("org.apache.commons:commons-pool2:2.6.0")
 compile("com.alibaba:fastjson:1.2.33")

yml 配置

 spring:
   redis:
     database: 1
     host: 192.168.1.XX
     port: 6379
     lettuce:
       pool:
         max-active: 8
         max-wait: -1ms
         min-idle: 0

redisTemplate 配置

@Configuration
public class RedisConfiguration {

@Bean
public RedisTemplate redisTemplate(LettuceConnectionFactory connectionFactory){
    RedisTemplate template = new RedisTemplate();
    template.setConnectionFactory(connectionFactory);

    ObjectMapper objectMapper = new ObjectMapper();
    objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
    jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

    template.setValueSerializer(jackson2JsonRedisSerializer);
    template.setKeySerializer(new StringRedisSerializer());
    template.afterPropertiesSet();

    return  template;
    }
}

  
1. 使用

 @Autowired
RedisTemplate redisTemplate;
 public void addData(){
    MyInfo myInfo = new MyInfo("11","22","s344");
    redisTemplate.opsForValue().set("11",myInfo);
    redisTemplate.opsForValue().set("myse","mys");
}
```

spring-cache 與 redis 整合

spring cache 可以在不更改現(xiàn)有代碼邏輯的基礎(chǔ)上，通過增加注解的方式，實現(xiàn)緩存。減少代碼侵入

在gradle文件中增加 spring-cache的相關(guān)依賴 compile("org.springframework.boot:spring-boot-starter-cache")

配置CacheManager，在Configuration 配置類上增加EnableCache 注解；

配置CacheManager Bean，代碼為

    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
     ObjectMapper objectMapper = new ObjectMapper();
     objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
     objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
     jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

     RedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory);

     RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig();
     cacheConfiguration = cacheConfiguration.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer));
     cacheConfiguration.entryTtl(Duration.ofMinutes(10));
     CacheManager cacheManager = new RedisCacheManager(redisCacheWriter, cacheConfiguration);
     return cacheManager;

完成上述配置后，便可以在service中直接使用spring-cache注解，完整代碼: 代碼