我可以将Flux作为ServerResponse主体的字段吗？

Question

我是Spring Reactive Web的新手，我遇到了以下问题。我想创建一个微服务A，它的endpoint接受一个数字N，向微服务B发送N个请求(微服务B为每个请求返回一个字符串)，将字符串包装成对象，将它们组合成一个List/Flux(？)并返回带有这些对象的JSON，比如:

{
  "number": 4,
  "objects": [
    {
       "name": "first"
    },
    {
       "name": "second"
    },
    {
       "name": "third"
    },
    {
       "name": "fourth"
    }
  ]
}

我想为此使用一个功能endpoint。所以我尝试了以下方法（尽量简化）：

public class MyObject {
    private String name; // here should be a value received from B
    // ...
}

public class MyResponse {
    private int number;
    private Flux<MyObject> objects; // or List?
    // ...
}

@Component
@RequiredArgsConstructor
public class MyHandler {

    private final MyClient client;

    public Mono<ServerResponse> generate(ServerRequest serverRequest) {
        return serverRequest.bodyToMono(MyRequestBody.class)
                .flatMap(request -> buildServerResponse(HttpStatus.OK, buildResponseBody(request)));
    }

    private Mono<ServerResponse> buildServerResponse(HttpStatus status, Mono<MyResponse> responseBody) {
        return ServerResponse.status(status)
                .contentType(MediaType.APPLICATION_JSON)
                .body(responseBody, MyResponse.class);
    }

    private Mono<MyResponse> buildResponseBody(MyRequestBody request) {
        return Mono.just(MyResponse.builder()
                .number(request.getNumber())
                .objects(getObjects(request.getNumber())
                .build());
    }

    private Flux<MyObject> getObjects(int n) {
        // how to receive n strings from MyClient, make MyObject from each of them and then combine them together to a Flux/List?
    }

public class MyClient {
    public Mono<String> getName() {
        WebClient client = WebClient.builder().baseUrl(getUrl()).build();

        return client.get()
                // ...
                .retrieve()
                .bodyToMono(String.class);
    }

    private String getUrl() {
        // ...
    }
}

所以，如果我在我的响应中使用Flux，我会收到这样的响应:

{
  "number": 4,
  "objects": {
    "prefetch": 2147483647,
    "scanAvailable": true
  }
}

另一方面，如果我尝试使用一个List，它似乎需要在某个时刻阻塞，并且我会收到与它相关的错误。那么，我该怎么做呢？

提前感谢！

更新：如果我使用CollectList（）. block（）从Flux制作一个列表，我会收到这个：

java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is not supported in thread <...>

正如我从这个问题的答案中了解到的，当我的方法返回Mono/Flux时，我不应该阻塞。将block（）调用从返回Mono/Flux的方法中调用的单独方法例外是没有帮助的。如果我在block（）之前使用share（），那么我的请求就会永远执行，出于某种我还不明白的原因。

Answer 1

好吧，我成功了。

＜code＞Flux＜/code＞作为一个字段不能以期望的方式工作，所以我需要一个＜code＜List＞/code。

public class MyResponse {
    private int number;
    private List<MyObject> objects;
    // ...
}

现在我需要一个方法来制作一个列表。

问题是，我们永远不会摆脱单晶或助焊剂，所以我们选择助焊剂。

private Flux<MyObject> getObjects(int n) {
    return Flux.range(0, n) // Flux<Integer>
            .map(i -> myClient.getName()) // Flux<String>
            .map(name -> new MyObject(name)); // Flux<MyObject>
}

然后我们制造通量:

private Mono<MyResponse> buildResponseBody(MyRequestBody request) {
    return getObjects(request.getNumber()) // Flux<MyObject>
            .collectList() // Mono<List<MyObject>>
            .map(objects -> MyResponse.builder() // Mono<MyResponse>
                    .number(request.getNumber())
                    .objects(objects)
                    .build()));
}

这样它的工作原理是，因为我们不必阻止任何东西。

只有当我们想在某个时候摆脱Mono/Flux时，才会出现问题，比如我们想要一个纯列表