[發(fā)明專利]數(shù)據(jù)采集調(diào)度的方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201310243125.2
• 申請(qǐng)日: 2013-06-19
• 公開（公告）號(hào): CN103346902A
• 公開（公告）日: 2013-10-09
• 發(fā)明（設(shè)計(jì)）人: 張志武;王雪山;劉興輝
• 申請(qǐng)（專利權(quán)）人: 北京華勝天成科技股份有限公司
• 主分類號(hào): H04L12/24
• 分類號(hào): H04L12/24;H04L29/08
• 代理公司: 廣州華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 陳振

技術(shù)領(lǐng)域

本發(fā)明涉及計(jì)算機(jī)信息技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)采集調(diào)度的方法及系統(tǒng)。

背景技術(shù)

隨著網(wǎng)絡(luò)應(yīng)用的日益廣泛，服務(wù)器系統(tǒng)的數(shù)據(jù)流量迅速增加，從而使傳統(tǒng)類型的服務(wù)器系統(tǒng)的數(shù)據(jù)處理能力受到極大挑戰(zhàn)，為解決上述問(wèn)題，目前普遍采用集群技術(shù)，即利用兩臺(tái)以上的服務(wù)器進(jìn)行協(xié)同工作，而且集群技術(shù)具有極高的可靠性和強(qiáng)大靈活的系統(tǒng)擴(kuò)充能力，但為充分發(fā)揮各服務(wù)器之間的協(xié)同工作，需要對(duì)各服務(wù)器的各項(xiàng)指標(biāo)進(jìn)行數(shù)據(jù)采集，從而靈活調(diào)度各服務(wù)器進(jìn)行工作。

在大型數(shù)據(jù)中心，物理服務(wù)器數(shù)量龐大，如果物理服務(wù)器實(shí)現(xiàn)虛擬化，則服務(wù)器數(shù)量更加龐大，面對(duì)如此龐大的服務(wù)器集群，并且每個(gè)服務(wù)器所要采集的指標(biāo)不一、各指標(biāo)采集間隔不一，這對(duì)調(diào)度服務(wù)器提出了較高的要求。一般的對(duì)各目標(biāo)服務(wù)器進(jìn)行指標(biāo)采集的方法容易造成調(diào)度服務(wù)器壓力過(guò)大，造成無(wú)法及時(shí)準(zhǔn)確的完成各調(diào)度指標(biāo)的采集任務(wù)；或存在要求各目標(biāo)服務(wù)器采集指標(biāo)必須一致及所有指標(biāo)采集周期必須一致等約束。

因此如何在不對(duì)各服務(wù)器的各項(xiàng)采集指標(biāo)進(jìn)行約束的條件下實(shí)現(xiàn)對(duì)目標(biāo)服務(wù)器高效、細(xì)粒度的數(shù)據(jù)采集是一個(gè)亟待解決的問(wèn)題。

發(fā)明內(nèi)容

為解決上述問(wèn)題本發(fā)明提供了一種數(shù)據(jù)采集調(diào)度的方法。

為實(shí)現(xiàn)本發(fā)明目的提供的一種數(shù)據(jù)采集調(diào)度的方法，包括以下步驟：

讀取各目標(biāo)服務(wù)器的采集指標(biāo)配置信息，設(shè)置每個(gè)采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值為所述配置信息中的指標(biāo)采集周期t_cycle的值，并構(gòu)建包含各目標(biāo)服務(wù)器的采集指標(biāo)配置信息及所述等待調(diào)度時(shí)間t_wait的數(shù)據(jù)表單schedule_table；

讀取調(diào)度服務(wù)器中預(yù)設(shè)的數(shù)據(jù)采集時(shí)間片t_slice的值，設(shè)置調(diào)度服務(wù)器中的定時(shí)采集調(diào)度器的采集時(shí)間間隔為所述t_slice的值，將所述采集時(shí)間間隔點(diǎn)作為調(diào)度時(shí)間點(diǎn)，并啟動(dòng)所述定時(shí)采集調(diào)度器；

