Spring如何結(jié)合Redis數(shù)據(jù)庫實現(xiàn)緩存

這篇文章將為大家詳細(xì)講解有關(guān) Spring 如何結(jié)合redis數(shù)據(jù)庫實現(xiàn)緩存，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。

為柳河等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù)，及柳河網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都做網(wǎng)站、網(wǎng)站建設(shè)、柳河網(wǎng)站設(shè)計，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會得到認(rèn)可，從而選擇與我們長期合作。這樣，我們也可以走得更遠(yuǎn)！

1. 依賴包安裝

pom.xml 加入：

 
 
 org.springframework.data 
 spring-data-redis 
 1.6.0.RELEASE 
 
 
 redis.clients 
 jedis 
 2.7.3

2. Spring 項目集成進緩存支持

要啟用緩存支持，我們需要創(chuàng)建一個新的 CacheManager bean。CacheManager 接口有很多實現(xiàn)，本文演示的是和 Redis 的集成，自然就是用 RedisCacheManager 了。Redis 不是應(yīng)用的共享內(nèi)存，它只是一個內(nèi)存服務(wù)器，就像 MySQL 似的，我們需要將應(yīng)用連接到它并使用某種“語言”進行交互，因此我們還需要一個連接工廠以及一個 Spring 和 Redis 對話要用的 RedisTemplate，這些都是 Redis 緩存所必需的配置，把它們都放在自定義的 CachingConfigurerSupport 中：

/** 
 * File Name：RedisCacheConfig.java 
 * 
 * Copyright Defonds Corporation 2015 
 * All Rights Reserved 
 * 
 */ 
package com.defonds.bdp.cache.redis; 
 
import org.springframework.cache.CacheManager; 
import org.springframework.cache.annotation.CachingConfigurerSupport; 
import org.springframework.cache.annotation.EnableCaching; 
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.connection.jedis.JedisConnectionFactory; 
import org.springframework.data.redis.core.RedisTemplate; 
 
/** 
 * 
 * Project Name：bdp 
 * Type Name：RedisCacheConfig 
 * Type Description： 
 * Author：Defonds 
 * Create Date：2015-09-21 
 * 
 * @version 
 * 
 */ 
@Configuration 
@EnableCaching 
public class RedisCacheConfig extends CachingConfigurerSupport { 
 
 @Bean 
 public JedisConnectionFactory redisConnectionFactory() { 
  JedisConnectionFactory redisConnectionFactory = new JedisConnectionFactory(); 
 
  // Defaults 
  redisConnectionFactory.setHostName("192.168.1.166"); 
  redisConnectionFactory.setPort(6379); 
  return redisConnectionFactory; 
 } 
 
 @Bean 
 public RedisTemplate redisTemplate(RedisConnectionFactory cf) { 
  RedisTemplate redisTemplate = new RedisTemplate(); 
  redisTemplate.setConnectionFactory(cf); 
  return redisTemplate; 
 } 
 
 @Bean 
 public CacheManager cacheManager(RedisTemplate redisTemplate) { 
  RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate); 
 
  // Number of seconds before expiration. Defaults to unlimited (0) 
  cacheManager.setDefaultExpiration(3000); // Sets the default expire time (in seconds) 
  return cacheManager; 
 } 
  
}

當(dāng)然也別忘了把這些 bean 注入 Spring，不然配置無效。在 applicationContext.xml 中加入以下：

3. 緩存某些方法的執(zhí)行結(jié)果

設(shè)置好緩存配置之后我們就可以使用 @Cacheable 注解來緩存方法執(zhí)行的結(jié)果了，比如根據(jù)省份名檢索城市的 provinceCities 方法和根據(jù) city_code 檢索城市的 searchCity 方法：

// R 
@Cacheable("provinceCities") 
public List provinceCities(String province) { 
 logger.debug("province=" + province); 
 return this.cityMapper.provinceCities(province); 
} 
 
// R 
@Cacheable("searchCity") 
public City searchCity(String city_code){ 
 logger.debug("city_code=" + city_code); 
 return this.cityMapper.searchCity(city_code);  
}

4. 緩存數(shù)據(jù)一致性保證

CRUD (Create 創(chuàng)建，Retrieve 讀取，Update 更新，Delete 刪除) 操作中，除了 R 具備冪等性，其他三個發(fā)生的時候都可能會造成緩存結(jié)果和數(shù)據(jù)庫不一致。為了保證緩存數(shù)據(jù)的一致性，在進行 CUD 操作的時候我們需要對可能影響到的緩存進行更新或者清除。

