使用 webClient 和 Mono 的代理黑白客户端和服务

Question

我正在编写一个代理 b/w 客户端和服务，在代理中我只需要一些基本的验证并将请求传递给服务，我在下面编写了相同的代码。请让我知道这是正确的方法还是有其他更好的方法来处理这个问题。

public Mono<ServerResponse> handlePostRequest(ServerRequest request) {
        return webClient.post().uri("/some/uri").headers(headers -> request.headers())
                        .body(request.bodyToMono(DataBuffer.class), DataBuffer.class)
                        .exchange()
                            .flatMap(response -> ServerResponse.status(response.statusCode())
                                            .headers(c -> response.headers().asHttpHeaders().forEach((name, value) -> c.put(name, value)))
                                            .body(response.bodyToMono(DataBuffer.class), DataBuffer.class));

}

Answer 1

我在此代码 sn-p 中看不到任何验证（尽管您在问题中提到了该要求）。

我也没有看到任何错误管理，它应该处理服务器应该响应的内容，以防远程服务器返回 HTTP 错误（它应该只转发响应吗？），或者如果它没有响应并且超时发生。

除此之外，鉴于您分享的简短要求，这可能适合您的用例。

请注意，根据您对 HTTP 客户端库和服务器的选择，DataBuffer 实例可以是 PooledDataBuffer - 这意味着引用被计数以允许它们被重用，并且使用它们的代码负责释放它们.在这种情况下，您将重用这些缓冲区以将它们作为请求正文转发给客户端或作为响应正文转发给服务器。 release 操作将在它们写入网络之前为您完成。

最后，如果您正在寻找更复杂的功能，您可以查看Spring Cloud Gateway project，它可以提供更多功能。