java - 在 Spring 中链接对 redis 的响应式调用

Question

我正在尝试获取所有键，然后使用ReactiveRedisTemplateSpring Data Redis中的 a 获取它们的所有值

（我知道这scan是可取的，但我现在想保持简单，除非这是我的问题）

代码片段：

@Service
class Test {
    Logger logger = LoggerFactory.getLogger(Test.class);

    @Autowired
    private ReactiveRedisTemplate<String, String> reactiveRedisTemplate;

    @EventListener(ApplicationReadyEvent.class)
    public void test() {
        logger.info("test");
        var ops = reactiveRedisTemplate.opsForValue();
        var keys = reactiveRedisTemplate.keys("*");
        keys
                .map(l -> {
                    logger.info("test1 " + l);
                    return ops.get(l);
                })
                .doOnNext(
                        l -> logger.info("test2 " + l)
                )
                .blockLast();

        logger.info("done");
    }

}

问题是我得到了这个输出：

test
test1 key1
test2 MonoNext
test1 key2
test2 MonoNext
test1 key3
test2 MonoNext
test1 key4
test2 MonoNext
done

我希望：

test
test1 key1
test2 val1
test1 key2
test2 val2
test1 key3
test2 val3
test1 key4
test2 val4
done

我是 rx-java 的新手，所以我可能遗漏了一些东西。

Answer 1

找到了解决方案...

我不得不使用flatMap而不是地图...

@Service
class Test {
    Logger logger = LoggerFactory.getLogger(Test.class);

    @Autowired
    private ReactiveRedisTemplate<String, String> reactiveRedisTemplate;

    @EventListener(ApplicationReadyEvent.class)
    public void test() {
        logger.info("test");
        var ops = reactiveRedisTemplate.opsForValue();
        var keys = reactiveRedisTemplate.keys("*");
        keys
                .flatMap(l -> {
                    logger.info("test1 " + l);
                    return ops.get(l);
                })
                .doOnNext(
                        l -> logger.info("test2 " + l)
                )
                .blockLast();

        reactiveRedisTemplate.opsForValue().get("test").doOnNext(l -> logger.info("test2 " + l)).block();

        logger.info("done");
    }

}

完整的解释在这里