/**
     * 配置訂閱，用于解決Caffeine一致性的問題
     *
     * @param connectionFactory 鏈接工廠
     * @param listenerAdapter 消息監(jiān)聽器
     * @return 消息監(jiān)聽容器
     */
    @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消息監(jiān)聽，解決Caffeine一致性的問題
 */
@Slf4j
@Component
public class RedisMessageListener extends MessageListenerAdapter {

    @Resource
    private Cache<String, TransportInfoDTO> transportInfoCache;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 獲取到消息中的運(yùn)單id
        String transportOrderId = Convert.toStr(message);
        log.info("redis消息監(jiān)聽緩存變更，運(yùn)單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) {
		// 省略代碼
 
        // 清除緩存中的數(shù)據(jù)
        // this.transportInfoCache.invalidate(transportOrderId);
        // Caffeine本地緩存一致性，發(fā)布訂閱消息到redis，通知訂閱者更新緩存
        this.stringRedisTemplate.convertAndSend(RedisConfig.CHANNEL_TOPIC, transportOrderId);
        // 保存/更新到MongoDB
        return this.mongoTemplate.save(transportInfoEntity);
    }