新增配置資訊

(1).config/config.properties檔案中新增

1. #快取預設有效期1h (60 * 60 = 3600秒)
2. redis.expiration=3600
3. #最大空閒數，資料庫連線的最大空閒時間。超過空閒時間，資料庫連線將被標記為不可用，然後被釋放。設為0表示無限制。
4. redis.maxIdle=300
5. #連線池的最大資料庫連線數。設為0表示無限制。
6. #Redis預設允許客戶端連線的最大數量是10000。若是看到連線數超過5000以上，那可能會影響Redis的效能。倘若一些或大部分客戶端傳送大量的命令過來，這個數字會低的多。
7. redis.maxActive=5000
8. #最大建立連線等待時間。如果超過此時間將接到異常。設為-1表示無限制。
9. redis.maxWait=-1
10. #申請連線時檢測連線是否有效，配置true會降低效能，但是可以檢測連結有效性，預設false
11. redis.testOnBorrow=true
12. #返回前會先校驗這個連結有效性，如果無效會被銷燬，預設值false
13. redis.testOnReturn=true
14. redis.database=0
15. #快取時間範圍
16. cache.cacheTime=300,400
17. #同步等待時間
18. cache.syncWaitTime=300
19. #空值快取時間
20. cache.nullCacheTime=60

(2).config資料夾下新增spring-data-redis.xml配置

1. <?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans"
3.  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
4.  xmlns:context="http://www.springframework.org/schema/context"
5.  xmlns:cache="http://www.springframework.org/schema/cache"
6.  xsi:schemaLocation="http://www.springframework.org/schema/beans
7. http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
8. http://www.springframework.org/schema/context
9. http://www.springframework.org/schema/context/spring-context-4.3.xsd
10. http://www.springframework.org/schema/cache
11. http://www.springframework.org/schema/cache/spring-cache-4.3.xsd">
12.  <description>Jedis Configuration</description>
13.  <!-- 載入配置屬性檔案 -->
14.  <context:property-placeholder ignore-unresolvable="true" location="classpath:config/config.properties"/>
15.  <!-- ******************** redis快取 **********************-->
16.  <!-- 啟用快取註解功能,否則註解不會生效 -->
17.  <cache:annotation-driven cache-manager="cacheManager" />
18.  <!-- redis 相關配置 -->
19.  <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
20.  <property name="maxIdle" value="${redis.maxIdle}" />
21.  <property name="maxWaitMillis" value="${redis.maxWait}" />
22.  <property name="testOnBorrow" value="${redis.testOnBorrow}" />
23.  <property name="testOnReturn" value="${redis.testOnReturn}" />
24.  </bean>
25.  <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
26.  p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.password}"
27.  p:database="${redis.database}" p:timeout="${redis.timeout}"
28.  p:pool-config-ref="poolConfig" />
29.  <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
30.  <property name="connectionFactory" ref="jedisConnectionFactory" />
31.  <!--對key的序列化器 -->
32.  <property name="keySerializer">
33.  <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
34.  </property>
35.  <!--是對value的列化器 預設:JdkSerializationRedisSerializer -->
36.  <property name="valueSerializer">
37.  <bean class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer" />
38.  </property>
39.  </bean>
40.  <!-- 擴充套件RedisCacheManager -->
41.  <bean id="cacheManager" class="com.we.core.web.cache.TFRedisCacheManager">
42.  <constructor-arg ref="redisTemplate" />
43.  <!-- 是否使用字首 預設: -->
44.  <!--<property name="usePrefix" value="true" />-->
45.  <!-- 預設有效期1h (60 * 60 = 3600秒) -->
46.  <property name="defaultExpiration" value="${redis.expiration}" />
47.  </bean>
48.  <!-- ******************** redis快取 **********************-->
49. </beans>

(3).config/spring-context.xml中新增

1. <import resource="spring-data-redis.xml" />

註解使用

概況

基於註解的快取宣告，需要掌握的有：@Cacheable、@CachePut 、 @CacheEvict 和@Caching

以下列舉了幾種常用的使用屬性，詳情可自行查閱

