实现响应式Redis时遭遇反序列化错误求助

问题根源 #

你用@Cacheable直接缓存了Mono/Flux类型对象，而非订阅后获取的实际业务数据。Redis中存储的是Reactor内部包装类（如MonoCacheTime），这类类缺少Jackson序列化所需的无参构造函数或对应创建逻辑，导致反序列化失败。

解决步骤 #

• 缓存实际数据而非响应式容器
  修改缓存逻辑，确保缓存的是Mono/Flux包裹的业务对象，而非响应式类型本身。示例代码：

  @Cacheable(value = "yourCacheName", key = "#id")
  public Mono<YourBusinessObject> getData(String id) {
      // 返回的Mono内部的业务对象会被Spring Cache正确序列化缓存
      return dataRepository.findById(id);
  }
  

  避免直接缓存Mono包装类，Spring Cache会自动处理响应式类型的订阅，提取内部数据进行缓存。

• 配置适配响应式的Redis缓存管理器
  确保缓存管理器使用正确的序列化策略，适配响应式场景。示例配置：

  @Configuration
  public class ReactiveRedisCacheConfig {
  
      @Bean
      public ReactiveRedisCacheManager reactiveRedisCacheManager(ReactiveRedisConnectionFactory connectionFactory) {
          GenericJackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer();
          RedisSerializationContext.SerializationPair<Object> serializationPair = 
              RedisSerializationContext.SerializationPair.fromSerializer(serializer);
  
          return ReactiveRedisCacheManager.builder(connectionFactory)
                  .cacheDefaults(RedisCacheConfiguration.defaultCacheConfig()
                          .serializeValuesWith(serializationPair))
                  .build();
      }
  }
  

• 清理Redis中无效缓存数据
  Redis中已存储的MonoCacheTime类型数据无法正常反序列化，需手动删除对应缓存键：

  redis-cli DEL yourCacheName::yourTargetKey
  

• 给业务对象添加序列化支持
  确保业务对象具备Jackson序列化所需的无参构造函数，可通过Lombok注解快速实现：

  @Data
  @NoArgsConstructor // 必须添加无参构造，否则Jackson无法反序列化
  @AllArgsConstructor
  public class YourBusinessObject {
      private String id;
      private String content;
      // 其他业务字段
  }
  

注意：确保Spring Boot版本在2.2及以上，该版本开始对响应式缓存的支持更完善，避免版本兼容问题。

内容的提问来源于stack exchange，提问作者Suman Paudel