在Spring webflux中处理条件响应的正确方法是什么

Question

所以，我想实现一个非常简单的输出。

我有与字段成功，消息和列表数据响应类。

@Data
@Accessors(chain = true)
public class Response {

    private boolean success;
    private String message;
    private List data;
}

和请求类

@Data
@Accessors(chain = true)
public class LoginRequest {

    private String email;
    private String password;
}

Mono<User> findUserByEmail(String email);

@PostMapping("/login")
public Mono<Response> login(@RequestBody Mono<LoginRequest> request) {
}

null

null

我试过很多方法，但最后都没能做到。

Answer 1

您不需要一个Mono作为控制器的参数，您可以接受Spring中标准数据绑定后的值。查看Spring文档中的示例:https://docs.Spring.io/Spring/docs/current/spring-framework-reference/web-reactive.html#webflux-controller

您也不应该从repo中获得null，如果找不到用户，您将获得一个空单声道（因此不会调用.map、.filter等）。在这种情况下，可以使用.switchifempty替换空检查。

如果获得数据，只需.将其映射到您需要的内容，因为您不需要阻止任何其他数据：

public Mono<Response> login(LoginRequest request) {
        return repo.findUserByEmail(request.getEmail())
            .map(user ->
                Objects.equals(request.getPassword(), user.getPassword())
                    ? new Response(true, "Welcome", Collections.emptyList())//populate list here
                    : new Response(false, "invalid password", Collections.emptyList()))
            //user wasn't found in the repo
            .switchIfEmpty(Mono.just(new Response(false, "No user found", Collections.emptyList())));
    }