如何使用对象内部的流量作为JSON响应？

Question

在我的Spring Webflux API网关中，我通过REST从微服务接收流量：

public Flux<MyObject> getMyObjects(String id) {

    Flux<MyObject> myObjects = webClient.get().uri(nextServerUrl + "/myobject" + issueId)
            .accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .bodyToFlux(MyObject.class);

    return myObjects;
}

我必须重新排列API网关中微服务接收到的信息，以便响应客户端。我尝试了两种方法：

1. 尽可能使用Flux：

    private Rearranged createClientResponse(String id) {
        Rearranged rearranged = new Rearranged();

        Flux<MyObject> myObjects = myObjectService.getMyObjects(id);

        rearranged.setMyObjects(myObjects);

        myObjects.map(myObject -> {
            rearranged.setInfo(myObject.getInfo());

            //set more

            return myObjects;
        });

        return rearranged;
    }

    public class Rearranged {
        private Flux<MyObject> myObjects;
        //more attributes
    }

结果：以下为空对象：

{
    "information": null,
    "myObjects": {
        "scanAvailable": true,
        "prefetch": -1
    }
}

    private Rearranged createClientResponse(String id) {
        Rearranged rearranged = new Rearranged();

        List<MyObject> myObjects = myObjectService.getMyObjects(id).collectList().block();

        rearranged.setMyObjects(myObjects);

        rearranged.setInfo(myObjects.get(0).getInfo());

        return rearranged;
    }

    public class Rearranged {
        private List<MyObject> myObjects;
        //more attributes
    }

结果：接收异常块（）/blockFirst（）/blockLast（）时，线程中不支持阻塞

要实现从微服务响应重新排列信息以响应客户机的可能性，正确的方法是什么？我如何才能阻止通量完成？我知道当我返回一个“同步”对象时，一个块是可能的（就像我正在做的，但仍然得到异常）？

Answer 1

首先，您的模型不应该计算反应流。使用普通对象或列表。

public class Rearranged {
        private MyObject myObject;       
}

或者

public class Rearranged {
        private List<MyObject> myObjects;       
}

如果阻塞线程，反应器线程将在片刻内耗尽。如果getMyObject方法只接收一个对象（如果没有，请查看注释的末尾），那么您应该将其作为Mono处理。然后在createClient响应中，您必须返回Mono

 private Mono<Rearranged> createClientResponse(String id) {

       Mono<MyObject> myObjects = myObjectService.getMyObjects(id);

       return myObjects.map(myObject -> {
           retrun new Rearranged(myObject)
            //create the proper object here
        });

    }

如果您需要更多的对象，您可以使用相同的方法，例如，CollectList（）从Flux收集元素