Spring @Cacheable redis出现异常如何解决

spring @Cacheable redis出现异常如何解决？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

原因分析

我们是通过@EnableCaching进行缓存启用的，因此可以先看@EnableCaching的相关注释

通过@EnableCaching的类注释可发现,spring cache的核心配置接口为：org.springframework.cache.annotation.CachinGConfigurer

public interface CachingConfigurer {  CacheManager cacheManager();  CacheResolver cacheResolver();  KeyGenerator keyGenerator();  CacheErrorHandler errorHandler();}

该接口errorHandler方法可配置异常的处理方式。通过该方法上的注释可以发现,默认的CacheErrorHandler实现类是org.springframework.cache.interceptor.SimpleCacheErrorHandler

public class SimpleCacheErrorHandler implements CacheErrorHandler { @Override public void handleCacheGetError(RuntimeException exception, Cache cache, Object key) { throw exception; } @Override public void handleCachePutError(RuntimeException exception, Cache cache, Object key, Object value) { throw exception; } @Override public void handleCacheEvictError(RuntimeException exception, Cache cache, Object key) { throw exception; } @Override public void handleCacheClearError(RuntimeException exception, Cache cache) { throw exception; }}

SimpleCacheErrorHandler类注释上说明的很清楚：对cache的异常不做任何处理，直接将该异常抛给客户端。因此默认的情况下，Redis服务器异常后，直接就阻断了正常业务

解决方案

通过上面的分析可知，我们可以通过自定义CacheErrorHandler来干预@Cacheable的异常处理逻辑。具体代码如下：

public class RedisConfig extends CachingConfigurerSupport {    @Override  public CacheErrorHandler errorHandler() {    return new CacheErrorHandler() {      @Override      public void handleCachePutError(RuntimeException exception, Cache cache,                      Object key, Object value) {        handleRedisErrorException(exception, key);      }      @Override      public void handleCacheGetError(RuntimeException exception, Cache cache,                      Object key) {        handleRedisErrorException(exception, key);      }      @Override      public void handleCacheEvictError(RuntimeException exception, Cache cache,                       Object key) {        handleRedisErrorException(exception, key);      }      @Override      public void handleCacheClearError(RuntimeException exception, Cache cache) {        handleRedisErrorException(exception, null);      }    };  }  protected void handleRedisErrorException(RuntimeException exception, Object key) {    log.error("redis异常：key=[{}]", key, exception);  }}

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注编程网精选频道，感谢您对编程网的支持。