一、前言
- 近期被刷接口了，考虑增加 本地缓存提高性能，另配置 限流
- 使用 spring-cache 注解式缓存，可以提高使用缓存的开发效率
- 不同业务，可以定制 自己的缓存策略，是基本需求
- 多模块项目，最好在 统一的模块(如 common) 加载缓存配置
二、方案
1. 配置缓存：接口 + 枚举 + Lombok
缓存配置接口：
1
2
3
4
5
|
public interface ICacheConfig {
Integer getTtl();
}
|
common模块缓存配置(使用 Lombok 的 FieldNameConstants 自动生成 常量)：
1
2
3
4
5
6
7
8
9
10
|
@lombok.Getter
@lombok.AllArgsConstructor
@lombok.experimental.FieldNameConstants(onlyExplicitlyIncluded = true)
public enum CommonCacheConfig implements ICacheConfig {
@FieldNameConstants.Include QUOTE_LEVEL(1000, 2);
private final Integer ttl;
}
|
业务模块缓存配置：
1
2
3
4
5
6
7
8
9
10
|
@lombok.Getter
@lombok.AllArgsConstructor
@lombok.experimental.FieldNameConstants(onlyExplicitlyIncluded = true)
public enum QuoteServiceCacheConfig implements ICacheConfig {
@FieldNameConstants.Include HOT_STOCK(1000, 30);
private final Integer ttl;
}
|
2. 多模块配置加载：Reflections + SimpleCacheManager
- 通过 Reflections 库加载多模块配置
- SimpleCacheManager 组合 各种不同配置的 缓存
1
2
3
4
5
6
7
8
9
10
|
@EnableCaching
@Configuration
public class CacheConfig {
private Logger log = LoggerFactory.getLogger(this.getClass());
@Bean
@Primary
public CacheManager cacheManager() {
final SimpleCacheManager cacheManager = new SimpleCacheManager();
final String prefix = "package";
|
1
2
3
4
5
6
7
8
9
10
|
Set<Class<? extends ICacheConfig>> classes = new Reflections(prefix).getSubTypesOf(ICacheConfig.class);
log.info("cache types|{}|{}", prefix, classes);
List<Cache> caches = classes.stream().flatMap(clazz -> Arrays.stream(clazz.getEnumConstants())).map(config -> {
final Caffeine<Object, Object> cache = Caffeine.newBuilder().recordStats();
Optional.ofNullable(config.getTtl()).ifPresent(t -> cache.expireAfterWrite(t, TimeUnit.SECONDS));
return new CaffeineCache(((Enum) config).name(), cache.build());
}).collect(Collectors.toList());
cacheManager.setCaches(caches);
return cacheManager;
}
|
3. 使用缓存
- 使用 @Cacheable(cacheNames = CommonCacheConfig.Fields.QUOTE_LEVEL, sync = true) 操作缓存
- 使用 Lombok 的 FieldNameConstants 自动生成的 常量：
1
2
3
4
5
6
7
|
public enum CommonCacheConfig implements ICacheConfig {
public static final class Fields {
public static final String QUOTE_LEVEL = "QUOTE_LEVEL";
}
}
|
三、总结
- 通过 接口 + 枚举，业务模块不用改common模块， 新增枚举 就能 方便的配置、使用缓存，符合 开闭原则
- 通过 Lombok 的 FieldNameConstants 自动生成 枚举名称常量，便于代码 导航、重构
- 通过 Reflections 库，common模块自动加载 各模块的缓存配置，SimpleCacheManager 组合 各种不同配置的 缓存(CaffeineCacheManager 不能)，降低使用成本，提高可维护性
- sync = true，加锁，只有一个线程去加载数据，其他线程阻塞，防止 缓存击穿
- alibaba/jetcache：支持 注解上指定过期时间等配置、两级缓存、自动刷新和加载保护 等
- netease-im/camellia：网易开源，有意思的是 支持基于注解执行mget，mevict等批量操作
本文首先发布于 https://www.890808.xyz/ ，其他平台需要审核更新慢一些。
javalover123
收录于 Java