[發明專利]一種消息傳輸及消費方法

在審

• 申請號: 202011338563.3
• 申請日: 2020-11-25
• 公開（公告）號: CN112463407A
• 公開（公告）日: 2021-03-09
• 發明（設計）人: 桂紅軍
• 申請（專利權）人: 北京神州數字科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L29/08
• 代理公司: 北京世譽鑫誠專利代理有限公司 11368
• 代理人: 任欣生

1.一種消息傳輸方法，其特征在于，包括：

接收客戶端或其他系統發送的業務請求并將執行所述業務請求前、中、后過程中產生的消息寫入數據庫；

根據所述業務請求的執行情況，判斷所述業務請求是否執行成功；

若所述業務請求成功執行，則將所述消息發送至消息隊列服務端并通過所述消息隊列服務端向客戶端或其他系統傳輸所述消息。

2.根據權利要求1所述的消息傳輸方法，其特征在于，判斷所述業務請求是否執行成功包括：

若所述業務請求未成功執行，則不再發送所述消息。

3.根據權利要求1所述的消息傳輸方法，其特征在于，若所述業務請求成功執行，則將所述消息發送至消息隊列服務端包括：

若所述消息發送失敗，則根據預設的重試發送機制，重復發送所述消息，直至所述消息發送成功。

4.根據權利要求1所述的消息傳輸方法，其特征在于，在根據所述業務請求的執行情況，在將執行所述業務請求前、中、后過程中產生的消息寫入數據庫之前，所述方法還包括：

為所述消息設置標識、流程編號、消息體、創建時間、狀態、過期時間及隊列編號，其中，所述消息狀態包括待發送狀態、準備發送狀態、發送成功狀態及發送失敗狀態。

5.根據權利要求1所述的消息傳輸方法，其特征在于，在將所述消息發送至消息隊列服務端之后，所述方法還包括：

實時判斷是否存在待發送狀態及準備發送狀態的消息，若是，則定時獲取所述消息。

6.根據權利要求5所述的消息傳輸方法，其特征在于，在則獲取所述消息之后，所述方法還包括：

判斷所述消息的創建時間與當前時間之間的時間間隔是否大于預設的有效期限，若是，則將所述消息的狀態設置為發送失敗狀態。

7.根據權利要求1所述的消息傳輸方法，其特征在于，在通過所述消息隊列服務端向客戶端或其他系統傳輸所述消息之后，所述方法還包括：

根據所述消息的業務處理情況，實時更新所述消息的狀態。

8.一種消息消費方法，其特征在于，包括：

獲取業務系統發送的消息并判斷所述消息是否已經被消費；

若消息已經被消費，則將所述消息寫入消息重復表中；

若所述消息未被消費，則將所述消息寫入消息消費表中，其中，所述消息消費表記錄消息的唯一標識、接收時間、狀態、更新時間、目的地。

9.根據權利要求8所述的消息消費方法，其特征在于，在將所述消息寫入消息消費表中之后，所述方法還包括：

根據所述消息對應的標題、標簽及目的地，判斷是否存在對應的消費者，如果不存在則進入預設的消費重試階段；

如果存在，則消費所述消息。