spring-webflux - Webflux 链接多个 Mono
问题描述
我是响应式编程(Spring webflux)的新手,想知道如何最好地处理这个用例。我有一个返回 Mono 的反应式服务调用 ( getAccount ),我想将它与另一个返回Mono<Set>的服务调用getBooks和一个执行某种转换并返回类似Mono<Set>的最终同步调用转换链接起来。当getAccount或getBooks返回空时记录警告时,我会以Mono<Set>的形式链接并返回转换后的数据吗?这是我试图做的一个简化版本的例子。
鉴于这里有一些虚假服务
public static Mono<String> getAccount(String name){
return Mono.just(name);
}
public static Mono<Set<Book> getBooks(String title){
return Mono.just(Sets.newHashSet(new Book(title + "One", "Author One"),
new Book(title +"Two", "Author Two"),
new Book(title + "Three", "Author Three")));
}
public static LibraryBook transform (Book a){
return new LibraryBook(a.getTitle(), a.getAuthorName(), "someUniqueId");
}
我想获取给定用户的帐户并找到他/她借的所有书籍并转换书籍并将值作为 Mono<Set> 返回值,同时在适当的地方记录警告
这是我的开始
public Mono<Set<LibraryBook>> getBorrowedBooks(String userId) {
return getAccount(userId)
.flatMap(account -> getBooks(account))
.log()
.map(books -> books.stream().map(book -> transform(book)).collect(Collectors.toSet()))
}
但是,我不确定混合响应式和流式是否是一件坏事,而且它看起来不正确。
解决方案
更新:
由于您无法修改getBooks方法,因此您可以通过以下方式构造您的getBorrowedBooks方法以避免处理流。
注意 - 记录器和异常只是示例。您也可以用不同的方式处理空场景。
public class MyApp {
private static final Logger LOGGER = LoggerFactory.getLogger(MyApp.class);
public static void main(String[] args) {
List<LibraryBook> libraryBooks = getBorrowedBooks("Abhi").collectList().block();
libraryBooks.forEach(System.out::println);
}
public static Mono<String> getAccount(String name) {
return Mono.just(name);
}
public static Mono<Set<Book>> getBooks(String title) {
return Mono.just(Sets.newHashSet(new Book(title + "One", "Author One"),
new Book(title + "Two", "Author Two"),
new Book(title + "Three", "Author Three")));
}
public static LibraryBook transform(Book a) {
return new LibraryBook(a.getTitle(), a.getAuthorName(), "someUniqueId");
}
public static Flux<LibraryBook> getBorrowedBooks(String userId) {
return getAccount(userId)
.switchIfEmpty(Mono.defer(() -> {
LOGGER.error("No account found");
return Mono.error(new NoAccountFoundException());
}))
.flatMap(account -> getBooks(account))
.flatMapMany(Flux::fromIterable)
.switchIfEmpty(Mono.defer(() -> {
LOGGER.error("No books found for account");
return Mono.error(new NoBooksFoundForGivenAccountException());
}))
.map(MyApp::transform);
}
明智地编译这是正确的。但从逻辑上讲,我认为这是不正确的,因为您没有考虑单声道和通量的定义。
Mono 是 0..1 个元素的流。Flux 是一个可以发出 0..N 个元素的流。
getBooks方法(顾名思义)应该为给定的标题发出超过 1 个元素(这里是 Book)。所以它的返回类型应该是flux而不是集合的Mono。
甚至您也可以从 Spring 的响应式存储库方法中获取示例:
现在,在响应式世界中,删除重复项并将集合存储在 hashset 中的想法与在Flux 元素上调用distinct()同义。
因此,您的getBooks方法应如下所示:
public static Flux<Book> getBooks(String title){
return Flux.just(new Book(title + "One", "Author One"),
new Book(title +"Two", "Author Two"),
new Book(title + "Three", "Author Three"))
.distinct();
}
您的getBorrowedBooks方法应如下所示:
public Flux<LibraryBook> getBorrowedBooks(String userId) {
return getAccount(userId)
.flatMapMany(account -> getBooks(account))
.log()
.map(book -> transform(book));
}
推荐阅读
- amazon-dynamodb - AWS AppSync - DeleteItem 不执行响应映射模板
- java - Action on Google Javadoc 和示例中的不一致
- node.js - 节点 zlib 增量膨胀
- javascript - 输出工作并获得“未定义”值
- javascript - Mongoose:尝试使用 (id) 检索文档 - 获取 NULL
- opengl - 无法让 Tessallation 着色器工作
- python - 如何部署我们的 ML 训练模型?
- php - PHP MySQLi:变量问题
- angular - angular ngx-bootstrap onClick 警报模块
- angular - 如何从 ngbdatepicker 角度禁用现有日期