相关疑难解决方法(0)

我是新手,一般都会对Reactor和反应式编程进行预测.

我目前正在编写一段类似于此的代码:

Mono.just(userId)
    .map(repo::findById)
    .map(user-> {
        if(user == null){
            throw new UserNotFoundException();
        }
        return user;
    })
    // ... other mappings

这个例子可能很愚蠢,实现这种情况肯定有更好的方法,但重点是:

throw new在map块中使用异常是否错误,或者我应该用return Mono.error(new UserNotFoundException())？替换它？

这两种做法有什么实际区别吗？

我正在尝试将现有的客户端代码替换RestTemplate为WebClient. 因此，大多数调用需要阻塞，以便应用程序的主要部分不需要更改。当涉及到错误处理时，这会带来一些问题。有几种情况必须涵盖：

• 在成功的情况下，响应包含 A 类型的 JSON 对象
• 在错误情况下（HTTP 状态 4xx 或 5xx），响应可能包含 B 类型的 JSON 对象
• 对于响应状态为 404 的某些请求，我需要返回与List成功响应类型匹配的空值

为了产生正确的误差 ( Exception)，需要考虑误差响应。到目前为止，我无法接触到错误主体。

我正在使用此RestController方法来生成错误响应：

@GetMapping("/error/404")
@ResponseStatus(HttpStatus.NOT_FOUND)
public ResponseEntity error404() {
    return ResponseEntity
            .status(HttpStatus.NOT_FOUND)
            .body(new ErrorResponse());
}

使用此响应对象：

public class ErrorResponse {    
    private String message = "Error message";    
    public String getMessage() {
        return message;
    }
}

定义WebClient如下：

WebClient.builder()
    .baseUrl("http://localhost:8081")
    .clientConnector(connector)
    .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
    .build();

连接器的类型为CloseableHttpAsyncClient（Apache Http client5）。

从我的测试应用程序中，我进行如下调用：

public String …