spring webflux：如何在不阻塞的情况下从Mono或Flux响应中提取用户定义的对象？

Question

getUserDetails方法返回JsonNode类型的Mono。但我真的想退货

public Mono<JsonNode> getUser(BigInteger Id){
    return this.client.get()
            .uri("/URL/{Id}",Id)
            .retrieve()
            .bodyToMono(JsonNode.class);
}

public Flux getBulkUsers(List<BigInteger> Ids){
    return Flux.fromIterable(Ids).flatMap(this::getUser);
}

但是来自Url的json响应类似于

{
"resultholder": {
            "totalResults": "1",
            "profiles": {
                "profileholder": {
                    "user": {
                        "country": "IND",
                        "zipCode": "560048",
                        "name":"Test"
                    }
                }
            }            
        }
}

我尝试了不同的方法，但都不管用。doOnNext（分别为-

    .bodyToMono(JsonNode.class)
.doOnNext(resp ->{return
 JSONUtils.deserialize(resp.get("resultholder").get("profiles").get("profileholder").get("user"), User.class)})

Answer 1

这非常简单，不需要阻止。它只是在响应上应用进一步的映射。您可以使用以下代码解决问题

 return webClient
            .get()
            .uri("profilesEndPoint/" + id)
            .retrieve()
            .bodyToMono(JsonNode.class)
            .map(jsonNode ->
                    jsonNode.path("resultholder").path("profiles").path("profileholder").path("user")
            ).map(
                    userjsonNode -> mapper.convertValue(userjsonNode, User.class)
            );

Mapper是Jackson ObjectMapper的地方

private final ObjectMapper mapper=new ObjectMapper（）；

如果您有任何问题，请参考以下代码：