如何使用 Mono<String> 处理逗号分隔的 id 字符串

Question

我有一个 api，它给了我一个逗号分隔的 id 列表，我正在使用 Spring Boot WebClient 来调用它并处理响应。

API 响应是纯文本/文本（不是 json）的 [1,2,3,4]，我正在执行以下操作来处理结果 -

Mono<String> ids = client.get()
                .uri("http://localhost:8080")
                .retrieve()
                .bodyToMono(String.class);

我想知道如何从那里处理 ids 变量中的项目。

这个 api 的新手。

Answer 1

您可以将响应直接转换为Flux，并逐项处理

webClient.get()
        .uri("http://localhost:8080")
        .retrieve()
        .bodyToFlux(Integer.class)
        .doOnNext(id -> {
            System.out.println(id);
            // process id...
        })
        .subscribe();

另一种可能的选择是使用方法flatMapIterable 将Mono<String> 转换为Flux<Integer>：

ids.flatMapIterable(line -> Arrays.asList(line.replace("[", "").replace ("]", "").split(",")))
        .doOnNext(id -> System.out.println(id))
        .subscribe();