を使用しJackson2JsonRedisSerializer
て、カスタム インスタンスを Redis ストアのハッシュ値としてシリアル化しようとしています。テンプレートを正しく作成したにもかかわらず、ハッシュが作成されていないようです。
私がKotlinで使用spring-data-reactive-redis
していることに注意してください。spring-webflux
data class Movie(
@get:JsonProperty("Id")
val id: String?,
@get:JsonProperty("Title")
val title: String,
)
@Configuration
class RedisConfig {
@Bean
fun hashTemplate(factory: ReactiveRedisConnectionFactory): ReactiveRedisTemplate<String, Movie> {
val serializationContext = RedisSerializationContext.newSerializationContext<String, Movie>(StringRedisSerializer())
.hashKey(StringRedisSerializer())
.hashValue(Jackson2JsonRedisSerializer(Movie::class.java))
.build()
return ReactiveRedisTemplate(factory, context)
}
}
このテンプレートを使用してデータを追加する例を次に示します。
@Component
class DataLoader(@Qualifier("hashTemplate") private val template: ReactiveRedisTemplate<String, Movie>) {
@PostConstruct
fun loadData() {
Flux.fromIterable(
listOf(Movie("1", "Avengers: Endgame"), Movie("2", "Black Widow"))
)
.flatMap { movie ->
template.opsForHash<String, Movie>().put("Movies", movie.id, movie)
}
.thenMany(template.opsForHash<String, Movie>().entries("Movies"))
.subscribe { m -> println(m) }
}
}
Spring が私が作成したテンプレートを使用していない理由を教えてください。