gpt4 book ai didi

java - 使用 Spring WebClient 发出多个请求

转载 作者:行者123 更新时间:2023-12-02 01:31:46 25 4
gpt4 key购买 nike

所以我的目标是使用 WebClient 发出多个并发请求,等到它们全部完成,然后合并结果。这是我到目前为止所拥有的:

...

Flux<ServerResponse> feedResponses = request
.bodyToMono(AddFeedRequestDto.class)
.map(AddFeedRequestDto::getFeeds) // Returns a list of RSS feed URLs
.map(this::getServerResponsesFromUrls) // Returns a list of Mono<Feed>
.map(Flux::merge) // Wait til all requests are completed
// Not sure where to go from here

...

/** Related methods: **/

private List<Mono<Feed>> getServerResponsesFromUrls(List<String> feedUrls) {
List<Mono<Feed>> feedResponses = new ArrayList<>();
feedUrls.forEach(feedUrl -> feedResponses.add(getFeedResponse(feedUrl)));
return feedResponses;
}

public Mono<Feed> getFeedResponse(final String url) {
return webClient
.get()
.uri(url)
.retrieve()
.bodyToMono(String.class) // Ideally, we should be able to use bodyToMono(FeedDto.class)
.map(this::convertResponseToFeedDto)
.map(feedMapper::convertFeedDtoToFeed);
}

/** Feed.java **/
@Getter
@Setter
public class Feed {
List<Item> items;
}

基本上,我的目标是将每个提要中的所有项目组合起来创建一个统一的提要。但是,我不太确定调用 Flux::merge 后要做什么。如有任何建议,我们将不胜感激。

最佳答案

使用.flatMap而不是.map/Flux.merge,如下所示:

Mono<Feed> unifiedFeedMono = request
.bodyToMono(AddFeedRequestDto.class) // Mono<AddFeedRequestDto>
.map(AddFeedRequestDto::getFeeds) // Mono<List<String>> feedUrls
.flatMapMany(Flux::fromIterable) // Flux<String> feedUrls
.flatMap(this::getFeedResponse) // Flux<Feed>
.map(Feed::getItems) // Flux<List<Item>>
.flatMap(Flux::fromIterable) // Flux<Item>
.collectList() // Mono<List<Item>>
.map(Feed::new); // Mono<Feed>

请注意,.flatMap 是异步操作,将并行执行请求。如果您想限制并发,有一个重载版本需要 concurrency 参数。

.flatMap 不保证排序,并且生成的项目可能会交错。如果您想要更多的排序保证,请替换 .concatMap.flatMapSequential

关于java - 使用 Spring WebClient 发出多个请求,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55932242/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com