當(dāng)所述定時(shí)采集調(diào)度器調(diào)度時(shí)間點(diǎn)到達(dá)時(shí)，所述數(shù)據(jù)表單中各個(gè)目標(biāo)服務(wù)器的各采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值減去數(shù)據(jù)采集時(shí)間片t_slice的值，作為新的等待調(diào)度時(shí)間t_wait的值；將所述等待調(diào)度時(shí)間t_wait的值小于等于0的采集指標(biāo)加入到調(diào)度服務(wù)器的任務(wù)隊(duì)列；同時(shí)將值小于等于0的采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值重新設(shè)置為所述采集指標(biāo)的指標(biāo)采集周期t_cycle的值，然后等待下一個(gè)調(diào)度時(shí)間點(diǎn)的到達(dá)。

較佳地，作為一種可實(shí)施方式，在所述讀取各目標(biāo)服務(wù)器的采集指標(biāo)配置信息，設(shè)置每個(gè)采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值為所述配置信息中的指標(biāo)采集周期t_cycle的值，并構(gòu)建包含各目標(biāo)服務(wù)器的采集指標(biāo)配置信息及所述等待調(diào)度時(shí)間t_wait的數(shù)據(jù)表單schedule_table之前，還包括以下步驟：

讀取調(diào)度服務(wù)器的數(shù)據(jù)采集模式schedule_mode；

所述數(shù)據(jù)采集模式包括立即采集模式和延遲采集模式；

在所述立即采集模式下，啟動(dòng)定時(shí)采集調(diào)度器時(shí)則對(duì)目標(biāo)服務(wù)器的各項(xiàng)采集指標(biāo)進(jìn)行采集調(diào)度；

在所述延遲采集模式下，啟動(dòng)定時(shí)采集調(diào)度器時(shí)不對(duì)目標(biāo)服務(wù)器的各項(xiàng)采集指標(biāo)進(jìn)行采集調(diào)度，只有當(dāng)某項(xiàng)采集指標(biāo)等待調(diào)度時(shí)間t_wait小于等于0時(shí)對(duì)所述采集指標(biāo)進(jìn)行采集調(diào)度。

較佳地，作為一種可實(shí)施方式，所述當(dāng)所述定時(shí)采集調(diào)度器調(diào)度時(shí)間點(diǎn)到達(dá)時(shí)，所述數(shù)據(jù)表單中各個(gè)目標(biāo)服務(wù)器的各采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值減去數(shù)據(jù)采集時(shí)間片t_slice的值，作為新的等待調(diào)度時(shí)間t_wait的值；將所述等待調(diào)度時(shí)間t_wait的值小于等于0的采集指標(biāo)加入到調(diào)度服務(wù)器的任務(wù)隊(duì)列；同時(shí)將值小于等于0的采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值重新設(shè)置為所述采集指標(biāo)的指標(biāo)采集周期t_cycle的值，然后等待下一個(gè)調(diào)度時(shí)間點(diǎn)的到達(dá)，包括以下步驟：

當(dāng)定時(shí)采集調(diào)度器調(diào)度時(shí)間點(diǎn)到達(dá)時(shí)，所述數(shù)據(jù)表單中各個(gè)目標(biāo)服務(wù)器的各采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值減去數(shù)據(jù)采集時(shí)間片t_slice的值，得到更新后的新的等待調(diào)度時(shí)間t_wait的值；

檢測(cè)出每臺(tái)目標(biāo)服務(wù)器的各采集指標(biāo)的所述新的等待調(diào)度時(shí)間t_wait的值小于等于0的采集指標(biāo)；

將每臺(tái)目標(biāo)服務(wù)器中的等待調(diào)度時(shí)間t_wait的值小于等于0的采集指標(biāo)組成采集調(diào)度指標(biāo)集合，發(fā)送所述采集調(diào)度指標(biāo)集合到采集任務(wù)，并將所述采集調(diào)度指標(biāo)集合中的采集指標(biāo)的等待調(diào)度時(shí)間t_wait的值重新設(shè)置為所述采集指標(biāo)的指標(biāo)采集周期t_cycle的值，直至下一個(gè)調(diào)度時(shí)間點(diǎn)的到達(dá)；