複雜任務中,流程的解耦設計

来源:https://www.cnblogs.com/cicada-smile/archive/2022/05/08/16246368.html
-Advertisement-
Play Games

在系統開發的過程中,必然存在耗時極高的動作,是基於請求響應模式無法解決的問題,通常會採用解耦的思維,並基於非同步或者事件驅動的方式去調度整個流程的完整執行。 ...


做事不能急,得一步非同步的來;

一、業務場景

在系統開發的過程中,必然存在耗時極高的動作,是基於請求響應模式無法解決的問題,通常會採用解耦的思維,並基於非同步或者事件驅動的方式去調度整個流程的完整執行;

文件任務:在系統解析大文件數據時,在獲取任務之後,會非同步處理後續文件讀寫流程;

中間表:執行複雜場景的數據分析時,收集完待分析的對象之後,會併發執行各個維度的採集動作,並依次將數據寫入臨時的中間表中,方便數據查詢動作;

在上述場景中,基於單次請求響應無法執行整個過程,必須對流程分段分步和非同步推進,在流程中根據場景去判斷,是非同步有序驅動,還是非同步併發處理,並基於各個節點的執行狀態判斷動作是否成功。

二、任務管理

複雜任務的執行周期相對偏長,要確保穩定的執行則需要對任務做精細的設計和管理,通常會基於如下幾個因素去描述任務:

  • 場景:定義任務的主題場景,便於將多種任務做統一管理和調度,例如:文件、數據、報表等;
  • 計劃:對任務做好步驟的拆分,並制定和推進相應的執行計劃,例如:有序調度、併發執行等;
  • 狀態:針對任務和節點的執行計劃,都要提供細節的狀態定義,例如:開始/結束,進行中/已完成,成功/失敗等;

設計合理的任務結構,以便更高效的管理流程,根據主題場景做任務分類,添加相應的執行計劃,根據狀態跟蹤任務執行過程,並對失敗動作進行捕捉和重試;

三、設計思路

1、同步請求響應

服務之間的通信模式一般分為:同步和非同步兩種;同步是指在請求端發出動作之後,會一直等待響應端完成,或者響應超時導致熔斷,即在一次請求調用中耦合所有的處理流程;

服務中大部分的請求都是同步響應模式,可以提高系統的響應速度;但是在分散式中,首先要控制超時熔斷的時間,避免在流量高峰期請求堆積,拖垮整個服務;另外對於被大量調用的公共服務,要提高併發的支撐能力,降低對請求鏈路的性能影響。

2、非同步解耦模式

非同步模式的最大優點就是實現請求和響應的完全解耦,任務只需要觸發一次開始動作,後續的流程就會逐步的推進直到結束;各個服務節點處理邏輯不會受到整個請求鏈路的耗時限制;

實現非同步有多種方式,例如:請求回調、發佈訂閱、Broker代理等;在之前非同步章節中有詳細描述,這裡不再贅述;非同步消除了服務節點之間的依賴關係,但是也同樣提高了流程的複雜性;

3、事件驅動設計

事件驅動是一個抽象的概念,即通過事件的方式實現多個服務間的協同,驅動整個流程的處理邏輯;在業務層面是一種設計思想,在技術層面通常採用發佈訂閱的方式,同樣也可以消除服務間的強依賴關係;

事件和非同步在模式上很類似,事件驅動在設計上更加精細,例如在訂單場景中:將訂單的狀態變化作為一個事件,服務間通過消息傳遞的方式,依次處理庫存服務、物流服務等;由於事件攜帶了一定的業務信息和狀態,流程解耦更加徹底的同時複雜度也會更高。

四、實踐總結

1、結構設計

在結構設計中圍繞任務、節點、數據三個核心要素,以確保對任務的執行過程有完整的跟蹤和管理,要實現對任務的節點及相關的操作,具備執行重試或者直接取消撤回的控制;

狀態管理是一項很複雜的工作,要衡量任務中各個狀態標識是否合理,就要實時監控狀態的變化,並且基於各種極端情況去驗證流程,例如:重試設計、任務取消、任務暫停。

2、高併發管理

任務型的場景加上複雜的管理流程,執行時間自然也很長,如果場景中涉及到大文件的解析、或者數據調度,自然會引入任務分割與併發執行的機制;

比較常用的思路:根據任務調度的集群數,對數據核心編號進行哈希計算,可以採用取模和分段兩種演算法,然後基於多線程的方式併發處理各自服務內的分管任務。

3、管理模型

