一種集群定時任務同步方法、系統和設備與流程

2023-09-20 08:21:30

本發明涉及集群
技術領域：
：，尤其涉及一種集群定時任務同步方法、系統和設備。
背景技術：
：：隨著網際網路技術的廣泛應用與快速發展，集群技術以其高性能、高可用、可擴展的特點獲得了越來越廣泛的應用與關注。集群通過多臺節點機(伺服器)協同起來執行任務並作為單一的系統向用戶提供服務。定時任務能夠在指定時間執行指定的任務，在用用程序中獲得了廣泛的應用，例如linux系統中的crontab命令，用於周期性的執行指定任務；java的util包中的timer定時器，一種簡單易用的定時任務；spring中的quartz，可以讓你的程序在指定時間執行，也可以按照某一個頻度執行。然而，上述定時任務在集群環境下並不能很好的應用：crontab命令並不便於應用程式調用；timer定時器過於簡單並不能執行較複雜的定時策略；quartz兼具了crontab命令豐富的定時策略以及timer的易用性，但其配置通常寫在xml文件中不能更改並不便於動態的配置定時任務。因此，現有的定時任務在集群環境下沒有解決任務如何在多個節點間的任務如何同步的問題。技術實現要素：本發明的主要目的在於提出一種集群定時任務同步方法、系統和設備，旨在解決在多個訂閱者節點中實現定時任務同步處理的問題。為實現上述目的，本發明提出一種集群定時任務同步方法，應用於集群中的目標訂閱者節點，所述目標訂閱者節點包含至少一個訂閱者節點，所述方法包括：接收目標定時任務的任務通知；按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息；根據所讀取的目標定時任務信息開啟定時任務。可選的，所述按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，包括：按照預設周期，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；或，按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除。可選的，所述目標定時任務信息至少包括：任務標識、任務定時策略、執行任務時所要調用的類、執行任務時所要調用的參數和過程。可選的，在所述目標訂閱者節點中的每一個訂閱者節點均有特定標識的情況下，所述按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，包括：根據所述訂閱者節點的所具有的特定標識，查找與所述特定標識相對應的任務接收隊列；讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息。相較於現有技術，本發明提供的一種集群定時任務同步方法，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，從而解決了現有技術中多個訂閱者節點之間任務不同步的問題。此外，為實現上述目的，本發明還提出一種集群定時任務同步系統，包括：任務發布設備、目標訂閱者節點、目標資料庫；所述任務發布設備，用於發布目標定時任務的任務通知至所述目標訂閱者節點，以及發布與所述目標定時任務相對應的目標定時任務信息至所述目標資料庫中的目標任務接收隊列，其中，所述目標訂閱者節點分別與所述目標任務接收隊列具有對應標識；目標資料庫，用於採用所述目標任務接收隊列接收與所述目標定時任務通知相對應的目標定時任務信息；所述目標訂閱者節點，用於接收所述目標定時任務通知，並通過對應從所述目標任務接收隊列中獲取與所述目標定時任務相對應的目標定時任務信息，並開啟定時任務。相較於現有技術，本發明提供的一種集群定時任務同步系統，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，從而解決了現有技術中多個訂閱者節點之間任務不同步的問題。為實現上述目的，本發明還提出一種集群定時任務同步設備，應用於集群中的目標訂閱者節點，所述目標訂閱者節點包含至少一個訂閱者節點，所述集群定時任務同步設備包括：存儲器、處理器及通信總線；所述通信總線用於實現處理器和存儲器之間的連接通信；所述處理器用於執行集群定時任務同步程序，以實現以下步驟：接收目標定時任務的任務通知；按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息；根據所讀取的目標定時任務信息開啟定時任務。可選的，所述處理器還用於執行集群定時任務同步程序，以實現以下步驟：在所述哈希地圖結構表中記錄並標記所述第二目標資按照預設周期，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；或，按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除。可選的，所述處理器還用於執行集群定時任務同步程序，以實現以下步驟：在所述目標訂閱者節點中的每一個訂閱者節點均有特定標識的情況下，根據所述訂閱者節點的所具有的特定標識，查找與所述特定標識相對應的任務接收隊列；讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息。可選的，所述處理器還用於執行集群定時任務同步程序，以實現以下步驟：所述目標定時任務信息至少包括：任務標識、任務定時策略、執行任務時所要調用的類、執行任務時所要調用的參數和過程。相較於現有技術，本發明提供的一種集群定時任務同步設備，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，從而解決了現有技術中多個訂閱者節點之間任務不同步的問題。本發明還提供一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有一個或者多個程序，所述一個或者多個程序可被一個或者多個處理器執行，以實現如下步驟：接收目標定時任務的任務通知；按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息；根據所讀取的目標定時任務信息開啟定時任務。可選的，所述一個或者多個程序可被一個或者多個處理器執行，以實現如下步驟：按照預設周期，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；或，按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除。可選的，所述一個或者多個程序可被一個或者多個處理器執行，以實現如下步驟：所述目標定時任務信息至少包括：任務標識、任務定時策略、執行任務時所要調用的類、執行任務時所要調用的參數和過程。可選的，所述一個或者多個程序可被一個或者多個處理器執行，以實現如下步驟：在所述目標訂閱者節點中的每一個訂閱者節點均有特定標識的情況下，根據所述訂閱者節點的所具有的特定標識，查找與所述特定標識相對應的任務接收隊列；讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息。相較於現有技術，本發明提供的一種計算機可讀存儲介質，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，從而解決了現有技術中多個訂閱者節點之間任務不同步的問題。附圖說明圖1為實現本發明各個實施例的一個可選的移動終端的硬體結構示意圖；圖2為如圖1所示的移動終端的無線通信系統示意圖；圖3為本發明所述的集群定時任務同步方法的流程示意圖；圖4為本發明所述的集群定時任務同步系統的模塊示意圖；圖5為本發明所述的集群定時任務同步系統的實施例示意圖；圖6為本發明所述的集群定時任務同步方法的實施例示意圖；圖7為本發明所述的集群定時任務同步設備模塊示意圖；圖8為本發明所述的計算機可讀存儲介質模塊示意圖。附圖標記：本發明目的的實現、功能特點及優點將結合實施例，參照附圖做進一步說明。具體實施方式應當理解，此處所描述的具體實施例僅僅用以解釋本發明，並不用於限定本發明。在後續的描述中，使用用於表示元件的諸如「模塊」、「部件」或「單元」的後綴僅為了有利於本發明的說明，其本身沒有特定的意義。因此，「模塊」、「部件」或「單元」可以混合地使用。終端可以以各種形式來實施。例如，本發明中描述的終端可以包括諸如手機、平板電腦、筆記本電腦、掌上電腦、個人數字助理(personaldigitalassistant，pda)、便捷式媒體播放器(portablemediaplayer，pmp)、導航裝置、可穿戴設備、智能手環、計步器等移動終端，以及諸如數字tv、臺式計算機等固定終端。後續描述中將以移動終端為例進行說明，本領域技術人員將理解的是，除了特別用於移動目的的元件之外，根據本發明的實施方式的構造也能夠應用於固定類型的終端。請參閱圖1，其為實現本發明各個實施例的一種移動終端的硬體結構示意圖，該移動終端100可以包括：rf(radiofrequency，射頻)單元101、wifi模塊102、音頻輸出單元103、a/v(音頻/視頻)輸入單元104、傳感器105、顯示單元106、用戶輸入單元107、接口單元108、存儲器109、處理器110、以及電源111等部件。本領域技術人員可以理解，圖1中示出的移動終端結構並不構成對移動終端的限定，移動終端可以包括比圖示更多或更少的部件，或者組合某些部件，或者不同的部件布置。下面結合圖1對移動終端的各個部件進行具體的介紹：射頻單元101可用於收發信息或通話過程中，信號的接收和發送，具體的，將基站的下行信息接收後，給處理器110處理；另外，將上行的數據發送給基站。通常，射頻單元101包括但不限於天線、至少一個放大器、收發信機、耦合器、低噪聲放大器、雙工器等。此外，射頻單元101還可以通過無線通信與網絡和其他設備通信。上述無線通信可以使用任一通信標準或協議，包括但不限於gsm(globalsystemofmobilecommunication，全球移動通訊系統)、gprs(generalpacketradioservice，通用分組無線服務)、cdma2000(codedivisionmultipleaccess2000，碼分多址2000)、wcdma(widebandcodedivisionmultipleaccess,寬帶碼分多址)、td-scdma(timedivision-synchronouscodedivisionmultipleaccess，時分同步碼分多址)、fdd-lte(frequencydivisionduplexing-longtermevolution，頻分雙工長期演進)和tdd-lte(timedivisionduplexing-longtermevolution，分時雙工長期演進)等。wifi屬於短距離無線傳輸技術，移動終端通過wifi模塊102可以幫助用戶收發電子郵件、瀏覽網頁和訪問流式媒體等，它為用戶提供了無線的寬帶網際網路訪問。雖然圖1示出了wifi模塊102，但是可以理解的是，其並不屬於移動終端的必須構成，完全可以根據需要在不改變發明的本質的範圍內而省略。音頻輸出單元103可以在移動終端100處於呼叫信號接收模式、通話模式、記錄模式、語音識別模式、廣播接收模式等等模式下時，將射頻單元101或wifi模塊102接收的或者在存儲器109中存儲的音頻數據轉換成音頻信號並且輸出為聲音。而且，音頻輸出單元103還可以提供與移動終端100執行的特定功能相關的音頻輸出(例如，呼叫信號接收聲音、消息接收聲音等等)。音頻輸出單元103可以包括揚聲器、蜂鳴器等等。a/v輸入單元104用於接收音頻或視頻信號。a/v輸入單元104可以包括圖形處理器(graphicsprocessingunit，gpu)1041和麥克風1042，圖形處理器1041對在視頻捕獲模式或圖像捕獲模式中由圖像捕獲裝置(如攝像頭)獲得的靜態圖片或視頻的圖像數據進行處理。處理後的圖像幀可以顯示在顯示單元106上。經圖形處理器1041處理後的圖像幀可以存儲在存儲器109(或其它存儲介質)中或者經由射頻單元101或wifi模塊102進行發送。麥克風1042可以在電話通話模式、記錄模式、語音識別模式等等運行模式中經由麥克風1042接收聲音(音頻數據)，並且能夠將這樣的聲音處理為音頻數據。處理後的音頻(語音)數據可以在電話通話模式的情況下轉換為可經由射頻單元101發送到移動通信基站的格式輸出。麥克風1042可以實施各種類型的噪聲消除(或抑制)算法以消除(或抑制)在接收和發送音頻信號的過程中產生的噪聲或者幹擾。移動終端100還包括至少一種傳感器105，比如光傳感器、運動傳感器以及其他傳感器。具體地，光傳感器包括環境光傳感器及接近傳感器，其中，環境光傳感器可根據環境光線的明暗來調節顯示面板1061的亮度，接近傳感器可在移動終端100移動到耳邊時，關閉顯示面板1061和/或背光。作為運動傳感器的一種，加速計傳感器可檢測各個方向上(一般為三軸)加速度的大小，靜止時可檢測出重力的大小及方向，可用於識別手機姿態的應用(比如橫豎屏切換、相關遊戲、磁力計姿態校準)、振動識別相關功能(比如計步器、敲擊)等；至於手機還可配置的指紋傳感器、壓力傳感器、虹膜傳感器、分子傳感器、陀螺儀、氣壓計、溼度計、溫度計、紅外線傳感器等其他傳感器，在此不再贅述。顯示單元106用於顯示由用戶輸入的信息或提供給用戶的信息。顯示單元106可包括顯示面板1061，可以採用液晶顯示器(liquidcrystaldisplay，lcd)、有機發光二極體(organiclight-emittingdiode,oled)等形式來配置顯示面板1061。用戶輸入單元107可用於接收輸入的數字或字符信息，以及產生與移動終端的用戶設置以及功能控制有關的鍵信號輸入。具體地，用戶輸入單元107可包括觸控面板1071以及其他輸入設備1072。觸控面板1071，也稱為觸控螢幕，可收集用戶在其上或附近的觸摸操作(比如用戶使用手指、觸筆等任何適合的物體或附件在觸控面板1071上或在觸控面板1071附近的操作)，並根據預先設定的程式驅動相應的連接裝置。觸控面板1071可包括觸摸檢測裝置和觸摸控制器兩個部分。其中，觸摸檢測裝置檢測用戶的觸摸方位，並檢測觸摸操作帶來的信號，將信號傳送給觸摸控制器；觸摸控制器從觸摸檢測裝置上接收觸摸信息，並將它轉換成觸點坐標，再送給處理器110，並能接收處理器110發來的命令並加以執行。此外，可以採用電阻式、電容式、紅外線以及表面聲波等多種類型實現觸控面板1071。除了觸控面板1071，用戶輸入單元107還可以包括其他輸入設備1072。具體地，其他輸入設備1072可以包括但不限於物理鍵盤、功能鍵(比如音量控制按鍵、開關按鍵等)、軌跡球、滑鼠、操作杆等中的一種或多種，具體此處不做限定。進一步地，觸控面板1071可覆蓋顯示面板1061，當觸控面板1071檢測到在其上或附近的觸摸操作後，傳送給處理器110以確定觸摸事件的類型，隨後處理器110根據觸摸事件的類型在顯示面板1061上提供相應的視覺輸出。雖然在圖1中，觸控面板1071與顯示面板1061是作為兩個獨立的部件來實現移動終端的輸入和輸出功能，但是在某些實施例中，可以將觸控面板1071與顯示面板1061集成而實現移動終端的輸入和輸出功能，具體此處不做限定。接口單元108用作至少一個外部裝置與移動終端100連接可以通過的接口。例如，外部裝置可以包括有線或無線頭戴式耳機埠、外部電源(或電池充電器)埠、有線或無線數據埠、存儲卡埠、用於連接具有識別模塊的裝置的埠、音頻輸入/輸出(i/o)埠、視頻i/o埠、耳機埠等等。接口單元108可以用於接收來自外部裝置的輸入(例如，數據信息、電力等等)並且將接收到的輸入傳輸到移動終端100內的一個或多個元件或者可以用於在移動終端100和外部裝置之間傳輸數據。存儲器109可用於存儲軟體程序以及各種數據。存儲器109可主要包括存儲程序區和存儲數據區，其中，存儲程序區可存儲作業系統、至少一個功能所需的應用程式(比如聲音播放功能、圖像播放功能等)等；存儲數據區可存儲根據手機的使用所創建的數據(比如音頻數據、電話本等)等。此外，存儲器109可以包括高速隨機存取存儲器，還可以包括非易失性存儲器，例如至少一個磁碟存儲器件、快閃記憶體器件、或其他易失性固態存儲器件。處理器110是移動終端的控制中心，利用各種接口和線路連接整個移動終端的各個部分，通過運行或執行存儲在存儲器109內的軟體程序和/或模塊，以及調用存儲在存儲器109內的數據，執行移動終端的各種功能和處理數據，從而對移動終端進行整體監控。處理器110可包括一個或多個處理單元；優選的，處理器110可集成應用處理器和調製解調處理器，其中，應用處理器主要處理作業系統、用戶界面和應用程式等，調製解調處理器主要處理無線通信。可以理解的是，上述調製解調處理器也可以不集成到處理器110中。移動終端100還可以包括給各個部件供電的電源111(比如電池)，優選的，電源111可以通過電源管理系統與處理器110邏輯相連，從而通過電源管理系統實現管理充電、放電、以及功耗管理等功能。儘管圖1未示出，移動終端100還可以包括藍牙模塊等，在此不再贅述。為了便於理解本發明實施例，下面對本發明的移動終端所基於的通信網絡系統進行描述。請參閱圖2，圖2為本發明實施例提供的一種通信網絡系統架構圖，該通信網絡系統為通用移動通信技術的lte系統，該lte系統包括依次通訊連接的ue(userequipment，用戶設備)201，e-utran(evolvedumtsterrestrialradioaccessnetwork，演進式umts陸地無線接入網)202，epc(evolvedpacketcore，演進式分組核心網)203和運營商的ip業務204。具體地，ue201可以是上述終端100，此處不再贅述。e-utran202包括enodeb2021和其它enodeb2022等。其中，enodeb2021可以通過回程(backhaul)(例如x2接口)與其它enodeb2022連接，enodeb2021連接到epc203，enodeb2021可以提供ue201到epc203的接入。epc203可以包括mme(mobilitymanagemententity，移動性管理實體)2031，hss(homesubscriberserver，歸屬用戶伺服器)2032，其它mme2033，sgw(servinggateway，服務網關)2034，pgw(pdngateway，分組數據網絡網關)2035和pcrf(policyandchargingrulesfunction，政策和資費功能實體)2036等。其中，mme2031是處理ue201和epc203之間信令的控制節點，提供承載和連接管理。hss2032用於提供一些寄存器來管理諸如歸屬位置寄存器(圖中未示)之類的功能，並且保存有一些有關服務特徵、數據速率等用戶專用的信息。所有用戶數據都可以通過sgw2034進行發送，pgw2035可以提供ue201的ip地址分配以及其它功能，pcrf2036是業務數據流和ip承載資源的策略與計費控制策略決策點，它為策略與計費執行功能單元(圖中未示)選擇及提供可用的策略和計費控制決策。ip業務204可以包括網際網路、內聯網、ims(ipmultimediasubsystem，ip多媒體子系統)或其它ip業務等。雖然上述以lte系統為例進行了介紹，但本領域技術人員應當知曉，本發明不僅僅適用於lte系統，也可以適用於其他無線通信系統，例如gsm、cdma2000、wcdma、td-scdma以及未來新的網絡系統等，此處不做限定。基於上述移動終端硬體結構以及通信網絡系統，提出本發明方法各個實施例。基於上述移動終端硬體結構以及通信系統，提出本發明系統各個實施例。首先，本發明提出一種集群定時任務同步方法。如圖3所示，在本實施例中，應用於集群中的目標訂閱者節點，所述目標訂閱者節點包含至少一個訂閱者節點，所述集群定時任務同步方法可以分為以下步驟：步驟s310為接收步驟：接收目標定時任務的任務通知；步驟s320為讀取步驟：按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息；步驟s330為開啟步驟：根據所讀取的目標定時任務信息開啟定時任務。上述這些步驟根據不同的需求調整順序，或者省略某些步驟。或者還可以根據需求補充其他的步驟。s310，接收目標定時任務的任務通知。需要說明的是，集群是通過多個節點(伺服器)協同起來執行任務並作為單一的系統向用戶提供服務，每一個伺服器可以稱為一個節點。對於本分發明實施例中，將用於接收並處理任務節點稱為訂閱者節點。本發明實施例中，將一個用來接收同一定時任務通知的或者多個訂閱者節點稱為目標訂閱者節點。具體的，任務通知可以由集群定時任務同步系統中的任務發布設備進行發布，任務發布設備可以為任務發布中心中用於發布任務相關信息的設備。具體的，任務通知是用於通知用於執行任務的節點：有任務需要該節點處理，以便節點能夠及時獲得待處理的任務的信息能夠及時對任務進行處理。任務通知的形式可以包括任務名稱、處理時間等等，也可以是包含任務的標定標識；任務通知只要能和具體的任務相對應起來即可，本發明實施例不對其形式進行具體限定。示4例性的，目標訂閱者節點中的訂閱者節點a，接收到任務通知為任務a的通知，任務通知的形式可以為：任務a，處理時間20160504170510，處理時間表示處理該任務的截止時間為2016年5月4日17時05分10秒。本發明實施例中的任務通知僅僅是示例性的。s320，按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息。需要說明的是，定時任務能夠在指定時間執行指定的任務，在用用程序中獲得了廣泛的應用。目標訂閱者節點在接收到任務通知以後，需要去獲取與該任務相關的任務信息，用於進行具體任務的執行。可以理解的是，任務發布設備可以將與該目標定時任務相關的任務信息放置於任務接收隊列中；在目標訂閱者節點中的任一訂閱者節點接收到任務通知以後去與自己相對應的任務接收隊列中讀取對應的任務信息。示例性的，目標訂閱者節點中的訂閱者節點a，訂閱者節點a對應的任務接收隊列為a1，訂閱者節點a接收到任務通知以後會去任務接收隊列a1中讀取與任務a對應的任務信息。需要說明的是，任務信息為處理目標定時任務所必不可少的信息，本發明實施例中所述目標定時任務信息可以至少包括：任務標識、任務定時策略、執行任務時所要調用的類、執行任務時所要調用的參數和過程。具體的，任務標識即任務id，用於標識任務；示例性的，目標定時任務a的任務id為a001。任務定時策略，即為用於控制任務的定時策略，通過cron表達式進行表達，cron表達式主要是用在quartz(quartz是一個完全由java編寫的開源作業調度框架)框架中，最主要的功能就是調度器(完成定時任務)，可以與javaee或者javase應用程式相結合也可以單獨使用，能藉助關係資料庫和jdbc作業存儲支持集群，負載均衡。需要說明的是，一個cron表達式有至少6個(也可能是7個)由空格分隔的時間元素。從左至右，這些元素的定義如下：1.秒(0–59)，2.分鐘(0–59)，3.小時(0–23)，4.月份中的日期(1–31)，5.月份(1–12或jan–dec)，6.星期中的日期(1–7或sun–sat)，7.年份(1970–2099)。具體的，每一個元素都可以顯式地規定一個值(如6)，一個區間(如9-12)，一個列表(如9，11，13)或一個通配符(如*)。「月份中的日期」和「星期中的日期」，這兩個元素是互斥的，因此應該通過設置一個問號(？)來表明你不想設置的那個欄位。示例性的，00,15,30,45*1-10*？表示：每月前10天每隔15分鐘。執行任務時所要調用的類即為定時任務執行時所要調用的類，類是具備某些共同特徵的實體的集合，它是一種抽象的概念。示例性的，執行目標定時任務a需要掉用的類為：person1、person2。另外，執行任務時所要調用的參數和過程；為執行方法名時定時任務執行時所要調用的具體方法名；方法參數列表中包含執行方法所需參數。示例性的，可以通過反射機制調用某個類的過程，具體的可以採用如下函數進行過程的調用：publicobjectinvoke(objectobj,object...args)這個方法過程對帶有指定參數的指定對象調用由此method對象表示的底層方法。個別參數被自動解包，以便與基本形參相匹配，基本參數和引用參數都隨需服從方法調用轉換。然後，返回使用參數args在obj上指派該對象所表示方法的結果。上述調用類的方法中包含的具體參數如下：obj表示從中調用底層方法的對象；rgs用於方法調用的參數。具體的，任務發布設備在發送任務接收隊列至目標訂閱者節點的同時將任務信息發送至任務接收隊列，在目標訂閱者節點接收到任務信息以後，按照預先設定的規則從任務接收隊列中獲取任務信息，當任務接收隊列為雲端的任務接收隊列，那麼目標訂閱者節點分別從雲端任務接收隊列中讀取任務信息。本發明實施例中，目標訂閱者節點可以按照預設周期，去讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；防止由於網絡問題目標訂閱者節點未接收到任務通知。另外，目標訂閱者節點啟動時可以到雲端任務隊列中讀取任務，防止由於節點暫時失效未接收到任務通知，從而未執行發布的任務。另外，目標訂閱者節點還可以按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除。以保證先進入任務接收隊列中的任務信息可以先進行處理。s330，根據所讀取的目標定時任務信息開啟定時任務。需要說明的是，目標訂閱者節點讀取到目標定時任務相關的任務信息以後，可以根據任務信息開啟定時任務，即執行定時任務。可以理解的是，任務信息中至少可以包括任務的標識、定時策略、調用的類、參數、調用類的方法及參數等等，目標訂閱節點可以先去根據任務標識確定需要執行的任務，獲取該任務定時的策略，示例性的，為任務的執行時間上的執行策略，然後根據該任務確認需要調用的類，確定以後進行類的調用與調用參數的獲取。應用本發明圖3所示的實施例，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，解決了現有技術中多個訂閱者節點之間任務不同步的問題，實現了各節點定時任務的同步。另外，本發明實施例還提供一種集群定時任務同步系統400，參見圖4，包括：任務發布設備410、目標訂閱者節點420、目標資料庫430；所述任務發布設備410，用於發布目標定時任務的任務通知至所述目標訂閱者節點，以及發布與所述目標定時任務相對應的目標定時任務信息至所述目標資料庫中的目標任務接收隊列，其中，所述目標訂閱者節點420分別與所述目標任務接收隊列具有對應標識；所述目標訂閱者節點420，用於接收所述目標定時任務通知，並通過對應從所述目標任務接收隊列中獲取與所述目標定時任務相對應的目標定時任務信息，並開啟定時任務；目標資料庫430，用於採用所述目標任務接收隊列接收與所述目標定時任務通知相對應的目標定時任務信息。具體的，任務發布設備410用於向指定的目標訂閱者節點集合發布定時任務；目標訂閱者節點420，由包含多個節點構成，用於執行定時任務；目標資料庫430，用於存儲定時任務同步所需的數據。具體的，可以將訂閱相同信息的訂閱者節點作為一個頻道，並將頻道信息存儲在目標資料庫430中，一個頻道設置一個標識或者一個設定值，任務發布設備410根據標識或者設定值頻道中的訂閱者節點發送任務通知並將任務信息放入對應接收者的雲端任務隊列。其中，任務通知告知訂閱者有新的任務。其中，雲端任務隊列為對應訂閱者未消費的任務隊列，可以為任務隊列設定一個標識；任務訂閱者節點也可以設置一個與其對應的任務隊列對應的任務接收隊列相同的標識，在訂閱者節點接收到任務通知後到，到與其自身相同的標識任務接收隊列中讀取任務，並將讀取過的任務清除出任務隊列。其中，讀取策略為每次讀取隊列中的所有任務。如圖5所示，任務發布設備410發送目標定時任務的任務通知至頻道1中的訂閱者節點，具體為訂閱者節點1和訂閱者節點2，還將該目標定時任務的目標定時任務信息發送至頻道1中所有目標訂閱者節點對應的雲端任務隊列中，即雲端任務隊列1和雲端任務隊列2；訂閱者節點和訂閱者節點2可以分別從雲端任務隊列1和雲端任務隊列2中獲取目標定時任務信息，以便開啟目標定時任務。本發明實施例中，目標資料庫430用於存儲雲端任務隊列、頻道等信息，避免了傳統發布訂閱機制的消息易失性。參見圖6，圖6為本發明實施例提供的集群定時任務同步方法的一個實施例。s610，將目標訂閱者節點放入訂閱者列表中；s620，向訂閱者列表中的每一個訂閱者節點發送任務通知；s630，按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；s640根據目標定時任務信息，所有目標訂閱者節點同時開啟定時任務。參見圖6，圖6為一種集群定時任務同步設備，應用於集群中的目標訂閱者節點，所述目標訂閱者節點包含至少一個訂閱者節點，所述集群定時任務同步設備包括：存儲器710、處理器720及通信總線730；所述通信總線730用於實現處理器120和存儲器710之間的連接通信；所述處理器720用於集群定時任務同步程序，以實現以下步驟：接收目標定時任務的任務通知；按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息；根據所讀取的目標定時任務信息開啟定時任務。進一步地，所述處理器720用於集群定時任務同步程序，以實現以下步驟：按照預設周期，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；或，按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除。進一步地，所述處理器720用於集群定時任務同步程序，以實現以下步驟：所述目標定時任務信息至少包括：任務標識、任務定時策略、執行任務時所要調用的類、執行任務時所要調用的參數和過程。進一步地，所述處理器720用於集群定時任務同步程序，以實現以下步驟：根據所述訂閱者節點的所具有的特定標識，查找與所述特定標識相對應的任務接收隊列；讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息。應用本發明圖7所示的實施例，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，從而解決了現有技術中多個訂閱者節點之間任務不同步的問題。進一步地，本發明還提供了一種計算機可讀存儲介質，參見圖8，所述計算機可讀存儲介質存儲有一個或者多個程序810，所述一個或者多個程序810可被一個或者多個處理器820執行，以實現以下步驟：接收目標定時任務的任務通知；按照預設規則，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，其中，所述目標定時任務信息為任意一個訂閱者節點的任務接收隊列所接收的與所述目標定時任務相對應的任務信息；根據所讀取的目標定時任務信息開啟定時任務。。進一步地，所述一個或者多個程序810被所述一個或者多個處理器820執行，以實現以下步驟：按照預設周期，讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除；或，按照先入先出的規則，依次讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息，以使所述任務接收隊列在所述目標定時任務信息讀取進行清除。進一步地，所述一個或者多個程序810被所述一個或者多個處理器820執行，以實現以下步驟所述目標定時任務信息至少包括：任務標識、任務定時策略、執行任務時所要調用的類、執行任務時所要調用的參數和過程。。進一步地，所述一個或者多個程序810還被所述一個或者多個處理器820執行，以實現以下步驟：在所述目標訂閱者節點中的每一個訂閱者節點均有特定標識的情況下，根據所述訂閱者節點的所具有的特定標識，查找與所述特定標識相對應的任務接收隊列；讀取任務接收隊列中與所述目標定時任務相對應的目標定時任務信息。。應用本發明圖8所示的實施例，通過目標訂閱者節點接收目標定時任務以及讀取與目標訂閱者節點相對應的任務接收隊列中的目標定時任務信息，從而根據所讀取的目標定時任務信息開啟定時任務。從而能夠實現在目標訂閱者節點中所有的訂閱者節點之間實現同步開啟定時任務，從而解決了現有技術中多個訂閱者節點之間任務不同步的問題。上述本發明實施例序號僅僅為了描述，不代表實施例的優劣。通過以上的實施方式的描述，本領域的技術人員可以清楚地了解到上述實施例方法可藉助軟體加必需的通用硬體平臺的方式來實現，當然也可以通過硬體，但很多情況下前者是更佳的實施方式。基於這樣的理解，本發明的技術方案本質上或者說對現有技術做出貢獻的部分可以以軟體產品的形式體現出來，該計算機軟體產品存儲在一個存儲介質(如rom/ram、磁碟、光碟)中，包括若干指令用以使得一臺終端設備(可以是手機，計算機，伺服器，空調器，或者網絡設備等)執行本發明各個實施例所述的方法。以上僅為本發明的優選實施例，並非因此限制本發明的專利範圍，凡是利用本發明說明書及附圖內容所作的等效結構或等效流程變換，或直接或間接運用在其他相關的
技術領域：
：，均同理包括在本發明的專利保護範圍內。當前第1頁12當前第1頁12