0

我正在尝试读取我在 redis 流中写入的数据,但我正在读取字节。我正在使用spring data redis,并且我已经配置了一个LettuceConnectionFactoryRedisTemplate<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 的更多文档。

4

0 回答 0