原創(chuàng)-轉(zhuǎn)載請注明 http://tramp.cincout.cn/2017/10/31/spring-boot-2017-10-31-spring-boot-multi-cache-manager/

摘要

Spring Cache 為企業(yè)級級應用提供了類似于 Spring Transactional 的聲明式緩存抽象層。Spring 采用 AOP 的方式實現(xiàn)對多種底層緩存技術(shù)的適配。包括 REDIS碟狞、COUCHBASE力奋、EHCACHE 等矫夯。
當配置好 spring.cache.type=REDIS 時秘狞， Spring Boot 的自動裝配策略會自動的為我們配置好需要的底層緩存框架以及對應的CacheManager忍疾。這在大多數(shù)場景下是滿足需求的。
筆者在實際開發(fā)中遇到的場景是一些常量信息需要存儲到Redis中峰髓，利用Redis 的分布式緩存功能，使得多個節(jié)點可以共享該數(shù)據(jù)息尺；一些需要基于特定的緩存清理規(guī)則（采用LRU存儲最近最常使用的10000 條）的數(shù)據(jù)則需要采用EhCache 實現(xiàn)携兵。

原理

Spring Boot 的自動裝配

當引入 spring-boot-starter-data-redis 時，Spring Boot 會采用RedisAutoConfiguration 會我們配置好 Redis 的基礎(chǔ)配置信息搂誉。具體參見該類徐紧。在本項目中我們采用的時 EnCache 2.x, 因此需要我們單獨引入對應的依賴。
當引入 spring-boot-starter-cache炭懊，以及注解了@EnableCaching 時并级， Spring Boot 便會采用CacheAutoConfiguration 和 RedisCacheConfiguration 來進行自n一如多個動裝配。裝配的條件是缺少 CacheManager.class 實例 Bean侮腹。

因此嘲碧，當需要引入多個 CacheManager 的需要我們自己來分別配置。

實現(xiàn)

pom 依賴

需要引入的核心依賴如下父阻，具體的參見后文的源代碼鏈接：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<!-- https://mvnrepository.com/artifact/net.sf.ehcache/ehcache -->
<dependency>
    <groupId>net.sf.ehcache</groupId>
    <artifactId>ehcache</artifactId>
    <version>2.10.4</version>
</dependency>
<!-- https://mvnrepository.com/artifact/net.sf.ehcache/ehcache-core -->
<dependency>
    <groupId>net.sf.ehcache</groupId>
    <artifactId>ehcache-core</artifactId>
    <version>2.6.11</version>
</dependency>

application.properties

在application.properties 可以配置底層 Redis 數(shù)據(jù)源的相關(guān)信息：

spring.redis.host=cincout.cn
spring.redis.port=6379

配置 CacheManager

分別配置 RedisCacheManager 和 EhCacheCacheManager：

@Configuration
@EnableCaching
public class CacheConfig implements ApplicationRunner {

    @Resource
    private List<CacheManager> cacheManagers;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        System.out.println(cacheManagers.size());
    }

    @Bean(name = "redisCacheManager")
    public RedisCacheManager redisCacheManager(RedisTemplate<Object, Object> redisTemplate) {
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        RedisCacheManager redisCacheManager = new RedisCacheManager(redisTemplate);
        redisCacheManager.setCacheNames(Arrays.asList("user"));
        redisCacheManager.setUsePrefix(true);
        return redisCacheManager;
    }

    @Bean(name = "ehcache")
    public EhCacheManagerFactoryBean ehCacheManagerFactoryBean() {
        EhCacheManagerFactoryBean cacheBean = new EhCacheManagerFactoryBean();
        cacheBean.setConfigLocation(new ClassPathResource("ehcache.xml"));
        return cacheBean;
    }

    @Bean("ehCacheCacheManager")
    public EhCacheCacheManager ehCacheCacheManager(@Qualifier("ehcache") net.sf.ehcache.CacheManager ehcacheManager) {
        EhCacheCacheManager ehCacheCacheManager = new EhCacheCacheManager(ehcacheManager);
        return ehCacheCacheManager;
    }

    @Bean(name = "cacheManager")
    @Primary
    public CompositeCacheManager cacheManager(RedisCacheManager redisCacheManager, EhCacheCacheManager ehCacheCacheManager) {
        CompositeCacheManager cacheManager = new CompositeCacheManager(redisCacheManager, ehCacheCacheManager);
        return cacheManager;
    }
}

encache.xml 配置文件的內(nèi)容：

<?xml version="1.0" encoding="UTF-8"?>
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:noNamespaceSchemaLocation="http://ehcache.org/ehcache.xsd"
    updateCheck="false">
    <defaultCache eternal="false" maxElementsInMemory="1000"
        overflowToDisk="false" diskPersistent="false" timeToIdleSeconds="0"
        timeToLiveSeconds="600" memoryStoreEvictionPolicy="LRU" />

    <!--  200 * 10 := 2k per api metadata -->
    <cache name="api" maxElementsInMemory="10000" eternal="false"
        timeToIdleSeconds="0" timeToLiveSeconds="600" overflowToDisk="false"
        diskPersistent="false" diskExpiryThreadIntervalSeconds="120"
        memoryStoreEvictionPolicy="LRU">
    </cache>
