[發明專利]一種隊列的數據處理方法和系統

有效

• 申請號: 201110030815.0
• 申請日: 2011-01-28
• 公開（公告）號: CN102541746A
• 公開（公告）日: 2012-07-04
• 發明（設計）人: 陳偉君
• 申請（專利權）人: 深圳市金蝶中間件有限公司
• 主分類號: G06F12/02
• 分類號: G06F12/02
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 鄭光

1.一種隊列的數據處理方法，其特征在于，包括：

設置用于存儲隊列的持久化存儲裝置，以及用于存儲隊列中預設數量隊頭數據的緩存；

讀取所述緩存中數據的數量，當所述緩存中的數據數量低于預設數量時，則按所述隊列中的順序將所述持久化存儲裝置中的數據存儲到緩存中。

2.根據權利要求1所述的隊列的數據處理方法，其特征在于，所述方法還包括：

當接收到讀取所述隊列中數據的請求時，讀取所述隊列中的第一個數據；

具體為：

當接收到讀取所述隊列中數據的請求時，讀取所述緩存以確定所述緩存中是否有數據，如果有數據，則將緩沖中的數據按照隊列的順序，讀取隊列中的第一個數據；如果沒有數據，則將所述持久化存儲設備中的數據按照隊列的順序，讀取隊列中的第一個數據。

3.根據權利要求2所述的隊列的數據處理方法，其特征在于，所述將所述持久化存儲設備中的數據按照隊列的順序，讀取隊列中的第一個數據包括：

將所述持久化存儲設備中的數據按照隊列的順序，讀取隊列中的第一個數據；并將隊列中該第一個數據之后的預設數量的數據存儲到所述緩存中。

4.根據權利要求3所述的隊列的數據處理方法，其特征在于，所述方法還包括：

將所述第一個數據從緩存和/或持久化存儲裝置中刪除。

5.根據權利要求1所述的隊列的數據處理方法，其特征在于，所述方法還包括：

當接收到對該隊列進行存儲的請求時，將所請求存儲的數據存儲到緩存和/或持久化存儲裝置中，并采用異步模式返回存儲成功消息；

具體為：

當接收到請求存儲到隊列中的數據時，先將該數據進行索引化，以生成該數據的索引ID；同時，采用異步模式直接返回存儲成功消息；

讀取所述緩存以判斷該隊列是否全部位于緩存中，且緩存未滿；如果是，則將該數據存儲到所述緩存中；如果否，則直接將該數據存儲到所述持久化存儲裝置中。

6.一種隊列的數據處理系統，其特征在于，包括：

數據庫模塊，所述數據庫模塊包括用于存儲隊列中數據的持久化存儲裝置，以及用于存儲隊列中預設數量隊頭數據的緩存；

控制模塊，用于讀取所述緩存中數據的數量，當所述緩存中的數據數量低于預設數量時，則按所述隊列中的順序將所述持久化存儲裝置中的數據存儲到緩存中。

7.根據權利要求6所述的隊列的數據處理系統，其特征在于，所述系統還包括：

讀取模塊，用于當接收到讀取所述隊列中數據的請求時，讀取所述隊列中的第一個數據；

所述讀取模塊包括：

判斷單元，當接收到讀取所述隊列中數據的請求時，讀取所述緩存以確定所述緩存中是否有數據；

緩存讀取單元，用于當所述緩存中有數據時，將緩沖中的數據按照隊列的順序，讀取隊列中的第一個數據；

持久化存儲設備讀取單元，用于當所述緩存中沒有數據時，將所述持久化存儲設備中的數據按照隊列的順序，讀取隊列中的第一個數據。

8.根據權利要求7所述的隊列的數據處理系統，其特征在于，所述持久化存儲設備讀取單元包括：

第一讀取子單元，用于將所述持久化存儲設備中的數據按照隊列的順序，讀取隊列中的第一個數據；

第二讀取子單元，用于將隊列中該第一個數據之后的預設數量的數據存儲到所述緩存中。

9.根據權利要求7所述的隊列的數據處理系統，其特征在于，所述系統還包括：

刪除模塊，用于將所述第一個數據從緩存和/或持久化存儲裝置中刪除。

10.根據權利要求7所述的隊列的數據處理系統，其特征在于，所述系統還包括：

存儲模塊，用于當接收到對該隊列進行存儲的請求時，將所請求存儲的數據存儲到緩存和/或持久化存儲裝置中，并采用異步模式返回存儲成功消息；

具體為：

索引單元，用于當接收到請求存儲到隊列中的數據時，先將該數據進行索引化，以生成該數據的索引ID；同時，采用異步模式直接返回存儲成功消息；

數據存儲單元，用于讀取所述緩存以判斷該隊列是否全部位于緩存中，且緩存未滿；如果是，則將該數據存儲到所述緩存中；如果否，則直接將該數據存儲到所述持久化存儲裝置中。