我正在尝试读取我在 redis 流中写入的数据,但我正在读取字节。我正在使用spring data redis,并且我已经配置了一个LettuceConnectionFactory
和RedisTemplate<String, OutputSpecRest>
bean。
写入流:
public void writeOutput(OutputSpecRest output) {
ObjectRecord<String, OutputSpecRest> objectRecord =
StreamRecords.newRecord().ofObject(output).withStreamKey(STREAM_KEY);
redisStreamTemplate.opsForStream().add(objectRecord);
}
从流中读取:
public void getRecordsHistory(int count) {
List<MapRecord<String, Object, Object>> mapRecords =
redisStreamTemplate.opsForStream().reverseRange(STREAM_KEY, Range.unbounded());
System.out.println(mapRecords);
}
如何从 redis 流中读取并放入我的OutputSpecRest
自定义对象?
opsForStream
为了继续该getRecordsHistory
方法,我找不到关于 Redis 的更多文档。