问题描述
由于DATAREDIS-1250的缺点,我将Spring Data Redis与Kotlin一起使用,但没有Spring数据存储库。 因此,我创建了自己的小资料库。
interface CoroutinesRepository<T : Serializable> {
suspend fun save(entity: T): T
suspend fun findByIdOrNull(id: String): T?
suspend fun deleteById(id: String)
}
及其实现:
abstract class AbstractCoroutinesRepository<T : Serializable>(clazz: Class<T>) : CoroutinesRepository<T> {
private val hash: String = clazz.simpleName
.// convert class name to hyphenated string
private val idField: Field = clazz.declaredFields
.// find field with @Id annotation
@Autowired
private lateinit var redistemplate: ReactiveRedistemplate<Any,Any>
@Autowired
private lateinit var persistenceProperties: PersistenceProperties
override suspend fun save(entity: T): T {
val valueOps = redistemplate
.opsForValue()
valueOps.set("$hash:${idField.get(entity)}",entity,getTtl(persistenceProperties))
.awaitFirst()
return entity
}
// Other methods omitted
}
用作:
@Repository
class ResponseRepositoryImpl : AbstractCoroutinesRepository<Response>(Response::class.java)
这有效,并且上面的代码可以从Redis设置和获取值。但是,当我从Redis CLI查询时,我看到:
127.0.0.1:6379> SCAN 0
1) "0"
2) 1) "\xac\xed\x00\x05t\x00\x0cuuid:test"
2) "\xac\xed\x00\x05t\x00\x10response:test"
这个奇怪的字符串前缀是什么?如我所说,它似乎并没有影响检索,但我很好奇。
Spring Data Redis 2.3.5.RELEASE。
解决方法
事实证明这是由于使用了默认的JdkSerializationRedisSerializer
而引起的,我猜很奇怪的是字段元信息(类型等)。其他GenericJackson2JsonRedisSerializer
等Redis序列化程序则不这样做,并且数据以人类可读的格式保存。