一種任務調度服務系統及方法
2023-07-13 20:46:51
一種任務調度服務系統及方法
【專利摘要】本發明提供一種任務調度服務系統及方法，所述任務調度服務系統包括：任務調用端模塊，用於發起任務調度請求；服務接口組件模塊，用於根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄；任務掃描組件模塊，用於對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；任務隊列組件模塊，用於按照優先級隊列元素出隊列算法在所述優先級隊列中選擇當前要執行的任務；任務執行模塊，用於執行所述當前要執行的任務。通過本發明所提供的任務調度服務系統及方法，使任務調度區分出優先級，提高了任務調度服務執行效率，同時也增強了用戶對不同優先級任務調度服務的差別化體驗。
【專利說明】一種任務調度服務系統及方法
【技術領域】
[0001]本發明涉及通信領域，特別是指一種任務調度服務系統及方法。
【背景技術】
[0002]近年來，電子通信已經普及我們的日常生活。其中語音信箱的應用也十分廣泛。目前語音信箱包括新郵件電話通知、客人定時留言、外呼提取傳真、日程提醒等定時任務，這些定時任務有些是由用戶指定日期時間的業務操作，有些是由於用戶指定日期時間的業務操作所引起的後續處理，有些是為實現某項功能採用內部任務機制實現。
[0003]這些定時任務的調用都是基於業務應用層執行內部處理步驟，增加了業務應用模塊的複雜度，造成業務應用層與系統內部的數據結構、數據分布以及模塊間關係的強耦合，而且由於業務通道不斷擴展和變化，會造成相同功能的重複開發測試，降低研發效率，也很難確保產品質量和性能。
【發明內容】
[0004]本發明要解決的技術問題是提供一種任務調度服務系統及方法。可以簡化業務應用層的處理邏輯，提高任務調度服務的執行效率及用戶體驗。
[0005]為解決上述技術問題，本發明的實施例提供一種任務調度服務系統及方法，所述任務調度服務系統包括:
[0006]任務調用端模塊，用於發起任務調度請求；
[0007]服務接口組件模塊，用於根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄；
[0008]任務掃描組件模塊，用於對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；
[0009]任務隊列組件模塊，用於按照優先級隊列元素出隊列算法在所述優先級隊列中選擇當前要執行的任務；
[0010]任務執行模塊，用於執行所述當前要執行的任務。
[0011]其中，所述任務調度服務系統還包括:
[0012]任務統計模塊，用於獲取和統計調度周期內的所述任務調用端模塊發起的任務調度請求總數以及所述任務執行模塊執行成功的任務數和執行失敗的任務數。
[0013]WEB管理模塊，用於配置任務的調度規則、系統參數，以及查詢當前任務的處理進度。
[0014]其中，所述服務接口組件模塊在創建任務時，應該按照任務調度算法為任務計算啟動時間和分配任務號。
[0015]其中，所述服務接口組件模塊還用於:接收所述任務執行模塊的任務執行結果報告、響應所述任務執行模塊對執行失敗的任務進行任務重試或進行任務的回執處理。
[0016]其中，所述服務接口組件模塊還用於:在任務重試時，按照任務調度規則計算算法計算任務的重新啟動時間。
[0017]其中，所述任務調度規則計算算法，具體是指:創建任務時當前的系統時間+最大啟動延遲時長* (大於新任務調度優先級的所有調度優先級的任務數比例總和)。
[0018]其中，所述服務接口組件模塊進行任務回執處理時，應該根據任務的信息向任務調用端模塊返回任務回執信息。
[0019]其中，所述服務接口組件模塊還用於:將執行結束的任務移動到歷史表中保存。
[0020]其中，所述任務掃描組件模塊還用於:在掃描到超時和過期的任務時，向服務接口組件模塊報告任務結果，使所述服務接口組件模塊對超時和過期的任務進行任務重試或進行任務的回執處理。
[0021]其中，所述任務隊列組件模塊還用於:在啟動任務發生異常時，向服務接口組件模塊報告任務結果，使所述服務接口組件模塊對啟動異常的任務進行任務重試或進行任務的回執處理。
[0022]其中，所述任務調度優先級算法，具體是指:新任務的任務類型對應的系統級優先級*2+任務優先標誌+1。
[0023]其中，所述優先級隊列元素出隊列算法，具體是指:任務隊列組件模塊按照各隊列的調度優先級逐一從每個任務隊列中取出任務處理，先處理高優先級隊列中的任務，再處理低優先級隊列中的任務，然後循環。
[0024]本發明的實施例還提供了一種任務調度方法，包括:
[0025]發起任務調度請求；
[0026]根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄；
[0027]對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；
[0028]按照優先級隊列元素出隊列算法，在所述優先級隊列中選擇當前要執行的任務；
[0029]執行當前要執行的任務。
[0030]其中，所述任務調度方法還包括:在任務重試時，按照任務規則算法計算任務的重新啟動時間。
[0031]本發明的上述技術方案的有益效果如下:
[0032]本發明的上述實施例通過任務調用端模塊發起任務調度請求；服務接口組件模塊根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄；任務掃描組件模塊對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；任務隊列組件模塊按照優先級隊列元素出隊列算法在所述優先級隊列中選擇當前要執行的任務；任務執行模塊執行所述當前要執行的任務；既簡化了業務應用層的處理邏輯，提高了任務調度服務執行效率，同時還增強了外部用戶對不同優先級任務調度服務的差別化體驗。
【專利附圖】
【附圖說明】
[0033]圖1為本發明所述任務調度服務系統的結構圖。
[0034]圖2、圖3、圖4為本發明所述任務調度實現方法的具體流程圖。
[0035]圖5為本發明所述任務調度方法的流程圖。
【具體實施方式】
[0036]為使本發明要解決的技術問題、技術方案和優點更加清楚，下面將結合附圖及具體實施例進行詳細描述。
[0037]本發明針對現有的定時任務的調用都是基於業務應用層執行內部處理且效率很低的問題，提供一種任務調度服務系統及方法。
[0038]如圖1所示，本發明的實施例提供一種任務調度服務系統，包括:
[0039]任務調用端模塊101，用於發起任務調度請求；
[0040]服務接口組件模塊102，用於根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄；
[0041]任務掃描組件模塊103，用於對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；
[0042]任務隊列組件模塊104，用於按照優先級隊列元素出隊列算法在所述優先級隊列中選擇當前要執行的任務；
[0043]任務執行模塊105，用於執行所述當前要執行的任務。
[0044]本發明的上述實施例通過任務調用端模塊發起任務調度請求；服務接口組件模塊根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄；任務掃描組件模塊對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；任務隊列組件模塊按照優先級隊列元素出隊列算法在所述優先級隊列中選擇當前要執行的任務；任務執行模塊執行所述當前要執行的任務；不僅簡化了業務應用層的處理邏輯，提高了任務調度服務執行效率，同時還增強了外部用戶對不同優先級任務調度服務的差別化體驗。
[0045]其中，再如圖1所示，本發明的上述任務調度服務系統的實施例還可以包括:
[0046]任務統計模塊106，用於獲取調度周期內的所述任務調用端模塊發起的任務調度請求總數以及所述任務執行模塊執行成功的任務數和執行失敗的任務數。
[0047]WEB管理模塊107，用於配置任務的調度規則、系統參數以及查詢當前任務的處理進度。
[0048]所述服務接口組件模塊102在創建任務時，具體用於:按照任務調度算法為任務計算啟動時間和分配任務號。
[0049]所述服務接口組件模塊102還用於:接收所述任務執行模塊105的任務執行結果報告、響應所述任務執行模塊105對執行失敗的任務進行任務重試或進行任務的回執處理。
[0050]所述服務接口組件模塊102還用於:在任務重試時，按照任務調度規則計算算法計算任務的重新啟動時間。
[0051]所述任務調度規則計算算法，具體是指:創建任務時當前的系統時間+最大啟動延遲時長* (大於新任務調度優先級的所有調度優先級的任務數比例總和)。
[0052]所述服務接口組件模塊102進行任務回執處理時，具體用於:根據任務的信息向任務調用端模塊101返回任務回執信息。
[0053]所述服務接口組件模塊102還用於:將執行結束的任務移動到歷史表中保存。
[0054]所述任務掃描組件模塊103還用於:在掃描到超時和過期的任務時，向服務接口組件模塊102報告任務結果，使所述服務接口組件模塊102對超時和過期的任務進行任務重試或進行任務的回執處理。
[0055]所述任務隊列組件模塊104還用於:在啟動任務發生異常時，向服務接口組件模塊102報告任務結果，使所述服務接口組件模塊102對啟動異常的任務進行任務重試或進行任務的回執處理。
[0056]所述任務調度優先級算法，具體是指:新任務的任務類型對應的系統級優先級*2+任務優先標誌+1。
[0057]所述優先級隊列元素出隊列算法，具體是指:任務隊列組件模塊104按照各隊列的調度優先級逐一從每個任務隊列中取出任務處理，先處理高優先級隊列中的任務，在處理低優先級隊列中的任務，然後循環。
[0058]下面結合圖2 —圖4具體說明上述系統是如何運行實現的。
[0059]如圖2所示，為本發明所述任務調度服務系統的實現方法的具體流程圖，主要有以下步驟:
[0060]步驟201，WEB管理模塊107主要負責配置任務調度規則，包括任務的系統級優先級、禁止調度時間、重試間隔和最大重試次數等參數；
[0061]步驟202，任務調用端模塊101向服務接口組件模塊102發送任務調度請求，請求消息中需指定當前調度任務的類型、是否需要將調度結果回執等欄位，調度任務啟動時間欄位可選；
[0062]步驟203，服務接口組件模塊102在接收任務調度請求後，根據任務調度規則計算算法計算任務的啟動時間，並在資料庫中創建對應的任務調度記錄；其中，需要根據統計周期內的各個調度優先級的任務計數器，計算出各個調度優先級的任務數佔總任務數的比例。
[0063]步驟204，任務掃描組件103根據任務調度優先級算法查詢出滿足任務啟動條件的任務，掃描其任務調度記錄，並將任務調度記錄放入對應的任務優先級隊列中；其中，例如,系統級優先級為3種(0、1、2)，每種任務類型分為普通和緊急2種優先級(0、1)，故整個系統的最大調度優先級級別數為6，但考慮到後續可能擴展系統級優先級數，故任務調度服務可配置其支持的最大調度系統級優先級個數，預設為6。
[0064]步驟205，任務隊列組件模塊104按照優先級隊列元素出隊列算法，將優先級隊列中符合要求的任務調出，並發送給任務執行模塊105執行；其中，任務優先級隊列元素出隊列算法包括:任務隊列組件按照各隊列的調度優先級數逐一從每個任務隊列取出任務處理，先處理高優先級隊列，再處理低優先級隊列，然後循環。每輪循環中按照優先級值6、5、4、3、2、1從對應的隊列中取出元素；
[0065]步驟206，任務執行模塊105在接收任務調度執行請求後，觸發智能網平臺進行任務調度，並將執行結果反饋給服務接口組件模塊102 ；
[0066]步驟207，由服務接口組件模塊102判斷調度是否成功，若成功則進入步驟208 ;若失敗則進入步驟209 ；
[0067]步驟208，由服務接口組件模塊102判斷任務調度請求是否需要回執，若需要回執，則進入步驟210 ;若不需要則進入步驟214，本次任務調度結束，服務接口組件模塊102將調度任務導入到任務歷史表中；
[0068]步驟209，由服務接口組件模塊102判斷調度任務的重試次數是否已超過最大重試次數，若超過則回到步驟208 ;若不超過則進入步驟212，由服務接口組件模塊102計算任務重試啟動時間，供任務掃描組件模塊103掃描；
[0069]步驟210，由服務接口組件模塊102判斷回執執行結果給任務調用端101是否成功，若成功則進入步驟214，本次任務調度結束，服務接口組件模塊102將調度任務導入到任務歷史表中；若不成功則進入步驟213，由服務接口組件模塊102計算任務重試回執時間，供任務掃描組件模塊103掃描。
[0070]如圖3所示，向服務接口組件模塊102請求調度的任務在創建和執行的過程中，可以分為任務執行和任務回執兩個階段:
[0071]首先是服務接口組件模塊102在任務表裡創建任務，任務創建之後需要等待執行；
[0072]在等待執行的過程中會出現三種情況:
[0073]調度啟動成功則由任務執行模塊105執行任務；
[0074]由任務調用端101主動取消任務；
[0075]等待執行且超時；
[0076]在執行任務階段通常會有三種結果:
[0077]執行成功，任務執行模塊105返回任務執行成功；
[0078]執行失敗，可分為:任務執行模塊105返回任務執行失敗；任務隊列組件模塊104返回任務啟動失敗；等待狀態的任務超時；
[0079]正在執行超時；
[0080]任務表中的任務都需要回執，在任務回執階段通常會有四種情況:
[0081]等待回執，回執失敗但可重試；
[0082]回執成功；
[0083]回執失敗，回執失敗且不可重試，或者回執失敗且已超過最大重試次數；
[0084]回執超時，等待回執超時；
[0085]如圖4所示，根據任務統計模塊106獲取調度周期內的各個調度優先級的任務計數器，計算出各個調度優先級的任務數佔總任務數的比例。為避免某個調度優先級不存在任務卻佔用延遲時間片，因此本算法採用根據每個調度優先級的任務數佔所有調度優先級的任務總數比例，來計算每個調度優先級的任務啟動時間。
[0086]如圖5所示，本發明的實施例還提供一種任務調度方法，包括:
[0087]步驟501,發起任務調度請求；
[0088]步驟502，根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄;
[0089]步驟503，對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中；
[0090]步驟504按照優先級隊列元素出隊列算法，在所述優先級隊列中選擇當前要執行的任務；
[0091]步驟505執行當前要執行的任務。
[0092]進一步的，上述實施例還可以進一步包括:
[0093]步驟506任務執行成功後，將執行結果回執給任務服務接口組件模塊102 ；
[0094]步驟507服務接口組件模塊102將結束的任務移動到任務歷史表中保存。
[0095]進一步地，所述任務調度方法，還包括:在任務重試時，服務接口組件應按照任務規則算法計算任務的重新啟動時間。
[0096]進一步地，所述任務調度方法，還包括:對於結束且要求回執的任務，服務接口組件應根據任務信息向任務調用端返回任務回執信息。
[0097]該方法的實施例是與上述系統對應的實施例，上述系統實施例中所有實現流程均適用於該方法的實施例，也能達到相同的技術效果。
[0098]本發明所述的任務調度服務系統及方法是基於系統分層構建的思想，由中間服務層負責與內部模塊交互實現定時任務的調度。具體來講，第一，對於外部用戶而言，任務的調度更加智能實時，而且支持任務調度系統模塊的多個部署；可以設置禁呼時段、啟呼延遲等功能；還能使用戶體驗到不同優先級任務調度服務的差異性。第二，對於廠商和內部工程部署維護而言，系統的配置簡單有效，操作方便；簡化業務應用層處理邏輯，提高了任務調度服務執行效率；實現參數配置的WEB界面化，方便管理員的管理維護；採用數據統計平臺，對系統用戶量、性能和穩定性的統計更加清晰有據。本發明的上述實施例不僅簡化了業務應用層的處理邏輯，提高了任務調度服務執行效率，同時還增強了外部用戶對不同優先級任務調度服務的差別化體驗。
[0099]以上所述是本發明的優選實施方式，應當指出，對於本【技術領域】的普通技術人員來說，在不脫離本發明所述原理的前提下，還可以作出若干改進和潤飾，這些改進和潤飾也應視為本發明的保護範圍。
【權利要求】
1.一種任務調度服務系統，其特徵在於，包括: 任務調用端模塊，用於發起任務調度請求； 服務接口組件模塊，用於根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄； 任務掃描組件模塊，用於對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中； 任務隊列組件模塊，用於按照優先級隊列元素出隊列算法在所述優先級隊列中選擇當前要執行的任務； 任務執行模塊，用於執行所述當前要執行的任務。
2.根據權利要求1所述的任務調度服務系統，其特徵在於，還包括: 任務統計模塊，用於獲取調度周期內的所述任務調用端模塊發起的任務調度請求總數以及所述任務執行模塊執行成功的任務數和執行失敗的任務數。
3.根據權利要求1所述的任務調度服務系統，其特徵在於，還包括: WEB管理模塊，用於配置任務的調度規則、系統參數以及查詢當前任務的處理進度。
4.根據權利要求1所述的任務調度服務系統，其特徵在於，所述服務接口組件模塊在創建任務時，具體用於:按照任務調度算法為任務計算啟動時間和分配任務號。
5.根據權利要求1所述的任務調度服務系統，其特徵在於，所述服務接口組件模塊還用於:接收所述任務執行模塊的任務執行結果報告、響應所述任務執行模塊對執行失敗的任務進行任務重試或進行任務的回執處理。
6.根據權利要求5所述的任務調度服務系統，其特徵在於，所述服務接口組件模塊還用於:在任務重試時，按照任務調度規則計算算法計算任務的重新啟動時間。
7.根據權利要求6所述的任務調度服務系統，其特徵在於，所述任務調度規則計算算法，具體是指: 創建任務時當前的系統時間+最大啟動延遲時長*(大於新任務調度優先級的所有調度優先級的任務數比例總和)。
8.根據權利要求5所述的任務調度服務系統，其特徵在於，所述服務接口組件模塊進行任務回執處理時，具體用於:根據任務的信息向任務調用端模塊返回任務回執信息。
9.根據權利要求1所述的任務調度服務系統，其特徵在於，所述服務接口組件模塊還用於:將執行結束的任務移動到歷史表中保存。
10.根據權利要求1所述的任務調度服務系統，其特徵在於，所述任務掃描組件模塊還用於:在掃描到超時和過期的任務時，向服務接口組件模塊報告任務結果，使所述服務接口組件模塊對超時和過期的任務進行任務重試或進行任務的回執處理。
11.根據權利要求1所述的任務調度服務系統，其特徵在於，所述任務隊列組件模塊還用於:在啟動任務發生異常時，向服務接口組件模塊報告任務結果，使所述服務接口組件模塊對啟動異常的任務進行任務重試或進行任務的回執處理。
12.根據權利要求1所述的任務調度服務系統，其特徵在於，所述任務調度優先級算法，具體是指: 新任務的任務類型對應的系統級優先級*2+任務優先標誌+1。
13.根據權利要求1所述的任務調度服務系統，其特徵在於，所述優先級隊列元素出隊列算法，具體是指: 任務隊列組件模塊按照各隊列的調度優先級逐一從每個任務隊列中取出任務處理，先處理高優先級隊列中的任務，再處理低優先級隊列中的任務，然後循環。
14.一種任務調度方法，其特徵在於，包括: 發起任務調度請求； 根據所述任務調度請求，創建任務，並在資料庫中創建對應的調度任務記錄； 對所述調度任務記錄進行掃描，按照任務調度優先級算法計算任務優先級，再將任務放入對應的優先級隊列中； 按照優先級隊列元素出隊列算法，在所述優先級隊列中選擇當前要執行的任務； 執行當前要執行的任務。
15.根據權利要求14所述的任務調度方法，其特徵在於，還包括: 在任務重試時，按照任務規則算法計算任務的重新啟動時間。
【文檔編號】G06F9/46GK104346215SQ201310342752
【公開日】2015年2月11日 申請日期:2013年8月7日 優先權日:2013年8月7日
【發明者】劉海波, 賴天建, 漆動波, 王祺 申請人:中興通訊股份有限公司