[發明專利]消息處理方法、裝置及系統

在審

• 申請號: 201610058201.6
• 申請日: 2016-01-28
• 公開（公告）號: CN105740083A
• 公開（公告）日: 2016-07-06
• 發明（設計）人: 程崢嶸
• 申請（專利權）人: 努比亞技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 廣東廣和律師事務所 44298
• 代理人: 章小燕

技術領域

本發明涉及通信技術領域，尤其涉及一種消息處理方法、裝置及系統。

背景技術

在大并發消息處理系統中，一般使用消息中間件(messageorientedmiddleware)來異步處理請求，以起到消除請求高峰的目的，同時提高系統穩定性和吞吐量。例如，在電商的倉儲服務器，使用RabbitMQ作為消息中間件接收順豐等公司的倉儲服務器推送給倉儲服務器的消息報文，然后轉發給消息處理服務器。當消息應答設置為自動應答時，RabbitMQ將接收到的消息推送給消息處理服務器后就將消息數據從消息隊列中刪除，當消息處理服務器在處理消息報文時，一旦倉儲服務器或者消息處理服務器出現宕機，則消息數據將丟失。

由此，有必要提供一種消息處理方法、裝置及系統，避免上述情況的出現，能夠及時保存消息報文并記錄消息數據的處理狀態。

發明內容

本發明的主要目的在于提出一種消息處理方法、裝置及系統，旨在解決現有技術中由于不能及時保存消息，而在系統宕機時出現的丟失消息數據的問題。

為實現上述目的，本發明提供的一種消息處理裝置，應用于數據庫，所述裝置包括：保存模塊，用于保存從消息接收服務器獲取的至少一個消息報文及其相關數據；檢測模塊，用于檢測消息處理服務器中所述消息報文的處理狀態；消息狀態處理模塊，用于當檢測消息處理服務器成功處理所述消息報文對應的數據時，將與所述消息報文對應的狀態值由第一狀態改為第二狀態。

可選地，所述裝置還包括：提取模塊，用于提取狀態值為第一狀態的消息報文；消息推送模塊，用于將所述消息報文推送至消息接收服務器，經由消息中間件轉發至所述消息處理服務器，以使所述消息處理服務器對所述消息報文進行業務處理。

可選地，所述相關數據至少包括發送時間戳，所述裝置還包括：偵測模塊，用于偵測所述消息接收服務器、所述消息中間件、以及所述消息處理服務器之一出現宕機；相應地，所述提取模塊具體用于當宕機的所述消息接收服務器、所述消息中間件、以及所述消息處理服務器之一重新啟動時，提取狀態值為第一狀態且所述發送時間戳在宕機之前的消息報文，并將提取的所述消息報文通過所述消息推送模塊推送至所述消息接收服務器。

可選地，所述裝置還包括：刪除模塊，用于刪除狀態值為第二狀態的消息報文及其數據。

此外，為實現上述目的，本發明還提出一種消息處理系統，所述系統包括：消息接收服務器，用于接收至少一個消息報文，并將所述至少一個消息報文依次發送給消息中間件的消息隊列中，同時將所述至少一個消息報文及其對應的狀態值寫入數據庫，默認所述狀態值為第一狀態；所述數據庫，用于保存從所述消息接收服務器獲取的所述至少一個消息報文及其相關數據；消息處理服務器，用于從所述消息中間件提取所述消息報文進行業務處理，當業務處理成功時，所述狀態值改為第二狀態。

此外，為實現上述目的，本發明還提出一種消息處理方法，應用于數據庫，所述方法包括：保存從消息接收服務器獲取的至少一個消息報文及其相關數據；檢測消息處理服務器中所述消息報文的處理狀態；當檢測消息處理服務器成功處理所述消息報文對應的數據時，將與所述消息報文對應的狀態值由第一狀態改為第二狀態。

可選地，所述方法還包括：提取狀態值為第一狀態的消息報文；將所述消息報文推送至消息接收服務器，經由消息中間件轉發至所述消息處理服務器，以使所述消息處理服務器對所述消息報文進行業務處理。

可選地，所述相關數據至少包括發送時間戳，所述方法具體包括：偵測所述消息接收服務器、所述消息中間件、以及所述消息處理服務器之一出現宕機；當宕機的所述消息接收服務器、所述消息中間件、以及所述消息處理服務器之一重新啟動時，提取狀態值為第一狀態且所述發送時間戳為宕機之前的消息報文，并將提取的所述消息報文推送至所述消息接收服務器。

可選地，所述方法還包括：刪除狀態值為第二狀態的消息報文及其數據。

此外，為實現上述目的，本發明還提出一種消息處理方法，所述方法包括步驟：接收至少一個消息報文；將所述至少一個消息報文依次發送給消息中間件的消息隊列中，同時將所述至少一個消息報文及其對應的狀態值寫入數據庫，默認所述狀態值為第一狀態；保存從所述消息接收服務器獲取的所述至少一個消息報文及其相關數據；以及從所述消息中間件提取所述消息報文進行業務處理，當業務處理成功時，所述狀態值改為第二狀態。