不适当的阻塞方法调用(使用reactor.core.publisher.mono< t>)

yws3nbqq 于 2021-07-23 发布在 Java

关注(0)|答案(1)|浏览(209)

你能帮我理解你为什么给我这个警告吗？
本质上，这个post调用给我结果（userpayload），我在进一步的post调用中重用这些结果，并将数据保存到db中。
怎么了？
public monocreateuser（用户请求有效负载）{

return webClientBuilder
            .build()
            .post()
            .uri(settings.getUrl())
            .accept(MediaType.APPLICATION_JSON)
            .contentType(MediaType.APPLICATION_JSON)
            .header("Authorization", settings.getApiToken())
            .body(BodyInserters.fromValue(requestPayload))
            .exchange()
            .flatMap(clientResponse -> {
                if (clientResponse.statusCode().isError()) {
                    return clientResponse.bodyToMono(Error.class)
                            .flatMap(error -> Mono.error(new CustomException(clientResponse.statusCode(), error)));
                } else {
                    return clientResponse.bodyToMono(UserPayload.class)
                            .flatMap(user -> {
                                saveNewUser(user);
                                validateUser(user.getLinks());
                                return Mono.just(new ResponseEntity<>(user, HttpStatus.OK));
                            }).switchIfEmpty(Mono.error(new NotFoundCustomException("User Payload not found!")));
                }
            }); 

}

第二种方法：
专用mono validateuser（字符串uri）{

webClientBuilder
            .build()
            .post()
            .uri(uri)
            .accept(MediaType.APPLICATION_JSON)
            .contentType(MediaType.APPLICATION_JSON)
            .header("Authorization", settings.getApiToken())
            .retrieve()
            .onStatus(HttpStatus::isError, clientResponse -> clientResponse.bodyToMono(Error.class)
                    .flatMap(error -> Mono.error(new CustomException(clientResponse.statusCode(), error)))
            ).bodyToMono(Void.class);
}

Java spring spring-boot spring-webflux

来源：https://stackoverflow.com/questions/66152488/inappropriate-blocking-method-call-using-reactor-core-publisher-monot

1条答案

按热度按时间

yyyllmsg1#

最后，我就这样解决了：

public Mono<ResponseEntity<UserPayload>> createUser(UserRequest requestPayload) {

        return webClientBuilder
                .build()
                .post()
                .uri(settings.getUrl())
                .accept(MediaType.APPLICATION_JSON)
                .contentType(MediaType.APPLICATION_JSON)
                .header("Authorization", settings.getApiToken())
                .body(BodyInserters.fromValue(requestPayload))
                .retrieve()
                .onStatus(HttpStatus::isError, errorResponse -> errorResponse
                        .bodyToMono(Error.class)
                        .flatMap(error -> Mono.error(new CustomException(errorResponse.statusCode(), error))))
                .bodyToMono(UserPayload.class)
                .flatMap(user -> {
                return Mono.fromSupplier(()->repository.save(convertFromPayloadUser(user)))
                        .subscribeOn(Schedulers.boundedElastic())
                        .then(validateUser(user.getLinks()))
                        .then(Mono.just(new ResponseEntity<>(user, HttpStatus.OK)));
            }).switchIfEmpty(Mono.error(new NotFoundCustomException("User Payload not found!")));
    }

第二种方法：

private Mono<Void> validateUser(String uri) {
        return webClientBuilder
                .build()
                .post()
                .uri(uri)
                .accept(MediaType.APPLICATION_JSON)
                .contentType(MediaType.APPLICATION_JSON)
                .header("Authorization", settings.getApiToken())
                .retrieve()
                .onStatus(HttpStatus::isError, clientResponse -> clientResponse.bodyToMono(Error.class)
                        .flatMap(error -> Mono.error(new CustomException(clientResponse.statusCode(), error)))
                ).bodyToMono(Void.class);
    }

赞(0）回复(0）举报 2021-07-23

我来回答

不适当的阻塞方法调用(使用reactor.core.publisher.mono< t>)

1条答案

相关问题

热门标签

最新问答