最近，我的一位同事向我介紹了Project Reactor類型的expand運(yùn)算符，在這篇文章中，我想介紹幾種使用它的方式。

展開(kāi)分頁(yè)結(jié)果

考慮在名為City的模型上基于Spring Data的存儲(chǔ)庫(kù)：

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

該存儲(chǔ)庫(kù)提供了一種檢索分頁(yè)結(jié)果的方法，大致如下：

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

現(xiàn)在，如果我要將多個(gè)頁(yè)面展開(kāi)到一個(gè)結(jié)果中，執(zhí)行此操作的方法將是以下一種循環(huán)：

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 expand運(yùn)算符通過(guò)以下方式完成分頁(yè)結(jié)果的等效展開(kāi)：

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() } )

在這里，結(jié)果的第一頁(yè)擴(kuò)展到第二頁(yè)，第二頁(yè)擴(kuò)展到第三頁(yè)，依此類推，直到?jīng)]有要檢索的頁(yè)面為止。

遍歷一棵樹(shù)

考慮以下模型表示的樹(shù)結(jié)構(gòu)中的節(jié)點(diǎn)：

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

樣本數(shù)據(jù)如下所示：

可以使用如下所示的調(diào)用遍歷：

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) }

這是廣度優(yōu)先的擴(kuò)展，輸出如下所示：

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變體將深度優(yōu)先遍歷

翻譯自: https://www.javacodegeeks.com/2020/02/project-reactor-expand-method.html

總結(jié)

以上是生活随笔為你收集整理的Project Reactor展开方法的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。