reactor使用方法_Project Reactor展开方法

港控/mmm° 2023-02-25 05:56 57阅读 0赞

reactor使用方法

最近，我的一位同事向我介绍了Project Reactor类型的[expand][]运算符，在这篇文章中，我想介绍几种使用它的方式。

## 展开分页结果 ##

考虑在名为City的模型上基于[Spring Data][]的存储库：

import org.springframework.data.jpa.repository.JpaRepository;  import samples.geo.domain.City;  public interface CityRepo extends JpaRepository<City, Long> {  }

该存储库提供了一种检索分页结果的方法，大致如下：

cityRepo.findAll(PageRequest.of( 0 , 5 ))

现在，如果我要将多个页面展开到一个结果中，执行此操作的方法将是以下一种循环：

var pageable: Pageable = PageRequest.of( 0 , 5 )  do { 
         var page: Page<City> = cityRepo.findAll(pageable) 
         page.content.forEach { city -> LOGGER.info( "City $city" ) } 
         pageable = page.nextPageable()  } while (page.hasNext())

可以使用Reactor扩展运算符通过以下方式完成分页结果的等效展开：

val result: Flux<City> = 
         Mono 
             .fromSupplier { cityRepo.findAll(PageRequest.of( 0 , 5 )) } 
             .expand { page -> 
                 if (page.hasNext()) 
                     Mono.fromSupplier { cityRepo.findAll(page.nextPageable()) } 
                 else 
                     Mono.empty() 
             } 
             .flatMap { page -> Flux.fromIterable(page.content) }  result.subscribe( 
         { page -> LOGGER.info( "City ${page}" ) }, 
         { t -> t.printStackTrace() }  )

在这里，结果的第一页扩展到第二页，第二页扩展到第三页，依此类推，直到没有要检索的页面为止。

## 遍历一棵树 ##

考虑以下模型表示的树结构中的节点：

data class Node( 
         val id: String, 
         val nodeRefs: List<String>,  )

样本数据如下所示：

![format_png][]

可以使用如下所示的调用遍历：

val rootMono: Mono<Node> = nodeService.getNode( "1" )  val expanded: Flux<Node> = rootMono.expand { node -> 
         Flux.fromIterable(node.childRefs) 
             .flatMap { nodeRef -> nodeService.getNode(nodeRef) }  }  expanded.subscribe { node -> println(node) }

这是广度优先的扩展，输出如下所示：

Node- 1  Node- 1 - 1  Node- 1 - 2  Node- 1 - 1 - 1  Node- 1 - 1 - 2  Node- 1 - 2 - 1  Node- 1 - 2 - 2

expandDeep变体将深度优先遍历

> 翻译自: [https://www.javacodegeeks.com/2020/02/project-reactor-expand-method.html][https_www.javacodegeeks.com_2020_02_project-reactor-expand-method.html]

reactor使用方法

[expand]: https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#expand-java.util.function.Function-
[Spring Data]: https://docs.spring.io/spring-data/jpa/docs/current/reference/html/#reference
[format_png]: /images/20230209/1fbc22dfa631451d93a251c1edd20293.png
[https_www.javacodegeeks.com_2020_02_project-reactor-expand-method.html]: https://www.javacodegeeks.com/2020/02/project-reactor-expand-method.html