[發明專利]基于云原生的消息處理方法、裝置、設備及存儲介質

在審

• 申請號: 202111459779.X
• 申請日: 2021-12-01
• 公開（公告）號: CN114138530A
• 公開（公告）日: 2022-03-04
• 發明（設計）人: 丁鐵梁;李琦;山金孝;段嘉;黃龍華;劉沁源;鄢偉
• 申請（專利權）人: 招商局金融科技有限公司
• 主分類號: G06F11/07
• 分類號: G06F11/07;G06F11/14;G06F11/30;G06F9/48;G06F9/54
• 代理公司: 深圳眾鼎專利商標代理事務所(普通合伙) 44325
• 代理人: 姚章國

本發明公開一種基于云原生的消息處理方法、裝置、設備及存儲介質。該方法包括：接收消息處理請求，所述消息處理請求包括目標操作類型；監聽當前消息流抽象的當前消息狀態；在所述當前消息狀態為無故障狀態時，執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理；在所述當前消息狀態為有故障狀態時，執行消息恢復進程，在監聽到所述當前消息狀態為無故障狀態時，執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理。該方法只有在保障當前消息狀態為無故障狀態時，才會執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理，有助于保障后續消息處理的一致性。

技術領域

本發明涉及云原生技術領域，尤其涉及一種基于云原生的消息處理方法、裝置、設備及存儲介質。

背景技術

現有消息處理系統中，在消息處理出現一次故障之后，再次進行消息處理時，無法保障其消息讀寫的一致性。

發明內容

本發明實施例提供一種基于云原生的消息處理方法、裝置、計算機設備及存儲介質，以解決現有消息處理系統無法保障消息讀寫的一致性的問題。

一種基于云原生的消息處理方法，包括：

接收消息處理請求，所述消息處理請求包括目標操作類型；

監聽當前消息流抽象的當前消息狀態；

在所述當前消息狀態為無故障狀態時，執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理；

在所述當前消息狀態為有故障狀態時，執行消息恢復進程，在監聽到所述當前消息狀態為無故障狀態時，執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理。

一種基于云原生的消息處理裝置，包括：

處理請求接收模塊，用于接收消息處理請求，所述消息處理請求包括目標操作類型；

消息狀態監聽模塊，用于監聽當前消息流抽象的當前消息狀態；

第一處理模塊，用于在所述當前消息狀態為無故障狀態時，執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理；

第二處理模塊，用于在所述當前消息狀態為有故障狀態時，執行消息恢復進程，在監聽到所述當前消息狀態為無故障狀態時，執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理。

一種計算機設備，包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述基于云原生的消息處理方法。

一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序被處理器執行時實現上述基于云原生的消息處理方法。

上述基于云原生的消息處理方法、裝置、計算機設備及存儲介質，當前Broker在接收到消息處理請求時，需先監聽當前消息流抽象的當前消息狀態，只有在保障當前消息狀態為無故障狀態時，才會執行與所述目標操作類型相對應的目標操作進程，對所述消息處理請求進行處理，有助于保障后續消息處理的一致性。

附圖說明

為了更清楚地說明本發明實施例的技術方案，下面將對本發明實施例的描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動性的前提下，還可以根據這些附圖獲得其他的附圖。

圖1是本發明一實施例中基于云原生的消息處理方法的一應用環境示意圖；

圖2是本發明一實施例中基于云原生的消息處理方法的一流程圖；

圖3是本發明一實施例中基于云原生的消息處理方法的另一流程圖；