使用WEBCLIENT使用请求后客户端方法

Question

我是WebClient字段的新手，但我遇到了以下问题。这是我的客户端方法，您已经看到它应该插入我发送到数据库参数的值，但我无法插入它。

 @Override
    public Mono<BulkSmsRequestResource> sendSms(BulkSmsRequestResource request) {
        Mono<BulkSmsRequestResource> bulkSmsRequestResourceMono = webClientBuilder.build()
                .post()
                .uri(url1)
                .body(Mono.just(request), BulkSmsRequestResource.class)
                .retrieve()
                .bodyToMono(BulkSmsRequestResource.class);
        return bulkSmsRequestResourceMono;

    }

我在这里写的代码是我的控制器区域。

@PostMapping("/send")
public ResponseEntity<? extends ResponseResource> sendSms(@RequestBody BulkSmsRequestResource request) {
    if (request == null) {
        return new ResponseEntity<>(
                new ErrorResponseResource(
                        "Transaction failed successfully!",
                        400),
                HttpStatus.BAD_REQUEST);
    }
    this.smsSendService.sendSms(request);
    return new ResponseEntity<>(new SuccessResponseResource("Transaction done successfully", 200), HttpStatus.OK);

}

当我运行我的方法时，我无法将值添加到服务器端的数据库中，但我可以使用以下使用客户端方法的方法从那里获取值。

@Override
public Flux<BulkSmsResponseDto> findAll() {
    Flux<BulkSmsResponseDto> bulkSmsResponseDtoFlux = webClientBuilder.build()
            .get()
            .uri(url2)
            .retrieve()
            .bodyToFlux(BulkSmsResponseDto.class);
    return bulkSmsResponseDtoFlux;
}

Answer 1

为了触发WebClient响应式请求，您必须订阅lattery以触发HTTP调用：

service.sendSms(request)
    .subscribe(System.out::println);

否则，您将必须链接Mono

因此，为了在控制器endpoint调用时触发WebClient请求，您必须将其返回结果映射到正确的响应实体，然后返回结果Mono：

@PostMapping("/send")
public Mono<ResponseEntity<? extends ResponseResource>> sendSms(@RequestBody BulkSmsRequestResource request) {
    if (request == null) {
        return Mono.just(new ResponseEntity<>(
                new ErrorResponseResource(
                        "Transaction failed successfully!",
                        400),
                HttpStatus.BAD_REQUEST));
    }
    return this.smsSendService.sendSms(request)
        .map(result -> new ResponseEntity<>(new SuccessResponseResource("Transaction done successfully", 200), HttpStatus.OK));
}

设计侧注：可能需要使用正确的HTTP代码（201）以及对所创建资源的引用来更新响应。