caffeine_redis自定义二级缓存（hibernate redis二级缓存）这都可以

文章摘要

这篇文章介绍了在Spring Boot项目中使用Caffeine和Redis实现二级缓存的技术方案。文章的主要内容包括： 1. **需求背景**：由于项目需要进行数据同步，选择Caffeine+Redis作为本地缓存和Redis缓存的结合方案，以提高缓存效率和扩展性。 2. **核心问题**： - Caffeine缓存如何失效的问题：当一个节点的数据改变时，其他节点需要及时失效本地缓存。 - 数据一致性问题：如何保证本地缓存和其他节点缓存的数据一致性，避免因缓存失效导致数据不一致。 3. **解决方案**： - 使用Redis订阅和发布功能实现通知机制，当本地缓存失效时，自动触发其他节点的缓存失效处理。 - 通过自定义注解和CaffeineCache接口实现低耦合、可扩展的切面设计，便于维护和扩展。 4. **实现细节**： - 自定义注解`@CaffeineCache`定义了缓存的配置信息，如模块ID、方法ID、缓存名称和缓存管理器等。 - `CacheMessageListener`实现了Redis监听器的功能，能够监听本地缓存的变化，并通过Redis发布机制通知相关节点失效。 - 切面逻辑通过Redis发布消息到主题，触发其他节点的缓存失效处理流程。 5. **总结**：文章通过详细的技术实现，展示了如何使用Caffeine和Redis构建高效、可靠的二级缓存系统，解决了数据一致性问题，并实现了低耦合、高扩展的缓存设计。

目录背景问题流程图开发CacheConfig@CaffeineCacheCacheMessageListenerCaffeineCacheAspectCacheMessage总结

最近产品下发一个需求：考虑在程序中加缓存，刚开始以为只是 Redis 缓存，后面才直到是本地缓存（Caffeine） + Redis。

在 SpringBoot2.x 后默认的缓存就是 Caffeine，所以本地缓存也选择了 Caffeine。

ps：我们的数据不是从程序中插入或者更新，是每天会有数据专门同步。

基于提出的需求，我认为主要有以下两个问题：

因为有本地缓存，如何保证数据一致性。当一个节点数据改变，其他节点的数据如何失效？数据不对，需要重新同步，缓存如何失效？

接下来就是配合产品和其他开发人员画出流程图，如下：

使用一张配置表，记录是否需要缓存，是否开启缓存，来达到通知时候缓存失效的情况。因为项目要求一般，即使消息丢失，也不会存在太大的影响，所以最终选择了 redis 里面的订阅、发布功能，实现通知其他节点失效本地缓存。

上面问题清楚了，流程图也清楚了。那就准备开始写 bug 了。整体思路是自定义注解实现切面，尽量降低对业务代码的耦合度。

主要是结合业务定义一个 CacheManager，代码里面的解释都有。因为这个是直接占用程序内存的，所有得特别注意最大可缓存条数，别把内存肝爆了。当然也不能太小了，因为还要考虑命中率的问题。所以这就得结合实际得业务来确定最终的大小。

@Bean(name=JKDDCX)
@Primary
public CacheManager cacheManager() {
CaffeineCacheManager cacheManager=new CaffeineCacheManager();
cacheManager.setCaffeine(Caffeine.newBuilder()
// 设置最后一次写入或访问后经过固定时间过期
.expireAfterAccess(EXPIRE, TIME_UNIT)
//设置本地缓存写入后过期时间
.expireAfterWrite(EXPIRE, TIME_UNIT)
// 初始的缓存空间大小
.initialCapacity(500)
// 缓存的最大条数
.maximumSize(1000));// 使用人数 * 5 （每个人不同的入参 5 条）\
return cacheManager;
}

自定义注解，把可以用到的参数都能加上。

@Target({ ElementType.METHOD ,ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface CaffeineCache {

public String moudleId() default “”;

//用于在数据库中配置参数
public String methodId() default “”;
public String cachaName() default “”;

//动态切换实际的 CacheManager
public String cacheManager() default “”;

}

缓存监听器，主要是保证多节点数据一致性的问题。当一个节点缓存更新，通知其他的节点相应处理。主要技术是 Redis 的发布、订阅功能，实现 MessageListener 接口。

当然下面还有个细节就是一般生产环境是禁用 Redis#keys 命令的，所以得换个方式扫描对应的 key。

public class CacheMessageListener implements MessageListener {
@Override
public void onMessage(Message message, byte[] pattern) {
CacheMessage cacheMessage=(CacheMessage) redisTemplate.getValueSerializer().deserialize(message.getBody());
logger.info(“收到redis清除缓存消息, 开始清除本地缓存, the cacheName is {}, the key is {}”, cacheMessage.getCacheName(), cacheMessage.getKey());
// redisCaffeineCacheManager.clearLocal(cacheMessage.getCacheName(), cacheMessage.getKey());

String prefixKey=RedisConstant.WXYMG_DATA_CACHE + cacheMessage.getCacheName();
Set<String> keys=redisTemplate.execute((RedisCallback<Set<String>>) connection -> {
Set<String> keysTmp=new HashSet<>();
Cursor<byte[]> cursor=connection.scan(new ScanOptions.ScanOptionsBuilder().
match(prefixKey + “*”).
count(50).build());
while (cursor.hasNext()) {
keysTmp.add(new String(cursor.next()));
}
return keysTmp;
});
Iterator iterator=keys.iterator();
while (iterator.hasNext()) {
if (iterator.next().toString().equals(cacheMessage.getKey())) {
iterator.remove();
}
}
redisTemplate.delete(keys);

cacheConfig.cacheManager().getCache(cacheMessage.getCacheName()).clear(); //cacheName 下的都删除
}
}

然后就是切面的逻辑处理，里面的内容和流程图一模一样，只是使用代码实现了需求。

其中：下面的代码是 Redis 发布消息。

redisTemplate.convertAndSend(CacheConfig.TOPIC, new CacheMessage(caffeineCache.cachaName(), redisKey));

这是在 Redis 发布消息的时候一个消息体，也是自定义的，可以加更多的参数属性

public class CacheMessage implements Serializable {

private static final long serialVersionUID=-1L;

private String cacheName;

private Object key;

public CacheMessage(String cacheName, Object key) {
super();
this.cacheName=cacheName;
this.key=key;
}

}

Redis 天然适合分布式缓存，但是本地缓存还得考虑数据一致性的问题，这里使用的是 Redis 的发布、订阅功能Caffeine 的简单学习了解使用结合自定义注解，使用低耦合的二级缓存

到此这篇关于caffeine_redis自定义二级缓存的文章就介绍到这了,更多相关caffeine_redis二级缓存内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:基于Spring?Cache实现Caffeine+Redis二级缓存基于Spring接口集成Caffeine+Redis两级缓存SpringBoot+Mybatis项目使用Redis做Mybatis的二级缓存的方法redis与ssm整合方法（mybatis二级缓存）springboot+mybatis+redis 二级缓存问题实例详解详解Spring boot使用Redis集群替换mybatis二级缓存