// C 
@CacheEvict(value = { "provinceCities"}, allEntries = true) 
public void insertCity(String city_code, String city_jb, 
  String province_code, String city_name, 
  String city, String province) { 
 City cityBean = new City(); 
 cityBean.setCityCode(city_code); 
 cityBean.setCityJb(city_jb); 
 cityBean.setProvinceCode(province_code); 
 cityBean.setCityName(city_name); 
 cityBean.setCity(city); 
 cityBean.setProvince(province); 
 this.cityMapper.insertCity(cityBean); 
} 
// U 
@CacheEvict(value = { "provinceCities", "searchCity" }, allEntries = true) 
public int renameCity(String city_code, String city_name) { 
 City city = new City(); 
 city.setCityCode(city_code); 
 city.setCityName(city_name); 
 this.cityMapper.renameCity(city); 
 return 1; 
} 
 
// D 
@CacheEvict(value = { "provinceCities", "searchCity" }, allEntries = true) 
public int deleteCity(String city_code) { 
 this.cityMapper.deleteCity(city_code); 
 return 1; 
}

業(yè)務(wù)考慮，本示例用的都是 @CacheEvict 清除緩存。如果你的 CUD 能夠返回 City 實例，也可以使用 @CachePut 更新緩存策略。筆者推薦能用 @CachePut 的地方就不要用 @CacheEvict，因為后者將所有相關(guān)方法的緩存都清理掉，比如上面三個方法中的任意一個被調(diào)用了的話，provinceCities 方法的所有緩存將被清除。

5. 自定義緩存數(shù)據(jù) key 生成策略

對于使用 @Cacheable 注解的方法，每個緩存的 key 生成策略默認(rèn)使用的是參數(shù)名+參數(shù)值，比如以下方法：

@Cacheable("users") 
public User findByUsername(String username)

這個方法的緩存將保存于 key 為 users~keys 的緩存下，對于 username 取值為 "趙德芳" 的緩存，key 為 "username-趙德芳"。一般情況下沒啥問題，二般情況如方法 key 取值相等然后參數(shù)名也一樣的時候就出問題了，如：

@Cacheable("users") 
public Integer getLoginCountByUsername(String username)

這個方法的緩存也將保存于 key 為 users~keys 的緩存下。對于 username 取值為 "趙德芳" 的緩存，key 也為 "username-趙德芳"，將另外一個方法的緩存覆蓋掉。

解決辦法是使用自定義緩存策略，對于同一業(yè)務(wù)(同一業(yè)務(wù)邏輯處理的方法，哪怕是集群/分布式系統(tǒng))，生成的 key 始終一致，對于不同業(yè)務(wù)則不一致：

@Bean 
public KeyGenerator customKeyGenerator() { 
 return new KeyGenerator() { 
  @Override 
  public Object generate(Object o, Method method, Object... objects) { 
   StringBuilder sb = new StringBuilder(); 
   sb.append(o.getClass().getName()); 
   sb.append(method.getName()); 
   for (Object obj : objects) { 
    sb.append(obj.toString()); 
   } 
   return sb.toString(); 
  } 
 }; 
}

于是上述兩個方法，對于 username 取值為 "趙德芳" 的緩存，雖然都還是存放在 key 為 users~keys 的緩存下，但由于 key 分別為 "類名-findByUsername-username-趙德芳" 和 "類名-getLoginCountByUsername-username-趙德芳"，所以也不會有問題。
這對于集群系統(tǒng)、分布式系統(tǒng)之間共享緩存很重要，真正實現(xiàn)了分布式緩存。

筆者建議：緩存方法的 @Cacheable 最好使用方法名，避免不同的方法的 @Cacheable 值一致，然后再配以以上緩存策略。

6. 緩存的驗證

6.1 緩存的驗證

為了確定每個緩存方法到底有沒有走緩存，我們打開了 MyBatis 的 SQL 日志輸出，并且為了演示清楚，我們還清空了測試用 Redis 數(shù)據(jù)庫。

先來驗證 provinceCities 方法緩存，Eclipse 啟動 tomcat 加載項目完畢，使用 JMeter 調(diào)用 /bdp/city/province/cities.json 接口：