[發明專利]消息隊列的實現方法和系統、消息隊列處理系統

有效

• 申請號: 201210123254.3
• 申請日: 2012-04-24
• 公開（公告）號: CN103377043A
• 公開（公告）日: 2013-10-30
• 發明（設計）人: 來鑫
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: G06F9/44
• 分類號: G06F9/44;G06F17/30
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 何平;曾旻輝

1.一種消息隊列的實現方法，包括如下步驟：

根據消息隊列中觸發的操作獲取隊列標識的位置值，并執行所述操作；

判斷所述獲取的位置值是否與所述隊列標識當前對應的位置值相同，若否，則拒絕所述操作的執行，若是，則

接受所述操作的執行，并更新接受操作的隊列標識當前對應的位置值以及所述隊列標識中的指針值。

2.根據權利要求1所述的消息隊列的實現方法，其特征在于，在所述拒絕所述操作的執行的步驟之后將返回所述根據消息隊列中觸發的操作獲取隊列標識的位置值的步驟；

所述方法還包括：

對操作的重試進行計數得到重試次數；

判斷所述操作的重試次數是否達到次數限值，若是，則結束。

3.根據權利要求1所述的消息隊列的實現方法，其特征在于，所述操作為發送消息，所述隊列標識為隊尾標識，所述執行所述操作的步驟為：

插入消息節點，向所述消息節點寫入消息以及所述消息對應的標識；

若判斷到所述位置值與所述隊尾標識當前對應的位置值相同，將尾部節點的指針值設為所述消息對應的標識；

所述更新所述隊列標識中的指針值的步驟為：

將所述消息對應的標識寫入所述隊尾標識的指針值。

4.根據權利要求1所述的消息隊列的實現方法，其特征在于，所述操作為接收消息，所述隊列標識為消息隊列的隊首標識；所述執行所述操作的步驟為：

判斷頭部節點中的消息是否被接收，若否，則

若判斷到所述位置值與所述隊首標識當前對應的位置值相同，在所述節點中提取消息，并標識消息接收者，向所述消息接收者返回所述消息。

5.根據權利要求4所述的消息隊列的實現方法，其特征在于，所述操作為刪除消息，所述執行所述操作的步驟為：

判斷所述消息刪除者是否與所述消息接收者相同，若是，則

若判斷到所述位置值與所述隊首標識當前對應的位置值相同，刪除所述頭部節點；

所述更新所述隊列標識中的指針值的步驟為：

向所述消息隊列中隊首標識的指針值寫入所述頭部節點的下一節點中消息對應的標識。

6.根據權利要求1所述的消息隊列的實現方法，其特征在于，所述根據所述位置值和所述隊列標識當前對應的位置值接受所述操作的執行的步驟之后還包括：

根據所述操作更新所述隊列標識中的標記值；

根據隊首標識的標記值和隊尾標識的標記值得到隊列長度。

7.一種消息隊列的實現系統，其特征在于，包括：

隊列處理裝置，用于根據消息隊列中觸發的操作獲取隊列標識的位置值；

判斷裝置，用于判斷所述獲取的位置值是否與所述隊列標識當前對應的位置值相同，若否，則拒絕所述操作的執行，若是，則通知存儲裝置；

所述存儲裝置用于接受操作的執行，并更新接受操作的隊列標識當前對應的位置值以及所述隊列標識中的指針值。

8.根據權利要求7所述的消息隊列的實現系統，其特征在于，所述隊列處理裝置包括：

計數模塊，用于對操作的重試進行計數得到重試次數；

重試控制模塊，用于判斷所述操作的重試次數是否達到次數限值，若是，則停止執行。

9.根據權利要求7所述的消息隊列的實現系統，其特征在于，所述操作為發送消息，所述隊列標識為隊尾標識，所述隊列處理裝置包括：

節點插入模塊，用于在所述存儲裝置中插入消息節點，向所述消息節點寫入消息以及所述消息對應的標識；

消息發送模塊，用于若判斷到所述位置值與所述隊尾標識當前對應的位置值相同，并將尾部節點的指針值設為所述消息對應的標識；

所述存儲裝置還用于將所述消息對應的標識寫入所述隊尾標識的指針值。

10.根據權利要求7所述的消息隊列的實現系統，其特征在于，所述操作為接收消息，所述隊列標識為消息隊列的隊首標識，所述隊列處理裝置包括：

接收判斷模塊，用于判斷頭部節點中的消息是否被接收，若否，則通知傳遞模塊；

消息提取模塊，用于若判斷到所述位置值與所述隊首標識當前對應的位置值相同，在所述節點中提取消息，并標識消息接收者，向所述消息接收者返回所述消息。