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