不管是觀察者模式,或者發佈訂閱模型,又或者說事件驅動設計,都可以理解為生產/消費的關係模型,圍繞生產、存儲、消費三個節點做管理;

  • 生產端:負責創建具體的消息主體,在匯流排模式中,通常將消息進行入庫存儲,然後再執行隊列推送,並跟蹤該過程的狀態變化,保證庫和隊列的一致性;
  • 消息體:描述動作的發佈方和消費方,關鍵的狀態信息變化,唯一標識和創建時間及版本,其餘則根據場景需要定義即可;
  • 消費端:在消費時要關註的核心問題即失敗重試,要避免重試機制引起數據不一致的問題,可以對消費進行加鎖或者消息狀態校驗,以實現冪等的效果;
  • 存儲端:通常採用資料庫和消息中間件雙存儲的模式,並且需要保證二者動作的同時成功或者失敗,順序為先入庫再執行隊列推送;

整個模型在設計思路上比較合理,但是架構的複雜性也變的很高,比如數據一致性問題、狀態機制、事務、冪等性、流程中斷等;整個鏈路需要詳細的追蹤記錄並且可視化管理,開發補償動作的介面,用來及時解決可能出現的突發問題。

4、組件案例

Spring框架本身就極具複雜度,這裡單看事件模型的設計,包含三個核心角色:事件、發佈、監聽;與觀察者設計模式在理念上相同;

事件:ApplicationEvent基礎抽象類繼承自JDK中EventObject類,具體事件要繼承該類;source事件源,timestamp發生的系統時間;

public class OrderState {
    // 基礎要素
    private Integer eventId ;
    private String version ;
    private Long createTime ;

    // 消息定位
    private String source ;
    private String target ;

    // 狀態變化
    private Integer orderId ;
    private Integer stateFrom ;
    private Integer stateTo ;
}
public class OrderStateEvent extends ApplicationEvent {
    public OrderStateEvent (OrderState orderState){
        super(orderState);
    }
}

發佈者:Spring定義的頂級介面ApplicationEventPublisher,提供事件發佈的能力;

@Service
public class EventService implements ApplicationContextAware, ApplicationEventPublisherAware {
    private ApplicationEventPublisher applicationEventPublisher;
    
    public void changeState (Integer orderId,Integer stateFrom,Integer stateTo){
        OrderState orderState = new OrderState() ;
        OrderStateEvent orderStateEvent = new OrderStateEvent(orderState) ;
        logger.info(Thread.currentThread().getName()+";"+orderStateEvent);
        applicationEventPublisher.publishEvent(orderStateEvent);
    }
}

監聽者:實現JDK中頂級介面EventListener,Spring擴展了多種事件監聽器,以實現各種場景的需求,例如:有序無序、同步非同步等;

@Component
public class OrderStateListener implements ApplicationListener<OrderStateEvent> {
    private static final Logger logger = LoggerFactory.getLogger(OrderStateListener.class) ;

    @Async
    @Override
    public void onApplicationEvent(OrderStateEvent orderStateEvent) {
        logger.info(Thread.currentThread().getName()+";"+orderStateEvent);
    }
}

五、參考源碼

應用倉庫:
https://gitee.com/cicadasmile/middle-ware-parent

編程文檔:
https://gitee.com/cicadasmile/butte-java-note

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 字元串是用引號包裹的,表示語言文字。 用雙引號包裹的都是字元串 註意:變數不能包裹在雙引號里 輸出 布爾類型 true和false 註意都是小寫 ...
  • 認識js 在谷歌瀏覽器的控制臺中右鍵單擊空白處,選擇檢查可以打開控制台 查看console.log輸出的內容。 JS的註釋 是”//”或者”/* */”,前者是行註釋,後者是塊註釋 1變數 js的變數必須申明在用,聲明後賦值,變數才可使用,使用過程中可以改變類型。 變數的命名規則: 變數名只能由字母 ...
  • 幾天的內容不是很多,因為我們腳手架的學習告一段落了,也是為了跟明天開始的內容有一個區分。 明天將會有一個非常重要的內容來了,各位,vue中的ajax他來了,這個絕對是重量級,有點興奮! 十一.TODOList編輯 新增一個編輯功能,要完成的邏輯就是,當我們一點擊編輯按鈕,對象會新增一個屬性edit為 ...
  • # JavaScript經典案例練習 P1:支付10秒倒計時 效果: 功能: 點擊立即支付彈出確認款 確認付款後跳轉到支付成功頁面並開始計時 計時結束或者點擊立即返回按鈕返迴首頁 知識點: window.confirm() 用於顯示一個帶有指定消息和確認及取消按鈕的對話框,如果訪問者點擊‘確認’, ...
  • ${}字元串可以用於字元串拼接,一般用於模糊查詢中(因為有sql註入的風險,很少用) ...
  • 在開發過程中,不知道有沒有這樣的經歷,項目實際讀取的配置信息有時候總是與預期不符,今天就來研究下 SpringBoot 讀取配置文件順序。 一、SpringBoot 配置文件載入優先順序 SpringBoot官方文檔說明瞭載入的順序如下,越靠前優先順序越高。 Spring Boot uses a ver ...
  • 前言 嗨嘍!大家好呀 第三方模塊: requests >>> pip install requests 模塊安裝問題: 如果安裝python第三方模塊: win + R 輸入 cmd 點擊確定, 輸入安裝命令 pip install 模塊名 (pip install requests) 回車 在py ...
  • 一、Matplotlib 博文來源:https://www.runoob.com/matplotlib/matplotlib-tutorial.html Matplotlib 是 Python 的繪圖庫,它能讓使用者很輕鬆地將數據圖形化,並且提供多樣化的輸出格式。 Matplotlib 可以用來繪製 ...
