[發明專利]任務處理的方法和裝置

有效

• 申請號: 201810333475.0
• 申請日: 2018-04-13
• 公開（公告）號: CN110209474B
• 公開（公告）日: 2023-05-12
• 發明（設計）人: 何奇芫
• 申請（專利權）人: 騰訊科技（深圳）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 劉映東

1.一種任務處理的方法，其特征在于，所述方法由目標定時回調服務器執行，所述目標定時回調服務器是多個定時回調服務器中的其中一個，所述方法包括：

響應于達到預設輪詢周期，發送包含不存在即設置SETNX命令的第一lua腳本，所述SETNX命令用于根據分布式鎖的釋放情況獲取輪詢權限，所述輪詢權限是指對預先存儲的各定時任務進行輪詢的權限，所述預先存儲的各定時任務被劃分為多個任務組，每個任務組包括屬于同一業務的多個定時任務；其中，同一時刻只有一個定時回調服務器對所述預先存儲的各定時任務進行輪詢，每個定時回調服務器對應的預設輪詢周期可以相同，也可以不同；

當接收到針對SETNX命令的請求成功響應時，獲取每個業務對應的輪詢優先級，所述接收到針對SETNX命令請求成功響應用于表征所述目標定時回調服務器獲取所述輪詢權限，所述輪詢優先級與各個任務組內過期時刻最小的定時任務的過期時刻大小呈負相關關系；

基于輪詢優先級由高到低的順序，對多個業務對應的任務組分別進行輪詢；

當查找到至少一個超時任務時，分別向所述至少一個超時任務對應的設備發送超時通知，超時任務為過期時刻早于當前時刻的定時任務。

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

獲取目標定時任務；

確定所述目標定時任務所屬的目標業務；

將所述目標定時任務存儲到所述目標業務對應的任務組中。

3.根據權利要求1或2任意一項所述的方法，其特征在于，所述方法還包括：

當接收到接收成功通知時，根據所述接收成功通知所攜帶的任務標識，將所述任務標識對應的定時任務刪除。

4.根據權利要求1或2任意一項所述的方法，其特征在于，所述方法還包括：

當任一超時任務的超時時長大于預設的時長閾值時，將所述任一超時任務刪除。

5.根據權利要求4所述的方法，其特征在于，所述預設的時長閾值根據業務需求設置。

6.根據權利要求1或2任意一項所述的方法，其特征在于，所述方法還包括：

當前輪詢結束前，發送輪詢權限釋放請求，其中，所述輪詢權限釋放請求用于釋放所述輪詢權限。

7.根據權利要求6所述的方法，其特征在于，所述發送輪詢權限釋放請求，包括：

發送攜帶有第二lua腳本的輪詢權限釋放請求，所述第二lua腳本包括用于釋放所述輪詢權限的命令。

8.一種任務處理的裝置，其特征在于，所述裝置包括：

第一發送模塊，用于響應于達到預設輪詢周期，發送包含不存在即設置SETNX命令的第一lua腳本，所述SETNX命令用于根據分布式鎖的釋放情況獲取輪詢權限，所述輪詢權限是指對預先存儲的各定時任務進行輪詢的權限，所述預先存儲的各定時任務被劃分為多個任務組，每個任務組包括屬于同一業務的多個定時任務；其中，同一時刻只有一個定時回調服務器對所述預先存儲的各定時任務進行輪詢，每個定時回調服務器對應的預設輪詢周期可以相同，也可以不同；

輪詢模塊，用于當接收到針對SETNX命令的請求成功響應時，獲取每個業務對應的輪詢優先級，所述接收到針對SETNX命令請求成功響應用于表征目標定時回調服務器獲取所述輪詢權限，所述輪詢優先級與各個任務組內過期時刻最小的定時任務的過期時刻大小呈負相關關系；

所述輪詢模塊，用于基于輪詢優先級由高到低的順序，對多個業務對應的任務組分別進行輪詢；

第二發送模塊，用于當查找到至少一個超時任務時，分別向所述至少一個超時任務對應的設備發送超時通知，超時任務為過期時刻早于當前時刻的定時任務。

9.一種網絡設備，其特征在于，所述網絡設備包括處理器和存儲器，所述存儲器中存儲有至少一段程序，所述至少一段程序由所述處理器加載并執行以實現如權利要求1至7任一所述的任務處理的方法。

10.一種計算機可讀存儲介質，其特征在于，所述存儲介質中存儲有至少一段程序，所述至少一段程序由處理器加載并執行以實現如權利要求1至7任一所述的任務處理的方法。