springboot中redis cachemanager反序列化中的错误处理

jdg4fx2g 于 2021-06-09 发布在 Redis

关注(0)|答案(1)|浏览(561)

我尝试在springboot中使用rediscachemanager的cutom序列化，而不是使用默认的java序列化。在这里如何处理错误？如果出现序列化/反序列化错误，我想从redis中删除密钥或至少添加一个日志行。请找到我使用jackson实现的自定义序列化

@Bean
RedisCacheManager redisCacheManager(RedisConnectionFactory factory) {
    StringRedisSerializer stringSerializer = new StringRedisSerializer();
    ObjectMapper mapper = new ObjectMapper();
    PolymorphicTypeValidator ptv = BasicPolymorphicTypeValidator.builder()
            .allowIfSubType("com.example")
            .allowIfSubType("java.sql.Timestamp")
            .allowIfSubType("org.hibernate.collection")
            .allowIfSubType("java.util.List")
            .allowIfSubType("java.util.ArrayList")
            .build();
    mapper.activateDefaultTyping(ptv, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
    RedisSerializer jacksonSerializer = new GenericJackson2JsonRedisSerializer(mapper);
    return new RedisCacheManager(
            RedisCacheWriter.nonLockingRedisCacheWriter(factory),
            RedisCacheConfiguration.defaultCacheConfig()
                    .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(stringSerializer))
                    .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jacksonSerializer))
    );
}

Java redis Jackson spring-boot

来源：https://stackoverflow.com/questions/62390259/error-handling-in-deserialisation-in-redis-cachemanager-in-springboot

1条答案

按热度按时间

unguejic1#

分享对我有用的解决方案
customcachemanagererrorhandler

@Slf4j
public class CustomCacheManagerErrorHandler implements CacheErrorHandler {
    @Override
    public void handleCacheGetError(RuntimeException exception, Cache cache, Object key) {
        log.error("CacheGetError, cache_name={}, key={}", cache.getName(), key, exception);
    }
    @Override
    public void handleCachePutError(RuntimeException exception, Cache cache, Object key, Object value) {
        log.error("CachePutError, cache_name={}, key={}", cache.getName(), key, exception);
    }
    @Override
    public void handleCacheEvictError(RuntimeException exception, Cache cache, Object key) {
        log.error("CacheEvictError, cache_name={}, key={}", cache.getName(), key, exception);
    }
    @Override
    public void handleCacheClearError(RuntimeException exception, Cache cache) {
        log.error("CacheClearError cache_name={}, key={}", cache.getName(), exception);
    }
}

缓存配置

@Configuration
public class CacheConfig extends CachingConfigurerSupport  {
    @Override
    public CacheErrorHandler errorHandler(){
        return new CustomCacheManagerErrorHandler();
    }
}

展开查看全部

赞(0）回复(0）举报 2021-06-09

我来回答

springboot中redis cachemanager反序列化中的错误处理

1条答案

相关问题

热门标签

最新问答