一周排行
    -Advertisement-
    Play Games
  • Github / Gitee QQ群(1群) : 813100564 / QQ群(2群) : 579033769 視頻教學 介紹 MiniWord .NET Word模板引擎,藉由Word模板和數據簡單、快速生成文件。 Getting Started 安裝 nuget link : https:// ...
  • Array.Sort Array類中相當實用的我認為是Sort方法,相比起冗長的冒泡排序,它的出現讓排序更加的簡化 結果如下: 還可以聲明一個靜態方法用來專門調用指定數組排序,從名為 array 的一維數組中 a 索引處開始,到 b 元素 從小到大排序。 註意: a + b 不能大於 array 的 ...
  • 前言 在上一篇文章CLR類型系統概述里提到,當運行時掛起時, 垃圾回收會執行堆棧遍歷器(stack walker)去拿到堆棧上值類型的大小和堆棧根。這裡我們來翻譯BotR里一篇專門介紹Stackwalking的文章,希望能加深理解。 順便說一句,StackWalker在中文里似乎還沒有統一的翻譯,J ...
  • 使用過 nginx 的小伙伴應該都知道,這個中間件是可以設置跨域的,作為今天的主角,同樣的 反向代理中間件的 YARP 毫無意外也支持了跨域請求設置。 有些小伙伴可能會問了,怎樣才算是跨域呢? 在 HTML 中,一些標簽,例如 img、a 等,還有我們非常熟悉的 Ajax,都是可以指向非本站的資源的 ...
  • 什麼是Git Git 是一個開源的分散式版本控制系統,用於敏捷高效地處理任何或小或大的項目。 Git 是 Linus Torvalds 為了幫助管理 Linux 內核開發而開發的一個開放源碼的版本控制軟體。 Git 與常用的版本控制工具 CVS, Subversion 等不同,它採用了分散式版本庫的 ...
  • 首先CR3是什麼,CR3是一個寄存器,該寄存器內保存有頁目錄表物理地址(PDBR地址),其實CR3內部存放的就是頁目錄表的記憶體基地址,運用CR3切換可實現對特定進程記憶體地址的強制讀寫操作,此類讀寫屬於有痕讀寫,多數驅動保護都會將這個地址改為無效,此時CR3讀寫就失效了,當然如果能找到CR3的正確地址... ...
  • 說明 onlyoffice為一款開源的office線上編輯組件,提供word/excel/ppt編輯保存操作 以下操作均基於centos8系統,officeonly鏡像版本7.1.2.23 鏡像下載地址:https://yunpan.360.cn/surl_y87CKKcPdY4 (提取碼:1f92 ...
  • 二叉樹查找指定的節點 前序查找的思路 1.先判斷當前節點的no是否等於要查找的 2.如果是相等,則返回當前節點 3.如果不等,則判斷當前節點的左子節點是否為空,如果不為空,則遞歸前序查找 4.如果左遞歸前序查找,找到節點,則返回,否繼續判斷,當前的節點的右子節點是否為空,如果不為空,則繼續向右遞歸前 ...
  • ##Invalid bound statement (not found)出現原因和解決方法 ###前言: 想必各位小伙伴在碼路上經常會碰到奇奇怪怪的事情,比如出現Invalid bound statement (not found),那今天我就來分析以下出現此問題的原因。 其實出現這個問題實質就是 ...
  • ###一、背景知識 爬蟲的本質就是一個socket客戶端與服務端的通信過程,如果我們有多個url待爬取,只用一個線程且採用串列的方式執行,那隻能等待爬取一個結束後才能繼續下一個,效率會非常低。 需要強調的是:對於單線程下串列N個任務,並不完全等同於低效,如果這N個任務都是純計算的任務,那麼該線程對c ...