无法从Flux转换为List

Question

我在我的项目中使用spring webflux与外部API进行通信。在我的项目中，我无法将Flux转换为List。

在尝试对collectList（）.block（）执行同样的操作时，flux的所有元素都被连接到一个字符串中，并存储在List的第0个索引处。如果我返回Flux而不是List，那么它会发送预期的响应。但我需要操作内容并将其作为子对象添加到其他对象中&因此尝试返回列表。

public List<String> retrieveWebLogin(String platformId) {
    try {
        ClientResponse response = webClient
                .get()
                .uri(EV_LEGACY_WEB_RTC_ENDPOINT_API_PATH)
                .accept(APPLICATION_JSON)
                .exchange().block();

        Flux<String> uriFlux = response.bodyToFlux(String.class);

        List<String> uriList = uriFlux.collectList().block();
        return uriList;

    } catch (Exception e) {
        logger.info(e.getMessage(), e);
    }
    return null;
}

预期结果:[“Agent1”,“Agent2”]

实际结果：“[”Agent1“,”Agent2“]”

Answer 1

您的代码应该是这样的。

final List<String> uriList = webClient
            .get()
            .uri(EV_LEGACY_WEB_RTC_ENDPOINT_API_PATH)
            .accept(MediaType.APPLICATION_JSON_UTF8)
            .exchange()
            .flatMap(response -> response.bodyToMono(new ParameterizedTypeReference<List<String>>() {}))
            .block();