SPRING REACTOR 之Flux和Mono
SPRING REACTOR 之Flux和Mono,有點象SPRING INTEGRATION的IntegrationFlow,有如下特點
編程則比較簡單,先根據(jù)不同的數(shù)據(jù)類型定義不同的Flux或Mono,業(yè)務操作用Function包裝后,放在map/flatmap中,再調(diào)用subscribe啟動流程。
- 定義了針對某種類型數(shù)據(jù)的處理流程
- 可以進行類型轉(zhuǎn)換
- 長期運行,除非被要求中止
- 流程中的每種操作可以在新的線程中執(zhí)行
- 可以正常中止,如果中途有異常,則該流程也會中止
- 要subscribe,流程才開始被啟動
- 可以分割成各個子流程
- 可以聚合子流程
- Mono發(fā)送一個數(shù)據(jù),就發(fā)送中止信號
- Flux發(fā)送任意數(shù)據(jù),由程序決定何時發(fā)送中止信號
編程則比較簡單,先根據(jù)不同的數(shù)據(jù)類型定義不同的Flux或Mono,業(yè)務操作用Function包裝后,放在map/flatmap中,再調(diào)用subscribe啟動流程。
posted on 2021-11-23 14:30 paulwong 閱讀(615) 評論(0) 編輯 收藏 所屬分類: REACTIVE STREAMS 、EVEN DRIVEN ARCHITECT