1. @Cacheable(value="",condition="",key="",unless="")
2.  public @interface Cacheable{ 
3.  String[] value(); //快取的名字，可以把資料寫到多個快取,我們擴充套件了屬性：area#60*10, area是value，60*10是快取時間（單位秒），不加走預設（1h）
4.  String key() default ""; //快取key，如果不指定將使用預設的KeyGenerator生成，後邊介紹
5.  String condition() default ""; //滿足快取條件的資料才會放入快取，condition在呼叫方法之前和之後都會判斷
6.  String unless() default ""; //用於否決快取更新的，不像condition，該表達只在方法執行之後判斷，此時可以拿到返回值result進行判斷了
7.  String keyGenerator() default ""; //指定key規則
8. } 
9. @CachePut(value="",condition="",key="",unless="")
10.  public @interface CachePut { 
11.  String[] value(); //快取的名字，可以把資料寫到多個快取
12.  String key() default ""; //快取key，如果不指定將使用預設的KeyGenerator生成，後邊介紹
13.  String condition() default ""; //滿足快取條件的資料才會放入快取，condition在呼叫方法之前和之後都會判斷
14.  String unless() default ""; //用於否決快取更新的，不像condition，該表達只在方法執行之後判斷，此時可以拿到返回值result進行判斷了
15. } 
16. @Cacheable(value="",condition="",key="",unless="")
17.  public @interface CacheEvict { 
18.  String[] value(); //快取的名字，可以把資料寫到多個快取
19.  String key() default ""; //快取key，如果不指定將使用預設的KeyGenerator生成，後邊介紹
20.  String condition() default ""; //滿足快取條件的資料才會放入快取，condition在呼叫方法之前和之後都會判斷
21.  boolean allEntries() default false; //是否移除所有資料
22.  boolean beforeInvocation() default false;//是呼叫方法之前移除/還是呼叫之後移除
23. @Caching(value="",condition="",key="",unless="")
24. public @interface Caching {
25.  Cacheable[] cacheable() default {}; //從快取獲取多個，如果沒有則執行方法體，獲取值後加入快取
26.  CachePut[] put() default {}; //快取多個
27.  CacheEvict[] evict() default {}; //從快取移除多個
28. }

@Cacheable

較常用，用在查詢方法上，先從快取中讀取，如果快取不存在再呼叫該方法獲取資料，然後把返回的資料新增到快取中去

正如其名字，@Cacheable用於新增在需快取記憶體的方法上。這些方法預設會以引數為主鍵把返回結果儲存到快取記憶體中，以便在隨後的呼叫（使用相同的引數）方法，直接返回快取記憶體中的值，不需要實際執行此方法。

• 最簡單的方式，只需要宣告一個相關快取策略的名稱

  1. @Cacheable("area#60*10")
  2. public Book getAreaVersion4(String code) {...}

• 也可以設定多個緩衝塊，其中一個緩衝塊命中即會返回，並會同步其他快取塊：

  1. @Cacheable(value = {"area#60*10","city#60*30"})
  2. public Book getAreaVersion4(String code) {...}

• 定製key，且加同步

  1. @Cacheable(value = {"area#60*10"}, key = "'code:'+#code",sync = true)
  2.  public AreaDto getAreaVersion4(String code) {
  3.  return areaBaseService.get (code);
  4.  }

• 定製key，且加同步，加條件

  1. @Cacheable(value = {"area#60*10"}, key = "'code:'+#code",sync = true, condition = "#code=='100000'")
  2.  public AreaDto getAreaVersion4(String code) {
  3.  return areaBaseService.get (code);
  4.  }

@CacheEvict

主要對方法配置，用來標記要清空快取的方法，當這個方法被呼叫並滿足一定條件後，即會清空快取。

• 引數解析：

value：快取的位置，不能為空。
key：快取的key，預設為空。
condition：觸發的條件，只有滿足條件的情況才會清楚快取，預設為空，支援SpEL。
allEntries：true表示清除value中的全部快取，預設為false。

1. /**
2. * 情況area#60*10下所有快取
3. */
4. @CacheEvict(value = {"area#60*10"}, key = "'code:'+#code", condition = "#code=='100000'")
5.  public AreaDto delete(String code) {
6.  return areaBaseService.delete (code);
7.  }

1.  /**
2. * 只要執行了delArea2方法，就重新整理快取名為”getAreaVersion4”下面的所有快取
3. */
4.  @Caching(evict = {@CacheEvict(value = {"getAreaVersion4#60*5"}, allEntries = true)})
5.  public void delArea2() {
6.  }

@CachePut

主要針對方法的配置，能夠根據方法的請求引數對其結果進行快取，和@Cacheable不同的是，它每次都會觸發真實方法的呼叫。

1. @CachePut(value = {"area#60*10"}, key = "'code:'+#code",sync = true, condition = "#code=='100000'")
2.  public AreaDto getAreaVersion4(String code) {
3.  return areaBaseService.get (code);
4.  }

其他自行查閱

1. spring-data-redis

自定義快取註解

1.更新專案包

• we-core-web

2.新增預設配置

• 在apollo中新增 或者 在config/config.properties中新增

  優先順序順序：1、apollo；2、配置檔案；

  1. #快取時間範圍
  2. cache.cacheTime=300,400
  3. #同步等待時間
  4. cache.syncWaitTime=3
  5. #空值快取時間
  6. cache.nullCacheTime=60

3.應用

• 使用demo

  1.  /**
  2. * 目標方法
  3. * <p&
  4. * 支援限流
  5. * 支援穿透
  6. * 支援非同步處理
  7. * </p&
  8. *
  9. * @param code
  10. * @return
  11. */
  12.  @TFCacheable(groupName = CACHE_GROUP_NAME, cacheTime = {300, 400}, syncWaitTime = 300)
  13.  public AreaDto getXXX(String code) {
  14.  return xxxBaseService.get (code);
  15.  }

註解介紹

1.  /**
2. * 分組名
3. */
4.  String groupName() default "";
5.  /**
6. * 快取的時間範圍
7. * <br/&
8. * 過期時間，單位為秒
9. *
10. * <p&
11. * 格式：minTime-maxTime,如：60-120
12. * </p&
13. */
14.  int[] cacheTime() default 0;
15.  /**
16. * 是否同步
17. * 同步排隊時間：{@link #syncWaitTime}.
18. * <p&
19. * 細粒度同步鎖，鎖定級別：引數級別
20. * </p&
21. * @see #syncWaitTime
22. */
23.  boolean sync() default true;
24.  /**
25. * 同步等待時間
26. * <br/&
27. * 過期時間，單位為秒
28. *
29. * <p&
30. * 過期時間，單位為秒
31. * 如果開啟同步，預設排隊時間，超過後，拋超時異常
32. * </p&
33. * @see #sync
34. */
35.  int syncWaitTime() default 0;
36.  /**
37. * 空值快取時間
38. *
39. * <p&
40. * 空值會快取短暫的時間，防止方法請求不斷請求資料庫，減少穿透機率
41. * </p&
42. */
43.  int nullCacheTime() default 0

@Cacheable(value = "ActivityScopeRedis#60*60",key = "#root.methodName + #activityId")
    public List<ActivityScopeDto> findByActivityId(long activityId) {
        return activityScopeBaseDao.findByActivityId(activityId);
    }

&n