SpringBoot 整合redis實現緩存 記錄@CachePut值爲1

一：先新增redis配置

 1 #redis
 2 spring.cache.type=REDIS
 3 spring.redis.database=0
 4 spring.redis.host=127.0.0.1
 5 pring.redis.password=
 6 spring.redis.port=6379
 7 spring.redis.pool.max-idle=8
 8 spring.redis.pool.min-idle=0  
 9 spring.redis.pool.max-active=100 
10 spring.redis.pool.max-wait=-1
11 #redis

二：添加redis的配置類

package com.gh.redis;


import java.lang.reflect.Method;

import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
    /*定義緩存數據 key 生成策略的bean
    包名+類名+方法名+全部參數
    */
    @Bean
    public KeyGenerator wiselyKeyGenerator(){
        return new KeyGenerator() {
            @Override
            public Object generate(Object target, Method method, Object... params) {
                StringBuilder sb = new StringBuilder();
                sb.append(target.getClass().getName());
                sb.append(method.getName());
                for (Object obj : params) {
                    sb.append(obj.toString());
                }
                return sb.toString();
            }
        };
 
    }
 
    /*要啓用spring緩存支持,需建立一個 CacheManager的 bean，CacheManager 接口有不少實現，這裏Redis 的集成，用 RedisCacheManager這個實現類
    Redis 不是應用的共享內存，它只是一個內存服務器，就像 MySql 似的，
    咱們須要將應用鏈接到它並使用某種「語言」進行交互，所以咱們還須要一個鏈接工廠以及一個 Spring 和 Redis 對話要用的 RedisTemplate，
    這些都是 Redis 緩存所必需的配置，把它們都放在自定義的 CachingConfigurerSupport 中
     */
    @Bean
    public CacheManager cacheManager(
            @SuppressWarnings("rawtypes") RedisTemplate redisTemplate) {
        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
//        cacheManager.setDefaultExpiration(60);//設置緩存保留時間（seconds）
        return cacheManager;
    }
 
    //1.項目啓動時此方法先被註冊成bean被spring管理
    @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;
    }
}

三：redis的三個經常使用註解 @Cacheable  @CacheEvict  @CachePut

　　1：@Cacheable：當重複使用相同參數調用方法的時候，方法自己不會被調用執行，即方法自己被略過了，取而代之的是方法的結果直接從緩存中找到並返回了。

　　實驗：在業務邏輯實現方法上加上次註解

　　其中value指的是要放在哪個數據緩存裏面

　　　　key指的就是一個鍵

    @Override
    @Cacheable(value="db0",key="T(String).valueOf(#userid)")//把userid轉換爲string類型的
    public List<GhTest> getGhTestByID(int userid) {
        // TODO Auto-generated method stub
        System.out.println("aaaaaaa");
        return dao.getGhTestByID(userid);
    }

 　　對接口進行測試

　　　執行第一次控制檯輸出aaaaa　　　　　　　　redis裏面新建一個鍵值對

 　　

　　再次測試，則再也不輸出aaaaa 說明數據是在緩存中所取。運行的步驟其實也就是，當@Cacheable接收到key value的時候先在value中找是否是存在key，若是不存在則在value中新建key 數據值爲這個方法的返回值。若是存在則方法不執行從緩存中讀取值。

 

　　2：@CacheEvict

　　

1 @Override
2     @CacheEvict(value = "db0", key ="T(String).valueOf(#userid)")
3     public int deleteTest(int userid) {
4         // TODO Auto-generated method stub
5         return dao.deleteTest(userid);
6     }

 

　　使用接口測試發現，會刪除掉數據庫和緩存裏面的值。能夠在@CacheEvict 裏面添加condition 表達式，讓其知足什麼條件的時候才刪除緩存。

 

　　3：@CachePut

　　在測試這個修改的時候我遇到了問題，那就是咱們日常寫的修改和添加返回值通常都是int類型的，也就倒置了緩存裏面存的值都是添加或者是修改的行數，並非真實的數據。

　　例如，

1     @Override
2     @CachePut(value = "db0", key ="T(String).valueOf(#test.userid)")
3     public int updateTest(GhTest test) {
4         // TODO Auto-generated method stub
5         return dao.updateTest(test);
6     }

 

 　測試新增一條記錄，userid爲20，查看發現redis緩存裏面是1，而不是userid爲20的數據記錄

 

　　

　　上面也說了，redis裏面存的值，是方法的返回值，咱們方法的返回值是int，是被影響的行數。因此會存進去1，那要對方法進行修改。

　　解決方案就是，新建方法，把新增或者修改和查詢結合這使用。

 1 @Override
 2     @CachePut(value = "db0", key ="T(String).valueOf(#test.userid)")
 3     public List<GhTest> insertTest2(GhTest test) {
 4         // TODO Auto-generated method stub
 5         insertTest(test);
 6         List<GhTest> list=getGhTestByID(test.getUserid());
 7         return list;
 8     }
 9     @Override
10     @CachePut(value = "db0", key ="T(String).valueOf(#test.userid)")
11     public List<GhTest> updateTest2(GhTest test) {
12         // TODO Auto-generated method stub
13         updateTest(test);
14         List<GhTest> list=getGhTestByID(test.getUserid());
15         return list;
16     }

 

　　再次進行測試，先對20那條記錄進行修改，在進行id查詢，若是不經過數據庫查詢就說明成功了。

　　發現緩存中的值已經被修改，並且根據id查詢也是經過緩存查詢。