WebClient非阻塞调用方法返回值及实现合理性咨询

问题1：非阻塞save方法的返回值选择 #

你当前的实现直接在方法内调用subscribe()，这会导致异步操作脱离调用方的控制，而且此时返回任何字符串都无法反映实际请求的结果（因为请求还没完成）。在反应式编程模型下，正确的做法是返回反应式类型（Mono/Flux），把订阅的控制权交给调用方，这样调用方才能处理成功/失败的信号，获取响应体或错误信息。

修正后的代码示例：

private Mono<String> save(String body) {
    WebClient client = WebClient.create(saveUrl);
    return client.post()
            .accept(MediaType.APPLICATION_FORM_URLENCODED)
            .contentType(MediaType.APPLICATION_FORM_URLENCODED)
            .body(this.getFormInserter(body))
            .retrieve()
            .bodyToMono(String.class)
            .doOnNext(response -> {
                // 记录请求成功日志
                log.info("Save request succeeded, response: {}", response);
            })
            .doOnError(error -> {
                // 记录请求失败日志
                log.error("Save request failed", error);
            });
}

调用方可以这样使用：

save(body)
    .subscribe(
        response -> { /* 处理成功响应 */ },
        error -> { /* 处理错误 */ }
    );

如果业务上不需要响应体，也可以返回Mono<Void>，通过then()方法转换：

private Mono<Void> save(String body) {
    WebClient client = WebClient.create(saveUrl);
    return client.post()
            .accept(MediaType.APPLICATION_FORM_URLENCODED)
            .contentType(MediaType.APPLICATION_FORM_URLENCODED)
            .body(this.getFormInserter(body))
            .retrieve()
            .bodyToMono(String.class)
            .doOnNext(response -> log.info("Save succeeded"))
            .doOnError(error -> log.error("Save failed", error))
            .then(); // 转换为Mono<Void>，只关注完成信号
}

问题2：令牌获取+数据保存的流程优化与返回值处理 #

你的现有实现存在几个关键问题：

1. TokenService.getToken()直接调用subscribe()，导致调用方完全无法感知异步操作的执行状态（成功/失败），也无法获取结果。
2. SaveService.save()没有完成WebClient的请求链（缺少retrieve()/exchange()），而且返回null，丢失了请求的信号。
3. 流程没有通过反应式操作符串联，错误无法向上传递，也无法统一处理日志。

修正后的实现方案 #

1. SaveService的正确实现

需要完整构建WebClient请求链，返回Mono<Void>或对应的响应类型，确保请求的信号能传递：

@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();
    
    return client.post()
            .body(BodyInserters.fromPublisher(Mono.just(message), String.class))
            .retrieve()
            .bodyToMono(Void.class) // 不需要响应体时用Void
            .doOnNext(v -> log.info("Data saved successfully"))
            .doOnError(error -> log.error("Data save failed", error));
}

2. TokenService的正确实现

返回Mono<Void>（表示整个令牌获取+数据保存的流程完成），用flatMap串联两个异步操作，不直接在方法内订阅：

@Override
public Mono<Void> getTokenAndSave(String message) {
    WebClient client = WebClient.create(tokenUrl);
    return client.post()
            .accept(MediaType.APPLICATION_FORM_URLENCODED)
            .contentType(MediaType.APPLICATION_FORM_URLENCODED)
            .body(this.getFormInserter())
            .retrieve()
            .bodyToMono(String.class)
            .retry(3)
            .doOnNext(response -> log.info("Token obtained successfully"))
            .doOnError(error -> log.error("Token acquisition failed after 3 retries", error))
            .map(this::getToken) // 解析令牌
            .flatMap(token -> saveService.save(message, token)); // 串联保存操作
}

private String getToken(String responseBody) {
    JsonObject jsonObject = new Gson().fromJson(responseBody, JsonObject.class);
    return jsonObject.get(ACCESS_TOKEN_FIELD).getAsString(); // 注意用getAsString()避免带引号
}

调用方的使用方式 #

调用方通过订阅Mono<Void>来触发整个流程，并处理结果：

tokenService.getTokenAndSave(message)
    .subscribe(
        () -> { /* 流程全部完成的处理 */ },
        error -> { /* 处理整个流程中的错误（令牌获取失败/保存失败） */ }
    );

日志补充建议 #

• 在每个异步操作的doOnNext中记录成功日志，doOnError中记录错误日志（包含异常栈信息）。
• 可以统一通过onErrorResume处理特定错误，比如令牌过期、权限不足等，输出更友好的日志。

内容的提问来源于stack exchange，提问作者Jonathan Hagen