[發明專利]一種多渠道接入消息轉發方法和裝置

在審

• 申請號: 202011484464.6
• 申請日: 2020-12-16
• 公開（公告）號: CN112579274A
• 公開（公告）日: 2021-03-30
• 發明（設計）人: 馬超;李芳
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 賈磊;李輝

本發明提供了一種多渠道接入消息轉發方法和裝置，該方法包括：配置轉發參數；通過平臺調度任務建立消息隊列；其中，消息隊列，包括：等待隊列，錯誤隊列，緩沖隊列；利用調度任務獲取執行本地事務時產生的事件消息；將事件消息匹配轉發參數，匹配成功后按照事件消息的業務限制，分別放入等待隊列和緩沖隊列；通過消息轉發服務讀取緩沖隊列中的事件消息，利用強序保證機制為事件消息配置發送順序；根據發送緩沖機制將事件消息按照發送順序發送至周邊系統，發送過程中動態調整發送配額；當發送至周邊系統失敗時，將事件消息放入錯誤隊列。

技術領域

本發明涉及計算機數據處理技術領域，尤其涉及一種多渠道接入消息轉發方法和裝置。

背景技術

本部分旨在為權利要求書中陳述的本發明的實施方式提供背景或上下文。此處的描述不因為包括在本部分中就承認是現有技術。

隨著社會和經濟的發展，IT軟件系統為滿足日益增長的業務需求，同時保證可維護性，不可避免的需要進行模塊化拆分，隨著模塊拆分越來越細，各模塊之間的交互越來越多，場景越來越復雜，每個模塊都有相應的邏輯處理，對前后置條件也要求較以前苛刻。

從整體上看，這種跨多個服務的調用涉及多個數據源，可以認為是一種特殊的分布式事務，但其對一致性要求比分布式更高，各個模塊其自身的業務邏輯處理也非常復雜，需要明確獲取上一步的結果后，才能決定后續的業務流程。而目前流行的分布式架構基本上都是以最終一致性為終極目標的設計的，不滿足每一環節都需要一致的要求。

一個業務涉及多個環境，每個環節都需要處理復雜的業務邏輯，系統實現的方式不同，導致耗時、緩存以及異常處理機制各不相同，為了保證業務的連續性，業務中轉系統通需要兼容各種復雜、不可預料的各種場景，需要實現按順序轉發、緩存機制、錯誤重發機制。

在銀行業的IT實踐中，賬務數據一致性的重要程度往往超過其他的非功能特性，在SOA架構下，目前普遍采用的是“存儲轉發”機制。該機制從交易發起方開始，根據業務流程，通過鏈式發送消息，依次推動到不同模塊的多個服務，當最后一個消息推送成功后，整個業務流程完成。當超過一定時間后若任意一個消息返回結果狀態為未知或失敗，為保證整體的數據一致性，需要對每個已推送消息發起沖正，無論上一次執行成功與否，都要進行撤銷，主要流程及執行順序如圖2所示。

在該類消息同步調用機制下，推送消息需要同步等待接受服務返回消息處理結果，雖然實現較為簡單，執行順序也有保證，但其缺點也顯而易見：

1、同步等待機制在調用鏈條較長時，響應時間無法保證。

2、同步等待會占用較多的系統資源，導致應用系統無法支撐高并發場景。

在數據一致性方面，沖正機制雖然提供了在一方失敗情況下的反向撤銷功能，但對于服務方處理消息結果未知的情況，并未提供查詢或自動重試功能。

因此，如何提供一種新的方案，其能夠解決上述技術問題是本領域亟待解決的技術難題。

發明內容

本發明實施例提供一種多渠道接入消息轉發方法，通過參數化配置，實現一種可動態調整、消息順序控制及緩存重發機制，保證下游系統業務處理正常，該方法包括：

配置轉發參數；

通過平臺調度任務建立消息隊列；其中，消息隊列，包括：等待隊列，錯誤隊列，緩沖隊列；

利用調度任務獲取執行本地事務時產生的事件消息；

將事件消息匹配轉發參數，匹配成功后按照事件消息的業務限制，分別放入等待隊列和緩沖隊列；

通過消息轉發服務讀取緩沖隊列中的事件消息，利用強序保證機制為事件消息配置發送順序；

根據發送緩沖機制將事件消息按照發送順序發送至周邊系統，發送過程中動態調整發送配額；