spring webflux webclient响应将字符串列表转换为字符串

Question

回复:

[ 
 {
  "version": "1.0",
  "content": [
    "12345",
    "67076",
    "123462",
    "604340",
    "1331999",
    "1332608",
    "1785581",
   ]
 }
]

代码:

Mono<List<String>> mp = webClient.get().uri(accountMgmtURI)
    .retrieve()
    .bodyToMono(Map.class)
    .flatMap(trans-> {
       List<String> content= (List<String>) trans.get("content");
       System.out.println("content :: "+content);
       return Mono.just(content);
     }); 
System.out.println("content :: "+mp.toString()); 
String sites=mp.toString();

Answer 1

第一个问题是您使用的 API 不是返回单个对象，而是返回一个对象数组，用方括号 ( [] ) 表示。
这意味着您至少应该重构代码以使用 bodyToFlux() 而不是 bodyToMono() :

client
    .get()
    .retrieve()
    // bodyToFlux() in stead of bodyToMono(
    .bodyToFlux(Map.class)
    // ...

第二个问题是在这种情况下使用 Map 并不容易，因为您必须一直强制转换所有内容，因为您无法传递任何泛型。与合适的类(class)一起工作，会使事情变得更容易。例如，您可以编写以下类:

public class VersionContent {
    private String version;
    private List<String> content;

    // TODO: Getters + Setters
}

并将您的代码更改为:

client
    .get()
    .retrieve()
    .bodyToFlux(VersionContent.class)
    .map(VersionContent::getContent)
    .flatMap(Flux::fromIterable)
    // ...

这段代码将检索每个对象的内容，并对其进行 flatMap，以便分别发出每个单独的值。

现在， content 数组中的每个项目都将单独发布。这将我们带到了第三个问题，即您没有连接字符串。
要连接项目，您可以使用 reduce() 运算符:

client
    .get()
    .retrieve()
    .bodyToFlux(VersionContent.class)
    .map(VersionContent::getContent)
    .flatMap(Flux::fromIterable)
    // reduce() can be used to merge all individual items to a single item
    .reduce((sites, site) -> sites + "|" + site)
    // ...

最后一个问题是您使用的是 toString() ，它不起作用。响应式编程的关键方面之一是一切都异步发生 。这意味着如果你试图在主线程中对你的数据做任何事情，什么都不会发生。
此外， Mono 和 Flux 等发布者的另一个特点是它们是 懒惰的 。如果没有适当的订阅，什么都不会发生。
解决方案是正确使用 subscribe() 来获取您的值，例如:

client
    .get()
    .retrieve()
    .bodyToFlux(VersionContent.class)
    .map(VersionContent::getContent)
    .flatMap(Flux::fromIterable)
    .reduce((sites, site) -> sites + "|" + site)
    .subscribe(System.out::println);

对于您的示例，上面的代码会将以下内容打印到控制台:

12345|67076|123462|604390|1331999|1332608|1785581

请注意，这也意味着您要对这些站点执行的每个操作都应异步完成。
如果你不想异步工作，你可以像这样使用 block() 操作符:

String sites = client
    .get()
    .retrieve()
    .bodyToFlux(VersionContent.class)
    .map(VersionContent::getContent)
    .flatMap(Flux::fromIterable)
    .reduce((sites, site) -> sites + "|" + site)
    .block();