使用过滤器和映射链接 Java Reactor Monos

Question

我正在尝试调用多个服务（使用 Java Reactor），一个服务的输出将决定是否应该调用下一个服务。

1. 通过调用 validateSession API 验证会话是否有效

2. 检查会话是否有效并且是否有关联的登录名

3. 获取登录的详细信息

4. 检查登录详细信息中是否包含名字

5. 如果以上都通过，则生成凭据

线

.filter(details -> details != null && StringUtils.isNotBlank(details.getFName))

给出错误，因为“细节”被解释为单声道。

如果我更改代码以使用 flatMap 而不是 Map，它可以正常工作，但我想要一个同步响应，因为我需要等待一切完成才能生成凭据。

.map(session -> dao.getDetails(session.getLogin()))
                .filter(details -> details != null && StringUtils.isNotBlank(details.getFName))

以下是有问题的代码。

Mono<Credentials> response = dao.validateSession(sessionId)
                .filter(session -> session != null && StringUtils.isNotBlank(session.getLogin()))
                .map(session -> dao.getDetails(session.getLogin()))
                .filter(details -> details != null && StringUtils.isNotBlank(details.getFName))
                .map(details -> dao.generateCredentials())
                .cast(Credentials.class);

Answer 1

你可以这样简化：Mono<Credentials>&nbsp;response&nbsp;=&nbsp;dao.validateSession(sessionId) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.filter(session&nbsp;->&nbsp;StringUtils.isNotBlank(session.getLogin())) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.flatMap(session&nbsp;->&nbsp;dao.getDetails(session.getLogin())) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.filter(details&nbsp;->&nbsp;StringUtils.isNotBlank(details.getFName)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.flatMap(details&nbsp;->&nbsp;dao.generateCredentials());我已经更改了用于简化的运算符，但我认为最后一步需要将details对象用作generateCredentials方法的参数。

Answer 2

下面的代码解决了这个问题。Map&nbsp;returns&nbsp;a&nbsp;<Mono<Mono>>&nbsp;while&nbsp;flatMap&nbsp;returns&nbsp;a&nbsp;<Mono>Mono<Credentials>&nbsp;response&nbsp;=&nbsp;dao.validateSession(sessionId) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.filter(session&nbsp;->&nbsp;session&nbsp;!=&nbsp;null&nbsp;&&&nbsp;StringUtils.isNotBlank(session.getLogin())) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.map(session&nbsp;->&nbsp;dao.getDetails(session.getLogin())) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.flatMap(session->session) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.filter(details&nbsp;->&nbsp;details&nbsp;!=&nbsp;null&nbsp;&&&nbsp;StringUtils.isNotBlank(details.getFName)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.map(details&nbsp;->&nbsp;dao.generateCredentials()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.flatMap(credentials&nbsp;->&nbsp;credentials);