[發明專利]一種基于Redis的分布式隊列調度方法及裝置

在審

• 申請號: 201410034919.2
• 申請日: 2014-01-24
• 公開（公告）號: CN103793273A
• 公開（公告）日: 2014-05-14
• 發明（設計）人: 戴晨
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F17/30
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 胡彬

1.一種基于Redis的分布式隊列調度方法，其特征在于，包括：

獲得當前時刻所述Redis中所有待處理的任務數據隊列的名稱；

獲得與所述Redis連接的異步任務處理程序的信息；

根據所述任務數據隊列的名稱及所述異步任務處理程序的信息，為所述任務數據隊列分配異步任務處理程序。

2.根據權利要求1所述的方法，其特征在于，根據所述任務數據隊列的名稱及所述異步任務處理程序的信息，為所述任務數據隊列分配異步任務處理程序，包括：

通過以下公式計算所述任務數據隊列對應的異步任務處理程序：

i?mod?j=k

其中，i為所述任務數據隊列的隊列編號，j為與所述Redis連接的異步任務處理程序的個數，k為與所述Redis連接的異步任務處理程序中與編號為i的任務數據隊列對應的異步任務處理程序的編號；

將編號為k的異步任務處理程序作為所述編號為i的任務數據隊列中所有數據的執行程序。

3.根據權利要求2所述的方法，其特征在于，將編號為k的異步任務處理程序作為所述編號為i的任務數據隊列的執行程序之后，還包括：

向所述編號為k的異步任務處理程序發送所述編號為i的任務數據隊列。

4.根據權利要求1-3任一項所述的方法，其特征在于，根據所述任務數據隊列的名稱及所述異步任務處理程序的信息，為所述任務數據隊列分配異步任務處理程序之后，還包括：

接收分配的異步任務處理程序發送的刪除指令；

根據所述刪除指令刪除所述Redis中相應的任務數據隊列中的數據。

5.根據權利要求4所述的方法，其特征在于，為所述任務數據隊列分配異步任務處理程序之后，還包括：

接收任務數據；

將接收到的所述任務數據插入Redis的任務數據隊列中，觸發執行調度。

6.一種基于Redis的分布式隊列調度裝置，其特征在于，包括：

名稱獲取單元，用于獲得當前時刻所述Redis中所有待處理的任務數據隊列的名稱；

程序獲取單元，用于獲得與所述Redis連接的異步任務處理程序的信息；

程序分配單元，用于根據所述任務數據隊列的名稱及所述異步任務處理程序的信息，為所述任務數據隊列分配異步任務處理程序。

7.根據權利要求6所述的裝置，其特征在于，所述程序分配單元包括：

程序計算單元，用于通過以下公式計算所述任務數據隊列對應的異步任務處理程序：

i?mod?j=k

其中，i為所述任務數據隊列的隊列編號，j為與所述Redis連接的異步任務處理程序的個數，k為與所述Redis連接的異步任務處理程序中與編號為i的任務數據隊列對應的異步任務處理程序的編號；

程序設置單元，用于將編號為k的異步任務處理程序作為所述編號為i的任務數據隊列中所有數據的執行程序。

8.根據權利要求7所述的裝置，其特征在于，所述裝置還包括：

任務數據隊列發送單元，用于向所述編號為k的異步任務處理程序發送所述編號為i的任務數據隊列。

9.根據權利要求6-8任一項所述的裝置，其特征在于，所述裝置還包括：

刪除指令接收單元，用于接收分配的異步任務處理程序發送的刪除指令；

數據刪除單元，用于根據所述刪除指令刪除所述Redis中相應的任務數據隊列中的數據。

10.根據權利要求9所述的裝置，其特征在于，所述裝置還包括：

任務數據接收單元，用于接收任務數據；

調度觸發單元，用于將接收到的所述任務數據插入Redis的任務數據隊列中，觸發執行調度。