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 閱讀(615) 評論(0)  編輯  收藏 所屬分類: REACTIVE STREAMSEVEN DRIVEN ARCHITECT

          主站蜘蛛池模板: 缙云县| 舟曲县| 天祝| 萝北县| 麻阳| 锡林浩特市| 江安县| 琼海市| 游戏| 孙吴县| 沂南县| 建始县| 桃园市| 拜泉县| 澳门| 墨脱县| 光泽县| 佛学| 广西| 武胜县| 从江县| 临沂市| 三河市| 建昌县| 临潭县| 吉水县| 闽清县| 新竹市| 金平| 林州市| 吴桥县| 湖北省| 凤山市| 芜湖县| 桂林市| 平安县| 宝清县| 锡林郭勒盟| 板桥市| 沙雅县| 吉木萨尔县|