以正确的方式处理和返回Mono错误-Java Reactor代码

Question

我有这样一门DTO课：

public class User {

    @Field("id")
    private String id;

    private String userName;

    private String emailId;
}

我必须通过API提供更新和删除功能。

我写了以下代码删除记录：

public Mono<String> userData(User body) {

    repo.removeUserDetails(userObj).subscribe(); 
     return Mono.just("Remove Successful");
 
}

RemoveUserDetails方法如下：

 public Mono<User> removeUserDetails(User userObj) {
 
    return findByUsername(userObj.getUsername())
    .flatMap(existingUser -> {
        // logic to delete the data from database which working as expected
    }).switchIfEmpty(
                        Mono.defer(() -> {
                            return Mono.error(new Exception("User Name " + userObj.getUsername() + " doesn't exist."));
                        })
                );
    
 }

这段代码的问题是，即使用户不存在，它也不会显示我返回的Mono错误。在任何情况下，都会返回“Remove Successful”。

如何更改我的服务层方法，使其能够返回repo方法接收到的任何内容？我对Reactor代码还不熟悉，所以不知道怎么写。

Answer 1

每当你订阅订阅时，都认为它是立即的红旗。订阅应该由您正在使用的框架来处理（本例中是Webflux）

如果您自己订阅，如本例所示：

public Mono<String> userData(User body) {
    repo.removeUserDetails(userObj).subscribe(); 
    return Mono.just("Remove Successful");
 
}

...然后，您基本上创建了一个“fire and forget”类型的订阅，您无法知道该发布服务器是否成功完成，是否导致了错误，完成所需的时间，是否完成，或者是否发出了元素。因此，在本例中，您的意思是“发送一个删除用户详细信息的请求，忘记您发送了它，然后在等待任何类型的结果之前，始终返回‘删除成功’。”这几乎不是你想要的。

你可以使用以下方法：

public Mono<String> userData(User body) {
    return repo.removeUserDetails(userObj)
               .then(Mono.just("Remove Successful"));
}

...这是更好的，因为它包括一切作为反应链的一部分。在这种情况下，您要么会得到一个错误信号，要么会得到“删除成功”。

然而，很可能你根本不需要返回这个字符串——你只需要知道它是否成功。这样做的标准方法（我只需要知道它是否成功完成，我不需要它返回值）是使用Mono

public Mono<Void> userData(User body) {
    return repo.removeUserDetails(userObj).then();
}

...如果删除成功，它会给你一个标准的完成，否则会给你一个错误信号。