4

我正在尝试将 CrudRepository 与 spring-data-redis 和生菜结合使用。按照我能找到的所有建议，我已经使用@ReadingConverters 和@WritingConverters 配置了我的spring-boot 2.1.8 应用程序，但是当我尝试使用存储库时，我得到“属性路径不能为空或空”。

做一些调试，这似乎是由org.springframework.data.redis.core.convert.MappingRedisConverter:393

writeInternal(entity.getKeySpace(), "", source, entity.getTypeInformation(), sink);

第二个参数是路径。MappingRedisConverter这将在运行此代码的第 747 行结束：

} else if (targetType.filter(it -> ClassUtils.isAssignable(byte[].class, it)).isPresent()) {
            sink.getBucket().put(path, toBytes(value));
}

最终，即使数据已被序列化，具有空路径的 put 最终也会org.springframework.data.redis.core.convert.Bucket:77失败。Assert.hasText(path, "Path to property must not be null or empty.");

这是 spring-data-redis 的错误还是我必须配置其他东西？

RedicsConfig.java

@Configuration
@EnableConfigurationProperties({RedisProperties.class})
@RequiredArgsConstructor
@EnableRedisRepositories
public class RedisConfiguration {
    private final RedisConnectionFactory redisConnectionFactory;

    @Bean
    public RedisTemplate<?, ?> redisTemplate() {
        RedisTemplate<byte[], byte[]> template = new RedisTemplate<byte[], byte[]>();
        template.setConnectionFactory(redisConnectionFactory);
        template.afterPropertiesSet();
        return template;
    }

    @Bean
    public ObjectMapper objectMapper() {
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        objectMapper.findAndRegisterModules();
        return objectMapper;
    }

    @Bean
    public RedisCustomConversions redisCustomConversions(List<Converter<?,?>> converters) {
        return new RedisCustomConversions(converters);
    }

}

我刚刚在这里包含了一个写作转换器，但有几个读写转换器......


@Component
@WritingConverter
@RequiredArgsConstructor
@Slf4j
public class CategoryWritingConverter implements Converter<Category, byte[]> {

    private final ObjectMapper objectMapper;

    @Setter
    private Jackson2JsonRedisSerializer<Category> serializer;

    @Override
    public byte[] convert(Category category) {
        return getSerializer().serialize(category);
    }

    private Jackson2JsonRedisSerializer<Category> getSerializer() {
        if (serializer == null) {
            serializer = new Jackson2JsonRedisSerializer<>(Category.class);
            serializer.setObjectMapper(objectMapper);
        }
        return serializer;
    }
}

要写的对象：

@Data
@JsonInclude(JsonInclude.Include.NON_NULL)
@EqualsAndHashCode(onlyExplicitlyIncluded = true)
@AllArgsConstructor
@NoArgsConstructor
@RedisHash("category")
@TypeAlias("category")
public class Category {

    @Id
    @EqualsAndHashCode.Include
    private String categoryCode;

    private String categoryText;
}

和回购：


public interface CategoryRepository extends CrudRepository<Category, String> {

    Page<Category> findAll(Pageable pageable);

}

任何人都可以建议我错过了什么，或者如果这是我应该在 spring-data-redis 上提出的错误？

4

0 回答 0