Redis+Caffeine多级缓存数据一致性解决方案

	/**
     * 配置订阅，用于解决Caffeine一致性的问题
     *
     * @param connectionFactory 链接工厂
     * @param listenerAdapter 消息监听器
     * @return 消息监听容器
     */
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                                   MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, new ChannelTopic(CHANNEL_TOPIC));
        return container;
    }

/**
 * redis消息监听，解决Caffeine一致性的问题
 */
@Slf4j
@Component
public class RedisMessageListener extends MessageListenerAdapter {

    @Resource
    private Cache<String, TransportInfoDTO> transportInfoCache;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 获取到消息中的运单id
        String transportOrderId = Convert.toStr(message);
        log.info("redis消息监听缓存变更，运单id:{}", transportOrderId);
        // 将本jvm中的缓存删除掉
        this.transportInfoCache.invalidate(transportOrderId);
    }
}

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @Override
    @CachePut(value = "transport-info", key = "#p0")
    public TransportInfoEntity saveOrUpdate(String transportOrderId, TransportInfoDetail infoDetail) {
		// 省略代码
 
        // 清除缓存中的数据
        // this.transportInfoCache.invalidate(transportOrderId);
        // Caffeine本地缓存一致性，发布订阅消息到redis，通知订阅者更新缓存
        this.stringRedisTemplate.convertAndSend(RedisConfig.CHANNEL_TOPIC, transportOrderId);
        // 保存/更新到MongoDB
        return this.mongoTemplate.save(transportInfoEntity);
    }