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

樣本數據如下所示：

可以使用如下所示的調用遍歷：

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

reactor使用方法

總結

以上是生活随笔為你收集整理的reactor使用方法_Project Reactor展开方法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。