您在Web客户端非阻塞调用的方法中返回什么？

Question

我正在尝试了解如何为我的方法编写 WebClient api 调用。下面是一个简单的示例：

private String save(String body) {
   WebClient client = Webclient.create(saveUrl);
   Mono<String> response = client.post()
                .accept(MediaType.APPLICATION_FORM_URLENCODED)
                .contentType(MediaType.APPLICATION_FORM_URLENCODED)
                .body(this.getFormInserter(body))
                .retrieve()
                .bodyToMono(String.class)
   responseText.doOnNext(response -> //log successful save message).subscribe();
   return ??; // what do I return here?

我知道当我成功完成请求时，它将执行 //log 成功保存消息，这是所需的行为。

但是，我拥有的保存方法的常见做法是什么？我习惯于将一些字符串值返回给调用方，可能是成功/失败消息，或者对于其他情况，我返回 body 以便进一步处理。

对于我目前正在处理的更实际的示例，我调用 WebClient 来获取访问令牌，并在另一个 Web 客户端中使用它来实际保存正文，如下所示： 令牌服务：

    @Override
    public String getToken(String message) {
        WebClient client = WebClient.create(tokenUrl);
        Mono<String> responseText = client.post()
                .accept(MediaType.APPLICATION_FORM_URLENCODED)
                .contentType(MediaType.APPLICATION_FORM_URLENCODED)
                .body(this.getFormInserter())
                .retrieve()
                .bodyToMono(String.class)
                .retry(3);
        responseText.doOnNext(response -> saveService.save(message, getToken(response))).subscribe();
        return // what to return?
    }

    private String getToken(String responseBody) {
        JsonObject jsonObject = new Gson().fromJson(responseBody, JsonObject.class);
        return jsonObject.get(ACCESS_TOKEN_FIELD).toString();
    }

保存服务：

    @Override
    public Mono<Void> save(String message, String accessToken) {
        WebClient client = WebClient.builder()
                .baseUrl(saveUrl)
                .defaultHeaders(httpHeaders -> {
                    httpHeaders.setAccept(List.of(MediaType.APPLICATION_JSON));
                    httpHeaders.setContentType(MediaType.APPLICATION_JSON);
                    httpHeaders.setBearerAuth(accessToken);
                })
                .build();
        client.post().body(BodyInserters.fromPublisher(Mono.just(message), String.class));
        return null; //do i need to return something?
    }

我对WebClient非阻塞调用的理解是，正如非阻塞建议的那样，它不应该阻塞线程。这意味着，我创建的WebClient调用在保存之前应该有自己的流(因为我需要令牌)。但是，调用方法的调用者该怎么办呢？

在了解Web客户端之前，我的第一个方法是在TokenService中进行rest调用，获取令牌，将其传递给SaveService并保存它。现在，TokenService（将不得不更改名称）正在获取令牌并保存它。

我目前的方法还好吗？我应该为来电者返回什么？它应该返回任何东西吗？似乎呼叫者不会知道呼叫是成功还是失败......不确定除了我试图保存它之外，我是否应该记录任何内容？

Answer 1

成功调用“getToken”方法后，它应该返回，告诉用户您已成功获取Token，无需等待“save”方法的执行。