[發(fā)明專利]一種事件請求分布式調度方法和系統

在審

• 申請?zhí)枺?/td>: 201410006102.4
• 申請日: 2014-01-07
• 公開（公告）號: CN104268007A
• 公開（公告）日: 2015-01-07
• 發(fā)明（設計）人: 盧長燭;賈西貝
• 申請（專利權）人: 深圳市華傲數據技術有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 暫無信息
• 代理人: 暫無信息

技術領域

?本申請涉及互聯網通信技術領域，特別是涉及一種事件請求分布式調度方法和系統。

背景技術

在互聯網技術不斷發(fā)展的今天，越來越多的數據處理依賴較高的計算能力，為了解決單一處理節(jié)點無法處理多種多樣的工作，以及無法滿足越來越搞的計算能力的要求；技術人員提供一種分布式處理方案。

以Gearman為例，Gearman是一個用來把工作委派給其他機器、分布式的調用更適合做某項工作的機器、并發(fā)的做某項工作在多個調用間做負載均衡、或用來在調用其它語言的函數的系統。在Gearman中，通過調度器將事件請求隊列中的事件按照一定規(guī)則分配給各個工作節(jié)點，由各個工作節(jié)點進行處理后反饋。

但在實際使用中，本發(fā)明的發(fā)明人返現Gearman沒有時間調度器不能對工作集群實現調度策略，效率較低。

發(fā)明內容

本申請所要解決的技術問題是提供一種能夠以更高效率調度事件請求的事件請求分布式調度方法和系統。

為了解決上述問題，本申請公開了一種事件請求分布式調度方法，包括：

調度器獲取客戶群發(fā)送的事件請求；

所述調度器根據預置的時間調度和心跳包檢測，分配所述事件請求到服務群中相應工作節(jié)點；

所述工作節(jié)點處理事件請求返回事件處理結果到調度器，并保存執(zhí)行記錄到數據庫；

所述調度器返回事件處理結果到客戶群。

進一步，所述調度器根據預置的時間調度和心跳包檢測，分配所述事件請求到服務群中相應工作節(jié)點包括：

調度器根據心跳包檢測判斷服務群中正常工作的工作節(jié)點；

根據時間調度策略分配所述時間請求到正常工作的工作節(jié)點。

進一步，所述工作節(jié)點處理事件請求返回事件處理結果到調度器，并保存執(zhí)行記錄到數據庫包括：

所述工作節(jié)點接收事件請求后，根據自身處理策略進行事件處理形成事件處理結果；

所述工作節(jié)點返回事件處理結果到調度器，并保存執(zhí)行記錄到數據庫。

進一步，所述調度器返回事件處理結果到客戶群包括：

所述調度器返回事件處理結果到客戶群中對應的客戶端。

進一步，所述調度器返回事件處理結果到客戶群后還包括：

所述調度器保存執(zhí)行記錄到數據庫。

本申請還提供了一種事件請求分布式調度系統，包括：

調度器，用于獲取客戶群發(fā)送的事件請求；根據預置的時間調度和心跳包檢測，分配所述事件請求到服務群中相應工作節(jié)點；返回事件處理結果到客戶群；

所述工作節(jié)點，用于處理事件請求返回事件處理結果到調度器，并保存執(zhí)行記錄到數據庫。

進一步，所述調度器還用于：

根據心跳包檢測判斷服務群中正常工作的工作節(jié)點；

根據時間調度策略分配所述時間請求到正常工作的工作節(jié)點。

進一步，所述工作節(jié)點還用于：

接收事件請求后，根據自身處理策略進行事件處理形成事件處理結果；

所述工作節(jié)點返回事件處理結果到調度器，并保存執(zhí)行記錄到數據庫。

進一步，所述調度器還用于：

返回事件處理結果到客戶群中對應的客戶端。

進一步，所述調度器還用于：

保存執(zhí)行記錄到數據庫。

與現有技術相比，本申請包括以下優(yōu)點：調度器在分配事件請求時根據自身事件調度策略以及工作節(jié)點資源狀況進行分配，提高了工作節(jié)點的工作效率。

附圖說明????????????????????????

圖1是本發(fā)明一種事件請求分布式調度方法一實施例的流程圖；

圖2是本發(fā)明一種事件請求分布式調度系統一實施例的結構示意圖。

具體實施方式

為使本申請的上述目的、特征和優(yōu)點能夠更加明顯易懂，下面結合附圖和具體實施方式對本申請作進一步詳細的說明。

參照圖1，示出了本申請一種事件請求分布式調度方法一實施例的流程圖；

本發(fā)明實施例提供的事件請求分布式調度方法包括如下步驟：

步驟S101、調度器獲取客戶群發(fā)送的事件請求；

客戶群包含多個客戶端，其中任一客戶端均可通過與調度器的鏈路發(fā)送事件請求到調度器。其中客戶端與調度器的鏈路可以通過HTTP或TCP進行。

調度器獲取到事件請求后放入事件隊列，等待按照預置規(guī)則按序處理。