paulwong

          SPRING REACTOR 之Flux和Mono

          SPRING REACTOR 之Flux和Mono,有點象SPRING INTEGRATION的IntegrationFlow,有如下特點
          • 定義了針對某種類型數(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 閱讀(618) 評論(0)  編輯  收藏 所屬分類: REACTIVE STREAMSEVEN DRIVEN ARCHITECT


          只有注冊用戶登錄后才能發(fā)表評論。


          網(wǎng)站導航:
           
          主站蜘蛛池模板: 石屏县| 灵武市| 星座| 阜康市| 通道| 四会市| 绥棱县| 南澳县| 台州市| 永兴县| 额尔古纳市| 镇原县| 高雄市| 响水县| 梅河口市| 南岸区| 德保县| 临湘市| 海宁市| 南丰县| 方城县| 新巴尔虎左旗| 墨脱县| 扬州市| 山西省| 贵州省| 苏州市| 靖远县| 凤山县| 应用必备| 习水县| 军事| 泸溪县| 伊吾县| 本溪市| 扶沟县| 云浮市| 蒲城县| 临洮县| 河东区| 望奎县|