Spring data redis реактивное чтение Ошибка приведения LocaldateTime

Я использую Spring Data Redis Reactive framework, а версия Spring Boot - 2.3.0.

Вот моя конфигурация Redis:

  @Bean("reactiveRedisTemplate")
public ReactiveRedisTemplate<String, Object> reactiveRedisTemplateString(ReactiveRedisConnectionFactory connectionFactory) {
    Jackson2JsonRedisSerializer jacksonSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
    ObjectMapper objectMapper = new ObjectMapper();
    objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
    JavaTimeModule timeModule = new JavaTimeModule();
    timeModule.addSerializer(Date.class, new DateSerializer(Boolean.FALSE, new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")));
    timeModule.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
    timeModule.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
    timeModule.addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern("HH:mm:ss")));
    timeModule.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
    timeModule.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
    timeModule.addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern("HH:mm:ss")));
    objectMapper.setDefaultPropertyInclusion(JsonInclude.Include.NON_NULL);
    objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance,
            ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
    objectMapper.registerModule(timeModule).registerModule(new ParameterNamesModule()).registerModules(ObjectMapper.findModules());
    jacksonSerializer.setObjectMapper(objectMapper);

    final StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
    RedisSerializationContext<String , Object> serializationContext = RedisSerializationContext
            .<String, Object>newSerializationContext()
            .key(stringRedisSerializer)
            .value(jacksonSerializer)
            .hashKey(stringRedisSerializer)
            .hashValue(jacksonSerializer)
            .build();

    return new ReactiveRedisTemplate(connectionFactory, serializationContext);
}

Я настроил объект LocalDateTime с помощью метода hashoperations.put для отображения следующей формы в Redis:

key hashKey "2020-06-23 16:42:44"

Когда я использую MonoMono = hashoperations.get (key,hashKey) для получения значения, возникает следующее исключение:

java.lang.ClassCastException: class java.lang.String cannot be cast to class java.time.LocalDateTime (java.lang.String and java.time.LocalDateTime are in module java.base of loader 'bootstrap')
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)

Но когда LocalDateTime является свойством объекта, проблем нет.

Я не знаю, как это решить. Спасибо за все ответы.

Источник

1 ответ

Я решил это

измените DefaultTyping.NON_FINAL на DefaultTyping.EVERYTHING

Это примет тип java.time.LocalDateTime

Источник
Другие вопросы по тегам