Spring webflux 非阻塞响应

Question

我有一个使用 'username' 和 'password' 正文参数从数据库中查找真实用户的请求方法，使用请求密码验证它，如果一切正常 - return 生成标记为字符串。

public Mono<ServerResponse> handleLogin(ServerRequest request) {
    User body = request.bodyToMono(User.class).block();
    return userRepository.findById(body.getUsername())
            .filter(user -> passwordEncoder.matches(body.getPassword(), user.getPassword()))
            .flatMap(user -> ServerResponse.ok().body(Mono.just(tokens.store(user)), String.class))
            .switchIfEmpty(ServerResponse.badRequest().build());
}

此方法工作正常，但我试图使其成为非阻塞的，但我不确定如何实现它。任何帮助表示赞赏。

已更新

现在我将我的方法内容更改为

    return request.bodyToMono(User.class)
            .flatMap(body -> userRepository.findById(body.getUsername()).flatMap(user -> Mono.just(new Object[]{body.getPassword(), user})))
            .filter(obj -> {
                User user = (User) obj[1];
                return user.isActive() && passwordEncoder.matches((CharSequence) obj[0], user.getPassword());
            })
            .flatMap(obj -> {
                User user = (User) obj[1];
                return ServerResponse.ok().body(Mono.just(tokens.store(user)), String.class);
            })
            .switchIfEmpty(ServerResponse.badRequest().build());

这是非阻塞的，但看起来不是那么优雅的解决方案。可以是improved/simplified吗？

Answer 1

记得

1) 一切都是流。

2) 保持你的流程

3) 完全没有阻塞操作

解决方案

因此，让您的流程保持组合而不阻塞操作

public Mono<ServerResponse> handleLogin(ServerRequest request) {

    return request.bodyToMono(User.class)
                  .flatMap(body -> userRepository.findById(body.getUsername())
                  .filter(user -> passwordEncoder.matches(body.getPassword(), user.getPassword()))
                  .flatMap(user -> ServerResponse.ok().body(Mono.just(tokens.store(user)), String.class))
                  .switchIfEmpty(ServerResponse.badRequest().build());
}

关于上次更新

关于上次更新，从我的角度来看，代码可能会在下一个方面进行优化：

return request.bodyToMono(User.class)
            .flatMap(body -> userRepository.findById(body.getUsername())                              
                                           .filter(user -> user.isActive())
                                           .filter(user -> passwordEncoder.matches(body.getPassword(), user.getPassword()))
            )
            .flatMap(user -> ServerResponse.ok().syncBody(tokens.store(user)))
            .switchIfEmpty(ServerResponse.badRequest().build());

Spring webflux 非阻塞响应

Spring webflux non-blocking response

java

nonblocking

spring-webflux

记得

解决方案

关于上次更新