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

有效

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

1.一種用于通過持久化隊列處理消息的方法，包括：

根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存隊列；若所述前置緩存已滿，將所述第一消息寫入所述內存隊列及所述持久化隊列對應的文件系統；所述第一消息是指尚未寫入持久化隊列中的消息；

根據讀消息請求從所述內存隊列讀取并處理對應第二消息；所述第二消息是指已被寫入所述持久化隊列中的消息；

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

將所述持久化隊列中未記錄于消息完成文件的消息加載至所述內存隊列。

2.根據權利要求1所述的方法，其中，所述根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存隊列包括：

若持久化隊列對應的前置緩存未滿，根據寫消息請求將對應第一消息寫入所述前置緩存及所述持久化隊列對應的內存隊列。

3.根據權利要求2所述的方法，其中，所述在所述第二消息被處理完成后，將所述第二消息從所述前置緩存中刪除包括：

在所述第二消息被處理完成后，若所述第二消息未存在于所述文件系統，將所述第二消息從所述前置緩存中清除；否則，

將所述第二消息添加至所述持久化隊列對應的消息完成文件。

4.根據權利要求1至3中任一項所述的方法，其中，所述方法還包括：

若對應消息應用重新啟動，將所述前置緩存中的消息寫入所述持久化隊列對應的文件系統；

在所述消息應用啟動成功后，將所述文件系統中待處理的消息加載至所述內存隊列。

5.根據權利要求1所述的方法，其中，所述前置緩存的消息容量小于所述內存隊列。

6.根據權利要求1所述的方法，其中，所述前置緩存基于哈希映射結構。

7.一種用于通過持久化隊列處理消息的設備，包括：

消息寫入裝置，用于根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存隊列；若所述前置緩存已滿，將所述第一消息寫入所述內存隊列及所述持久化隊列對應的文件系統；所述第一消息是指尚未寫入持久化隊列中的消息；

消息處理裝置，用于根據讀消息請求從所述內存隊列讀取并處理對應第二消息；所述第二消息是指已被寫入所述持久化隊列中的消息；

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

消息加載裝置，用于將所述持久化隊列中未記錄于消息完成文件的消息加載至所述內存隊列。

8.根據權利要求7所述的設備，其中，所述消息寫入裝置用于：

若持久化隊列對應的前置緩存未滿，根據寫消息請求將對應第一消息寫入所述前置緩存及所述持久化隊列對應的內存隊列。

9.根據權利要求8所述的設備，其中，所述消息再處理裝置包括：

消息清理單元，用于在所述第二消息被處理完成后，若所述第二消息未存在于所述文件系統，將所述第二消息從所述前置緩存中清除；否則，

消息記錄單元，用于將所述第二消息添加至所述持久化隊列對應的消息完成文件。

10.根據權利要求7至9中任一項所述的設備，其中，所述設備還包括：

消息應用重啟處理裝置，用于若對應消息應用重新啟動，將所述前置緩存中的消息寫入所述持久化隊列對應的文件系統；

消息應用重啟加載裝置，用于在所述消息應用啟動成功后，將所述文件系統中待處理的消息加載至所述內存隊列。

11.根據權利要求7所述的設備，其中，所述前置緩存的消息容量小于所述內存隊列。

12.根據權利要求7所述的設備，其中，所述前置緩存基于哈希映射結構。

13.一種用于通過持久化隊列處理消息的設備，包括：

處理器；

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

根據寫消息請求將對應第一消息寫入持久化隊列對應的前置緩存及內存隊列；若所述前置緩存已滿，將所述第一消息寫入所述內存隊列及所述持久化隊列對應的文件系統；所述第一消息是指尚未寫入持久化隊列中的消息；

根據讀消息請求從所述內存隊列讀取并處理對應第二消息；所述第二消息是指已被寫入所述持久化隊列中的消息；

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

將所述持久化隊列中未記錄于消息完成文件的消息加載至所述內存隊列。