</ehcache>

該文件定義了名字為api 的cache 的緩存策略愈涩。具體的參見Ehcache望抽。

業(yè)務(wù)中使用

在業(yè)務(wù)代碼中使用時為了區(qū)分不同的業(yè)務(wù)使用不同的CacheManager 有兩種方式實現(xiàn)。

• 在業(yè)務(wù)代碼中采用@CacheConfig, @CachePut, @Cacheable, @CacheEvict 來進行緩存的配置履婉。它們都擁有cacheManager 這個屬性煤篙。
  具體配置:

@Service
@CacheConfig(cacheManager = "ehCacheCacheManager")
public class ApiMetaServiceImpl implements ApiMetaService {
    private final static Logger LOG = LoggerFactory.getLogger(ApiMetaServiceImpl.class);

    @Override
    @CachePut(cacheNames = "api", key = "#api.id.toString()")
    public Api save(Api api) {
        LOG.info("save {}", api);
        return api;
    }

    @Override
    @Cacheable(cacheNames = "api", key = "#id.toString()")
    public Api get(Integer id) {
        LOG.info("get {}", id);
        return new Api(1, "x");
    }
}

@Service
@CacheConfig(cacheManager = "redisCacheManager")
public class UserServiceImpl implements UserService {
    private final static Logger LOG = LoggerFactory.getLogger(UserServiceImpl.class);

    @Override
    @CachePut(cacheNames = "user", key = "#user.id.toString()")
    public User save(User user) {
        LOG.info("saved user {}", user);
        return user;
    }

    @Override
    @CacheEvict(cacheNames = "user")
    public void delete(int id) {
        LOG.info("delete {}", id);
    }

    @Override
    @Cacheable(cacheNames = "user")
    public User get(int id) {
        LOG.info("get user {}", id);
        return new User(1, "zhang");
    }
}

• 采用CompositeCacheManager。 Spring Cache在 CacheManager 之下可以采用緩存名稱(cacheNames 屬性)來對緩存進行區(qū)分谐鼎。Spring Cache 提供了CompositeCacheManager 來對所有的 CacheManager 進行代理舰蟆。
  根據(jù)指定的cacheName 去遍歷所有的 CacheManager，查找對應的緩存狸棍。

RedisCacheManager指定CacheNames

redisCacheManager.setCacheNames(Arrays.asList("user"));
redisCacheManager.setUsePrefix(true);

同時需要在緩存相關(guān)的注解上配置 cacheNames 屬性身害。

EnCache

EnCache 直接在其配置文件中指明：

<cache name="api" maxElementsInMemory="10000" eternal="false"
        timeToIdleSeconds="0" timeToLiveSeconds="600" overflowToDisk="false"
        diskPersistent="false" diskExpiryThreadIntervalSeconds="120"
        memoryStoreEvictionPolicy="LRU">
</cache>

配置基于CompositeCacheManager 的CacheManager

@Bean(name = "cacheManager")
@Primary
public CompositeCacheManager cacheManager(RedisCacheManager redisCacheManager, EhCacheCacheManager ehCacheCacheManager) {
    CompositeCacheManager cacheManager = new CompositeCacheManager(redisCacheManager, ehCacheCacheManager);
    return cacheManager;
}

由于當前 Spring Context 中存在多個實現(xiàn)了 CacheManager.class 的 Bean，需要使用 @Primary 注解指定優(yōu)先選擇的 CacheManager草戈。

不然CacheAspectSupport.class 會拋出No CacheResolver specified, and no unique bean of type CacheManager found. Mark one as primary (or give it the name 'cacheManager') or declare a specific CacheManager to use, that serves as the default one. 的錯誤塌鸯。

業(yè)務(wù)代碼的配置

此時在業(yè)務(wù)代碼中就不需要配置 CacheManager：

@Service
@CacheConfig
public class UserServiceImpl implements UserService {
    private final static Logger LOG = LoggerFactory.getLogger(UserServiceImpl.class);

    @Override
    @CachePut(cacheNames = "user", key = "#user.id.toString()")
    public User save(User user) {
        LOG.info("saved user {}", user);
        return user;
    }

    @Override
    @CacheEvict(cacheNames = "user")
    public void delete(int id) {
        LOG.info("delete {}", id);
    }

    @Override
    @Cacheable(cacheNames = "user")
    public User get(int id) {
        LOG.info("get user {}", id);
        return new User(1, "zhang");
    }
}

源代碼

本工程源代碼可以從github 獲取。源代碼

總結(jié)

本文介紹了 Spring Cache 配置多種不同的 CacheManager 的具體實現(xiàn)方案唐片，在實際生產(chǎn)中可以直接使用丙猬。 在使用 Spring Boot 的自動裝配時，我們一定要搞清楚其底層的配置原理费韭。遇到默認的配置不能滿足時茧球，就需要我們閱讀文檔和源代碼來進行解決了。
本文沒有涉及到 Spring Cache 的具體使用星持，相關(guān)的內(nèi)容會在后續(xù)推出抢埋。

參考

1. Spring Reference
2. Spring Boot Reference
3. Ehcache