[發明專利]一種用于通過持久化隊列處理消息的方法與設備

有效

• 申請號: 201710193817.9
• 申請日: 2017-03-28
• 公開（公告）號: CN107391269B
• 公開（公告）日: 2021-04-20
• 發明（設計）人: 佟路林
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 上海百一領御專利代理事務所(普通合伙) 31243
• 代理人: 陳貞健;王路豐

本申請的目的是提供一種用于通過持久化隊列處理消息的方法與設備。具體地，根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存隊列；根據讀消息請求從所述內存隊列讀取并處理對應第二消息；在所述第二消息被處理完成后，將所述第二消息從所述前置緩存中刪除。與現有技術相比，本申請中增加持久化隊列對應的前置緩存，通過將消息寫入持久化隊列對應的前置緩存及內存隊列，并在處理時從所述內存隊列讀取并處理，最終在消息被處理完成后，將消息從所述前置緩存中刪除，減少了消息從持久化隊列對應文件系統的讀寫次數，減少了IO操作，提升了消息的處理速度。

技術領域

本申請涉及計算機領域，尤其涉及一種用于通過持久化隊列處理消息的技術。

背景技術

隨著時代的發展，數據消息處理量日益增大，為保障數據消息處理的過程中數據的安全，避免出現因程序重啟等原因造成的內存隊列數據消息丟失，現有技術會布置由內存隊列和文件系統組成持久化隊列，確保在程序重啟等情況下數據消息被存儲在文件存統中。然而，現有技術在處理數據消息時會出現從文件系統中寫入或讀取的操作，產生大量的IO操作，使得數據消息的處理速度受限。

發明內容

本申請的一個目的是提供一種用于通過持久化隊列處理消息的方法與設備，用以解決持久化隊列處理消息速度受限的問題。

為實現上述目的，本申請提供了一種用于通過持久化隊列處理消息的方法，該方法解決了持久化隊列處理消息速度受限的問題，該方法包括：

根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存

隊列；

根據讀消息請求從所述內存隊列讀取并處理對應第二消息；

在所述第二消息被處理完成后，將所述第二消息從所述前置緩存中刪除。

為實現上述目的，本申請還提供了一種用于通過持久化隊列處理消息的設備，該設備解決了持久化隊列處理消息速度受限的問題，該設備包括：

消息寫入裝置，用于根據寫消息請求將對應第一消息寫入持久化隊列對

應的前置緩存及內存隊列；

消息處理裝置，用于根據讀消息請求從所述內存隊列讀取并處理對應第二消息；

消息再處理裝置，用于在所述第二消息被處理完成后，將所述第二消息從所述前置緩存中刪除。

為實現上述目的，本申請還提供了一種用于通過持久化隊列處理消息的設備，包括：

處理器；

以及被安排成存儲計算機可執行指令的存儲器，所述可執行指令在被執行時使所述處理器：

根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存隊列；

根據讀消息請求從所述內存隊列讀取并處理對應第二消息；

在所述第二消息被處理完成后，將所述第二消息從所述前置緩存中刪除。

與現有技術相比，本申請中增加持久化隊列對應的前置緩存，通過將消息寫入持久化隊列對應的前置緩存及內存隊列，并在處理時從所述內存隊列讀取并處理，最終在消息被處理完成后，將消息從所述前置緩存中刪除，減少了消息從持久化隊列對應文件系統的讀寫次數，減少了IO操作，提升了消息的處理速度。進一步地，在消息對應應用程序重啟時，將所述前置緩存中的消息存儲至所述文件系統，保障消息在應用程序重啟過程中的安全性。

附圖說明

通過閱讀參照以下附圖所作的對非限制性實施例所作的詳細描述，本申請的其它特征、目的和優點將會變得更明顯：

圖1示出根據本申請一個方面的一種用于通過持久化隊列處理消息的方法流程圖；