springboot整合redis(注解形式)

准備工作

springboot通常整合redis,采用的是RedisTemplate的形式,除了這種形式以外,還有另外一種形式去整合,即采用spring支持的注解進行訪問緩存.

• pom.xml

  <dependency>
              <groupId>redis.clients</groupId>
              <artifactId>jedis</artifactId>
              <version>2.7.3</version>
          </dependency>
          <dependency>
              <groupId>org.springframework.data</groupId>
              <artifactId>spring-data-redis</artifactId>
              <version>1.7.2.RELEASE</version>
          </dependency>
          <dependency>
              <groupId>org.springframework.boot</groupId>
              <artifactId>spring-boot-starter-redis</artifactId>
              <version>RELEASE</version>
    </dependency>

• application.properties

  # REDIS (RedisProperties)
  # Redis數據庫索引（默認為0）
  spring.redis.database=0
  # Redis服務器地址
  spring.redis.host=127.0.0.1
  # Redis服務器連接端口
  spring.redis.port=6379
  # 連接池最大連接數（使用負值表示沒有限制）
  spring.redis.pool.max-active=8
  # 連接池最大阻塞等待時間（使用負值表示沒有限制）
  spring.redis.pool.max-wait=-1
  # 連接池中的最大空閑連接
  spring.redis.pool.max-idle=8
  # 連接池中的最小空閑連接
  spring.redis.pool.min-idle=0
  # 連接超時時間（毫秒）
  spring.redis.timeout=0
  

  Redis配置類

  /**
   * @author hulonghai
   * redis配置類
   */
  @Configuration
  @EnableCaching
  public class CacheConfig extends CachingConfigurerSupport{
  
      @SuppressWarnings("rawtypes")
      @Bean
      public CacheManager cacheManager(RedisTemplate redisTemplate) {
          RedisCacheManager rcm = new RedisCacheManager(redisTemplate);
          // 多個緩存的名稱,目前只定義了一個
          rcm.setCacheNames(Arrays.asList("thisredis"));
          //設置緩存過期時間(秒)
          rcm.setDefaultExpiration(600);
          return rcm;
      }
  
      @Bean
      public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {
          StringRedisTemplate template = new StringRedisTemplate(factory);
          Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
          ObjectMapper om = new ObjectMapper();
          om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
          om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
          jackson2JsonRedisSerializer.setObjectMapper(om);
          template.setValueSerializer(jackson2JsonRedisSerializer);
          template.afterPropertiesSet();
          return template;
      }
  
  }
  

  可以看出,我們這里主要配置了兩個東西,cacheManager方法配置了一個緩存名稱,它的名字叫做thisredis,當我們要在方法注解里面使用到它的時候,就要根據名稱進行區分不同緩存.同時設置了緩
  存的過期時間.redisTemplate則是比較常見的,我們設置了RedisTemplate,因此在代碼里面,我們也可以通過@Autowired注入RedisTemplate來操作redis.

• 使用

　　接下來就是如何使用注解啦,這一步反而是最簡單的.其實只用到了兩個注解,@Cacheable和@CacheEvict.第一個注解代表從緩存中查詢指定的key,如果有,從緩存中取,不再執行方法.如果沒有則執
行方法,並且將方法的返回值和指定的key關聯起來,放入到緩存中.而@CacheEvict則是從緩存中清除指定的key對應的數據.使用的代碼如下:

@Cacheable(value="thisredis", key="'users_'+#id")
    public User findUser(Integer id) {
        User user = new User();
        user.setUsername("hlhdidi");
        user.setPassword("123");
        user.setUid(id.longValue());
        System.out.println("log4j2壞啦?");
        logger.info("輸入user,用戶名:{},密碼:{}",user.getUsername(),user.getPassword());
        return user;
    }

    @CacheEvict(value="thisredis", key="'users_'+#id",condition="#id!=1")
    public void delUser(Integer id) {
        // 刪除user
        System.out.println("user刪除");
    }

　　可以看出,我們用@Cacheable的value屬性指定具體緩存,並通過key將其放入緩存中.這里key非常靈活,支持spring的el表達式,可以通過方法參數產生可變的key(見findUser方法),也可以通過其指定在
什么情況下,使用/不使用緩存(見delUser方法).