我想進行一個異步休息調用，我正在使用 spring webclient 并取回 Mono。我也在并行進行一些數據庫調用，但由于某種原因無法被動完成。 Map<String, Object> models = new HashMap<>(); Mono<User> users = this.webClient...; users.map(resp -> new UserState(userRequest, resp)) .subscribe(response -> { models.put("userState", response); }); Iterable<Product> messages = this.productRepository.findAll(); models.put("products", messages); //Wait for users.subscribe to finish <<<<<<<<<<<<<HERE return new ModelAndView("messages/list", models);如何在返回 ModelAndView 之前等待訂閱完成。Future如果我使用一個我可以get()隨時隨地做的地方，這會很容易。
1 回答
搖曳的薔薇
TA貢獻1793條經驗 獲得超6個贊
您可以將阻塞調用包裝在Mono一個單獨的調度程序上執行，將其與Mono包含的UserState數據一起壓縮并將它們的組合轉換為一個Mono<ModelAndView>（可以從 Spring 控制器方法返回）。調用將并行執行，兩個調用完成后將合并結果。
您可以為每個應用程序定義一個專門用于阻塞調用的有界調度程序，并將其作為構造函數參數提供給任何進行阻塞調用的類。
代碼如下所示：
@Configuration
class SchedulersConfig {
@Bean
Scheduler parallelScheduler(@Value("${blocking-thread-pool-size}") int threadsCount) {
return Schedulers.parallel(threadsCount);
}
}
@RestController
class Controller {
final Scheduler parallelScheduler;
...
Mono<User> userResponse = // webClient...
Mono<Iterable<Product>> productsResponse = Mono.fromSupplier(productRepository::findAll)
.subscribeOn(parallelScheduler);
return Mono.zip(userResponse, productsResponse, (user, products) ->
new ModelAndView("messages/list",
ImmutableMap.of(
"userState", new UserState(userRequest, user),
"products", products
))
);
}
根據評論更新：
如果您只需要異步執行 HTTP 調用，然后將其與數據庫結果結合起來，您可以執行以下操作
Map<String, Object> models = new HashMap<>();
Mono<User> userMono = webClient...;
CompletableFuture<User> userFuture = userMono.toFuture();
Iterable<Product> messages = productRepository.findAll();
User user = userFuture.join();
models.put("products", messages);
models.put("userState", new UserState(userRequest, user));
return new ModelAndView("messages/list", models);
添加回答
舉報
0/150
提交
取消