我们有 rest api 应用程序。我们使用 redis 进行 API 响应缓存和内部方法缓存。如果是 redis 连接，那么它会使我们的 API 宕机。如果 redis 连接失败或出现任何异常，我们希望绕过 redis 缓存，而不是关闭我们的 API。 有一个接口(interface) CacheErrorHandler 但它处理 redis get set 操作失败而不是 redis 连接问题。我们正在使用 Spring 4.1.2。

最佳答案

让我们把它归结一下。您的应用程序使用缓存(使用 Redis 实现)。如果 Redis 连接过时/关闭或其他情况，那么您希望应用程序绕过缓存并(大概)直接转到底层数据存储(例如 RDBMS)。应用程序服务逻辑可能类似于...

@Service
class CustomerService ... {

    @Autowired
    private CustomerRepository customerRepo;

    protected CustomerRepository getCustomerRepo() {
        Assert.notNull(customerRepo, "The CustomerRepository was not initialized!");
        return customerRepo;
    }

    @Cacheable(value = "Customers")
    public Customer getCustomer(Long customerId) {
        return getCustomerRepo().load(customerId);
    }
    ...
}

在 Spring 核心的缓存抽象中，确定缓存“未命中”的所有重要事项是返回的值为 null。因此，Spring Caching Infrastructure 将继续调用实际的服务方法(即 getCustomer)。请记住 getCustomerRepo().load(customerId) 调用的返回，您还需要处理 Spring 的缓存基础结构现在尝试缓存值的情况。

本着保持简单的精神，我们将不使用 AOP，但您也应该能够使用 AOP 来实现这一点(您的选择)。

所有你(应该)需要的是一个扩展 SDR CacheManager implementation 的“自定义”RedisCacheManager , 像...

package example;

import org.springframework.cache.Cache;
import org.springframework.data.redis.cache.RedisCacheManager;
...

class MyCustomRedisCacheManager extends RedisCacheManager {

    public MyCustomerRedisCacheManager(RedisTemplate redisTemplate) {
        super(redisTemplate);
    }

    @Override
    public Cache getCache(String name) {
        return new RedisCacheWrapper(super.getCache(name));
    }


    protected static class RedisCacheWrapper implements Cache {

        private final Cache delegate;

        public RedisCacheWrapper(Cache redisCache) {
            Assert.notNull(redisCache, "'delegate' must not be null");
            this.delegate = redisCache;
        }

        @Override
        public Cache.ValueWrapper get(Object key) {
            try {
              delegate.get(key);
            }
            catch (Exception e) {
                return handleErrors(e);
            }
        }

        @Override
        public void put(Object key, Object value) {
            try {
                delegate.put(key, value);
            }
            catch (Exception e) {
                handleErrors(e);
            }
        }

        // implement clear(), evict(key), get(key, type), getName(), getNativeCache(), putIfAbsent(key, value) accordingly (delegating to the delegate).

        protected <T> T handleErrors(Exception e) throws Exception {
            if (e instanceof <some RedisConnection Exception type>) {
                // log the connection problem
                return null;
            }
            else if (<something different>) { // act appropriately }
            ...
            else {
                throw e;
            }
        }
    }
}

因此，如果 Redis 不可用，也许您能做的最好的事情就是记录问题并继续让服务调用发生。显然，这会影响性能，但至少会提高对问题存在的认识。显然，这可以绑定(bind)到更强大的通知系统中，但它只是可能性的一个粗略示例。重要的是，您的服务仍然可用，而应用程序服务所依赖的其他服务(例如 Redis)可能已经失败。

在这个实现中(相对于我之前的解释)我选择委托(delegate)给底层的、实际的 RedisCache 实现来让异常发生，然后完全知道 Redis 存在问题，这样你就可以适本地处理异常.但是，如果您确定异常与检查时的连接问题有关，您可以返回“null”让 Spring Caching Infrastructure 继续进行，就好像它是一个缓存“未命中”(即坏的 Redis 连接 == 缓存未命中，在这种情况下)。

我知道这样的事情应该有助于解决您的问题，因为我为 GemFire 和 Pivotal 的一位客户构建了一个类似的“自定义”CacheManager 实现原型(prototype)。在那个特定的 UC 中，缓存“未命中”必须由应用程序域对象的“过时版本”触发，其中生产混合了通过 Spring 的缓存抽象连接到 GemFire 的新旧应用程序客户端。例如，应用程序域对象字段会在较新版本的应用程序中发生变化。

无论如何，希望这对您有所帮助或给您更多的想法。

干杯!

关于spring-mvc - 如果 redis 连接失败，如何在运行时禁用 Redis 缓存，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29003786/