单声道开关如果空() 始终称为

我有两种方法。
主要方法:

@PostMapping("/login")
public Mono<ResponseEntity<ApiResponseLogin>> loginUser(@RequestBody final LoginUser loginUser) {
    return socialService.verifyAccount(loginUser)
            .flatMap(socialAccountIsValid -> {
                if (socialAccountIsValid) {
                    return this.userService.getUserByEmail(loginUser.getEmail())
                            .switchIfEmpty(insertUser(loginUser))
                            .flatMap(foundUser -> updateUser(loginUser, foundUser))
                            .map(savedUser -> {
                                String jwts = jwt.createJwts(savedUser.get_id(), savedUser.getFirstName(), "user");
                                return new ResponseEntity<>(HttpStatus.OK);
                            });
                } else {
                    return Mono.just(new ResponseEntity<>(HttpStatus.UNAUTHORIZED));
                }
            });

}

这个调用的方法(服务调用外部 API):

public Mono<User> getUserByEmail(String email) {
    UriComponentsBuilder builder = UriComponentsBuilder
            .fromHttpUrl(USER_API_BASE_URI)
            .queryParam("email", email);
    return this.webClient.get()
            .uri(builder.toUriString())
            .exchange()
            .flatMap(resp -> {
                if (Integer.valueOf(404).equals(resp.statusCode().value())) {
                    return Mono.empty();
                } else {
                    return resp.bodyToMono(User.class);
                }
            });
} 

在上面的示例中,始终从 main 方法调用,即使返回结果 with 也是如此。switchIfEmpty()Mono.empty()

我找不到这个简单问题的解决方案。
以下操作也不起作用:

Mono.just(null) 

因为该方法将抛出一个 .NullPointerException

我也不能使用的是 flatMap 方法来检查它是否为空。
可悲的是,如果我返回,flatMap根本不会被调用,所以我也不能在这里添加条件。foundUserMono.empty()

@SimY4

   @PostMapping("/login")
    public Mono<ResponseEntity<ApiResponseLogin>> loginUser(@RequestBody final LoginUser loginUser) {
        userExists = false;
        return socialService.verifyAccount(loginUser)
                .flatMap(socialAccountIsValid -> {
                    if (socialAccountIsValid) {
                        return this.userService.getUserByEmail(loginUser.getEmail())
                                .flatMap(foundUser -> {
                                    return updateUser(loginUser, foundUser);
                                })
                                .switchIfEmpty(Mono.defer(() -> insertUser(loginUser)))
                                .map(savedUser -> {
                                    String jwts = jwt.createJwts(savedUser.get_id(), savedUser.getFirstName(), "user");
                                    return new ResponseEntity<>(HttpStatus.OK);
                                });
                    } else {
                        return Mono.just(new ResponseEntity<>(HttpStatus.UNAUTHORIZED));
                    }
                });

    }

答案 1

这是因为switchIfEmpty“按值”接受Mono。这意味着甚至在您订阅单声道之前,这个替代单声道的评估已经被触发。

想象一下这样的方法:

Mono<String> asyncAlternative() {
    return Mono.fromFuture(CompletableFuture.supplyAsync(() -> {
        System.out.println("Hi there");
        return "Alternative";
    }));
}

如果像这样定义代码:

Mono<String> result = Mono.just("Some payload").switchIfEmpty(asyncAlternative());

无论在流建设期间发生什么,它都会始终触发替代方案。要解决此问题,您可以使用以下命令延迟对第二个单声道的评估Mono.defer

Mono<String> result = Mono.just("Some payload")
        .switchIfEmpty(Mono.defer(() -> asyncAlternative()));

这样,当请求替代项时,它将仅打印“嗨在那里”

UPD:

详细阐述一下我的答案。你面临的问题与 Reactor 无关,而是与 Java 语言本身以及它如何解析方法参数有关。让我们检查一下我提供的第一个示例中的代码。

Mono<String> result = Mono.just("Some payload").switchIfEmpty(asyncAlternative());

我们可以将其重写为:

Mono<String> firstMono = Mono.just("Some payload");
Mono<String> alternativeMono = asyncAlternative();
Mono<String> result = firstMono.switchIfEmpty(alternativeMono);

这两个代码片段在语义上是等效的。我们可以继续打开它们,看看问题出在哪里:

Mono<String> firstMono = Mono.just("Some payload");
CompletableFuture<String> alternativePromise = CompletableFuture.supplyAsync(() -> {
        System.out.println("Hi there");
        return "Alternative";
    }); // future computation already tiggered
Mono<String> alternativeMono = Mono.fromFuture(alternativePromise);
Mono<String> result = firstMono.switchIfEmpty(alternativeMono);

如您所见,未来的计算已经在我们开始编写类型时触发了。为了防止不必要的计算,我们可以将我们的未来包装成一个推迟的评估:Mono

Mono<String> result = Mono.just("Some payload")
        .switchIfEmpty(Mono.defer(() -> asyncAlternative()));

这将展开

Mono<String> firstMono = Mono.just("Some payload");
Mono<String> alternativeMono = Mono.defer(() -> Mono.fromFuture(CompletableFuture.supplyAsync(() -> {
        System.out.println("Hi there");
        return "Alternative";
    }))); // future computation defered
Mono<String> result = firstMono.switchIfEmpty(alternativeMono);

在第二个示例中,未来被困在一个懒惰的供应商中,并且仅在请求时才被安排执行。


答案 2

对于那些尽管投票率很高的答案,但仍然不明白为什么会有这种行为的人:

反应堆源(Mono.xxx 和 Flux.xxx)是:

  • 懒惰评估:只有当订阅者订阅时,才会评估/触发源的内容;

  • 热切评估 :甚至在订阅者订阅之前,源的内容就会立即被评估。

像 、 这样的表达式是急切的。Mono.just(xxx)Flux.just(xxx)Flux.fromIterable(x,y,z)

通过使用 ,可以强制懒惰地评估源。这就是为什么公认的答案有效。defer()

所以这样做:

 someMethodReturningAMono()
  .switchIfEmpty(buildError());

依靠一个渴望的来源来创建一个替代的Mono将始终在订阅之前进行评估:buildError()

Mono<String> buildError(){
       return Mono.just("An error occured!"); //<-- evaluated as soon as read
}

为防止这种情况,请执行以下操作:

 someMethodReturningAMono()
  .switchIfEmpty(Mono.defer(() -> buildError()));

阅读此答案了解更多信息。


推荐