如何在包装类中合并两个spring boot微服务响应

Question

我是Spring boot微服务和探索webflux框架的新手。我试图将来自两个微服务的响应合并到一个包装类中，以获得正确的JSON响应。下面是详细的场景。

微服务1:http://localhost:8080/该微服务的控制器中的产品其返回流量和我得到

[
    {
        "id": "5b2fd1e5f57d731904c54ad7",
        "name": "Product3",
        "price": "30"
    },
    {
        "id": "5b2fd1e4j9fdj3kds9djkj43",
        "name": "Product2",
        "price": "20"
    }
]

微服务2:http://localhost:8181/person In controller of second Service其返回单声道，对此我也得到如下正确响应，

{
    "id": ehj8u3jmodmdj,
    "name": "PersonXXX",
    "email": "[e-mail]"
}

现在我想创建另一个微服务http://localhost:8282/personproduct它应该将上述两个微服务的结果组合在一个包装类中，如下所示，

{
    {
        "id": ehj8u3jmodmdj,
        "name": "PersonXXX",
        "email": "[e-mail]"
    },

    [
        {
            "id": "5b2fd1e5f57d731904c54ad7",
            "name": "Product3",
            "price": "30"
        },
        {
            "id": "5b2fd1e4j9fdj3kds9djkj43",
            "name": "Product2",
            "price": "20"
        }
    ]

}

现在，我有了一个产品类和个人类的父类实体，我通过WebClient调用上述两个微服务，并使用Flux进行响应。concat（人员响应、产品响应）；其中personResp是Mono类型，productResp是Flux类型，但我得到的这个（第三个）微服务的响应只有文本，而不是JSON，如下所示，

data:{"id":ehj8u3jmodmdj,"name":"PersonXXX","email":"[e-mail]"}
data:{"id":"5b2fd1e5f57d731904c54ad7","name":"Product3","price":"30"}
data:{"id":"5b2fd1e4j9fdj3kds9djkj43","name":"Product2","price":"20"}

这可能是由于每个元素都作为不同的流发送。

因此，我只想知道是否有任何方法可以将两个响应组合到一个包装器类中，而无需在对这两个服务执行的任何调用中使用block（）方法。

更新

目前我将产品微服务称为，

clientProd.get().uri(productUrl)
                .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .retrieve().bodyToFlux(Product.class).onErrorReturn(new Product());

并且类似地，

clientPerson.get().uri(personUri)
                .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
                .retrieve().bodyToMono(Person.class).onErrorReturn(new Person());

连接是使用Flux.concat（），

提前致谢。

Answer 1

正确的方法是将这些响应映射到类：

public class Product{
    private Long id;
    private String name;
    private Double price;

    //constructors, getters, setters
}

public class Person{
    private Long id;
    private String name;
    private String mail;

    //constructors, getters, setters
}

public class Entity{
    private Person person;
    private List <Product> products;

    //constructors, getters, setters
}

这样，您就有了三种不同的POJOs，您可以根据需要（调用的API类型）使用它们。