混合任務下的動態資源調度方法及系統的製作方法
2023-05-09 21:47:56
混合任務下的動態資源調度方法及系統的製作方法
【專利摘要】本發明提供一種混合任務下的動態資源調度方法及系統，資源伺服器執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型，其中混合任務包括MR任務和VM任務，在判斷出VM任務時，將資源請求消息發送給位於第一工作節點上的VM伺服器，接收VM伺服器反饋的第一指示消息，根據所述第一指示消息獲取第一目標工作節點，將VM任務發送到第一目標工作節點上綁定資源並執行。本發明中資源伺服器在執行MR任務同時，也可以為VM任務分配資源，從而實現了對混合任務統一管理的目的，提高了執行混合任務時資源的整體利用率。
【專利說明】混合任務下的動態資源調度方法及系統
【技術領域】
[0001]本發明涉及計算機技術，尤其涉及一種混合任務下的動態資源調度方法及系統。
【背景技術】
[0002]虛擬機此也丨加，簡稱穩)技術的發展帶動了雲計算的發展，通過在雲中心使用VI技術，向用戶提供相同服務質量的在線任務的同時，能夠極大的較低集群的資源使用量，從而節約能源。但是無論是離線的數據計算任務，還是在線的穩任務，資源的整體利用率仍然不高。
[0003]在雲環境中資源的使用情況不僅影響集群中任務的執行性能，而且集群資源利用率的本質是成本問題，如購置成本、部署成本、維護成本等，同時由於虛擬機任務自身的特點導致了融合的難度。
[0004]通過將運行不同計算任務的集群混合在一起執行，可以提高集群資源利用率。一種簡單的方式是直接混合，比如可以將計算密集型任務和內存密集型任務同時執行。但是這種方式缺少一種全局的資源視圖，容易帶來一些額外的開銷，同時任務的放置、執行、資源綁定操作起來比較複雜。另外一種方式是對任務以及資源進行統一管理的框架，對不同類型的任務進行統一的資源管理和性能檢測。目前這種對任務和資源進行統一管理的框架在和？狀1上已經得到實現，但是和？狀1框架只能夠對離線計算類任務和資源進行統一管理，例如，無迴路有向圖^070110 ，簡稱0八(?任務、或者流任務等任務類型，丫犯11和？狀1兩種框架均不能對上述VI任務進行統一管理。
【發明內容】
[0005]本發明提供一種混合任務下的動態資源調度方法及系統，用於解決由於現有技術不能對包含VI任務的混合任務進行統一管理，使得執行混合任務時資源的整體利用率較低。
[0006]本發明的第一個方面是提供一種混合任務下的動態資源調度方法，包括:
[0007]資源伺服器在執行混合任務時接收物理任務發送的資源請求消息，並根據所述資源請求消息判斷所述物理任務的任務類型；所述混合任務包括映射歸屬任務和虛擬機VI任務；
[0008]如果判斷出所述任務類型為所述VI任務，所述資源伺服器將所述資源請求消息發送給位於第一工作節點上的VI伺服器；
[0009]所述資源伺服器接收所述VI伺服器反饋的第一指示消息；
[0010]所述資源伺服器根據所述第一指示消息獲取第一目標工作節點；
[0011]所述資源伺服器將所述穩任務發送到所述第一目標工作節點上綁定資源並執行。
[0012]本發明的另一個方面是提供一種混合任務下的動態資源調度系統，包括:資源伺服器和虛擬機VI伺服器；
[0013]所述資源伺服器，用於在執行混合任務時接收物理任務發送的資源請求消息，並根據所述資源請求消息判斷所述物理任務的任務類型，如果所述任務類型為虛擬機VI任務，將所述資源請求消息發送給位於第一工作節點上的VI伺服器，接收所述VI伺服器反饋的第一指示消息，根據所述第一指示消息獲取第一目標工作節點，所述VI任務發送到所述第一目標工作節點上綁定資源並執行；其中所述混合任務包括謝任務和VI任務；
[0014]所述VI伺服器，用於從所述資源伺服器處接收所述資源請求消息，並向所述資源伺服器發送第一指示消息，以指示所述資源伺服器根據所述第一指示消息獲取第一目標工作節點；
[0015]所述第一目標工作節點，用於接收所述VI任務，並對所述VI任務進行資源綁定及執行。
[0016]本發明提供的混合任務下的動態資源調度方法及系統，資源伺服器在執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型，其中混合任務包括謝任務和VI任務；在判斷為VI任務時，將資源請求消息發送給位於第一工作節點上的VI伺服器，接收VI伺服器反饋的第一指示消息，根據所述第一指示消息獲取第一目標工作節點，將VI任務發送到第一目標工作節點上綁定資源並執行。本發明中資源伺服器在執行服任務的同時，也可以VI任務分配工作資源，從而實現了對混合任務統一管理的目的，提高了執行混合任務時資源的整體利用率。
【專利附圖】
【附圖說明】
[0017]圖1為本發明一實施例提供的混合任務下的動態資源調度方法的流程示意圖；
[0018]圖2為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖；
[0019]圖3為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖；
[0020]圖4為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖；
[0021]圖5為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖；
[0022]圖6為本發明一實施例提供的混合任務下的動態資源調度系統的結構示意圖；
[0023]圖7為本發明另一實施例提供的混合任務下的動態資源調度系統的結構示意圖。
【具體實施方式】
[0024]圖1為本發明一實施例提供的混合任務下的動態資源調度方法的流程示意圖，如圖1所示，該方法包括:
[0025]100、資源伺服器執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型。
[0026]其中，所述混合任務包括映射歸屬(1即1^6(11106,簡稱謝)和VI任務。
[0027]本實施例中，資源伺服器處於執行混合任務的模式下，需要同時處理謝任務和VI任務。物理任務在運行時可以通過所在終端向資源伺服器發送的資源請求消息，資源伺服器根據該資源請求消息可以對物理任務的任務類型進行識別。可選地，資源請求消息中可以攜帶物理任務的任務類型標識。
[0028]101、如果判斷出任務類型為VI任務，資源伺服器將資源請求消息發送給位於第一工作節點上的穩伺服器。
[0029]在確定出任務類型為VI任務時，資源伺服器將資源請求消息發送給VI伺服器，其中，該穩伺服器處於某一工作節點上，本實施例中將VI伺服器所在的工作節點稱為第一工作節點。具體地，資源伺服器將資源請求消息首先發送給第一工作節點，由第一工作節點轉發給VI伺服器。
[0030]102、資源伺服器接收VI伺服器反饋的第一指示消息。
[0031]資源伺服器向VI伺服器發送資源請求消息後，VI伺服器可以向資源伺服器反饋一個第一指示消息，可選地，第一指示消息中攜帶有第一目標工作節點的標識，例如第一目標工作節點的地址。資源伺服器根據第一指示消息獲取到第一目標工作節點，其中，該第一目標工作節點為執行VI任務的工作節點。
[0032]103、資源伺服器根據所述第一指示消息獲取相應的第一目標工作節點。
[0033]104、資源伺服器將VI任務發送到第一目標工作節點上綁定資源並執行。
[0034]在獲取第一目標工作節點後，資源伺服器將請求資源的VI任務發送到第一目標工作節點上，由該第一目標工作節點執行該VI任務。
[0035]本實施例提供的資源調度方法，資源伺服器在執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型，其中混合任務包括任務和VI任務，在判斷出物理任務為VI任務時，將資源請求消息發送給位於第一工作節點上的VI伺服器，接收VI伺服器反饋的第一指示消息，根據第一指示消息獲取第一目標工作節點，將VI任務發送到第一目標工作節點上綁定資源並執行。本實施例中資源伺服器在執行謝任務同時，也可以為為VI任務分配資源，從而實現了對混合任務統一管理的目的，提高了執行混合任務時資源的整體利用率。
[0036]圖2為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖，如圖2所示，該方法包括:
[0037]200、資源伺服器執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型。
[0038]201、如果任務類型為VI任務，資源伺服器將資源請求消息發送給位於第一工作節點上的VI伺服器。
[0039]步驟201?步驟202參見上述實施例的步驟101?步驟102，此處不再贅述。
[0040]202、資源伺服器接收VI伺服器發送VI任務所需的目標資源量。
[0041〕 本實施例中，VI伺服器在接收到資源請求消息後，可以向資源伺服器發送該VI任務所需的目標資源量。可選地，VI伺服器可以向資源伺服器發送一個通知消息，通過該通知消息告知資源伺服器VI任務所需的目標資源量。
[0042]203、資源伺服器獲取每個工作節點上的資源情況，其中，資源情況包括每個工作節點的資源總量以及可用資源量。
[0043]實際中，資源伺服器負責對系統中所有工作節點上的任務分配資源，並且對系統中正在執行的每個任務的狀態以及所有工作節點的資源總量和工作節點上使用的資源量等信息進行監控。在獲取到VI任務所需的目標資源量之後，為了給VI任務分配相應的資源，資源伺服器可以查詢獲取每個工作節點上的資源情況，其中該資源情況包括每個工作節點的資源總量以及可用資源量。
[0044]204、資源伺服器將資源情況發送給VI伺服器，以使VI伺服器在所有工作節點中選取第一目標工作節點，將第一目標工作節點攜帶在第一指示消息中發送給資源伺服器。
[0045]具體地，資源伺服器將資源情況發送給VI伺服器，以使VI伺服器對目標資源量進行加鎖，並且根據負載均衡原理以及每個工作節點的可用資源量，在所有工作節點中選取第一目標工作節點，將第一目標工作節點攜帶在第一指示消息中發送給資源伺服器。
[0046]205、資源伺服器接收VI伺服器反饋的第一指示消息，並根據第一指示消息獲取第一目標工作節點。
[0047]在接收到第一指示消息後，資源伺服器可以從第一指示消息中得知第一目標工作節點的標識，例如地址，從而獲取到穩伺服器為VI任務選取到的第一目標工作節點。
[0048]206、資源伺服器將VI任務發送到第一目標工作節點上綁定資源並執行。
[0049]由於VI伺服器在獲取到VI任務所請求的目標資源量之後，對目標資源量進行加鎖，因此，在資源伺服器將VI任務發送到第一目標工作節點上執行之前，需要資源伺服器指示VI伺服器對目標資源量進行解鎖，從而能夠將VI任務發送到第一目標工作節點上之後，第一目標工作節點為穩任務分配相應的目標資源量。
[0050]本實施例中，資源伺服器在執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型，其中混合任務包括謝任務和VI任務，在物理任務為VI任務時，將資源請求消息發送給位於第一工作節點上的VI伺服器，接收VI伺服器反饋的第一指示消息，根據所述第一指示消息獲取第一目標工作節點，將VI任務發送到第一目標工作節點上綁定資源並執行。本實施例中資源伺服器在執行任務同時，也可以為VI任務分配資源，從而實現了對混合任務統一管理的目的，提高了執行混合任務時資源的整體利用率。
[0051]圖3為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖。在上述實施例的基礎之上，在資源伺服器將VI任務發送到第一目標工作節點上綁定資源並執行之後，如圖3所示，該方法還包括:
[0052]301、資源伺服器對執行VI任務的第一目標工作節點進行監控，獲取VI任務當前的資源佔用量。
[0053]302、資源伺服器判斷資源佔用量與目標資源量是否一致。
[0054]資源伺服器將VI任務當前的資源佔用量，與VI任務所需的目標資源量進行比較，判斷資源佔用量與目標資源量是否一致，如果判斷結果為不一致，則執行步驟303 ；如果判斷結果為一致，則返回執行步驟301，繼續對第一目標工作節點進行監控。
[0055]303、資源伺服器指示數字權限管理0冊對VI任務重新進行資源綁定。
[0056]在確定出資源佔用量與目標資源量不一致後，資源伺服器可以指示數字權限管理
此的陰郵社，簡稱01?)重新對VI任務進行資源綁定。一般重新綁定的資源量會變小，或者會變大，但是在第一目標工作節點的承受範圍內，0應則直接進行動態綁定，並執行步驟304以通知資源伺服器綁定的情況。如果需要重新綁定的資源量超出了第一目標工作節點的承受能力，則需要對VI任務進行遷移，則執行步驟305。
[0057]304、資源伺服器接收0咖發送的綁定通知消息。
[0058]其中，所述綁定通知消息是由0咖在重新綁定的資源量未超過第一目標工作節點的可用資源量時發送的。
[0059]305、資源伺服器接收由0咖經過VI伺服器轉發的請求遷移VI任務的遷移請求。
[0060]其中，所述遷移請求是由0咖在重新綁定的資源量超過第一目標工作節點生成的，所述遷移請求中攜帶VI任務遷移後所需的資源量大小。
[0061]當確定出在重新綁定的資源量超過第一目標工作節點時，說明第一目標工作節點的可用資源量不能滿足VI任務的需求，此時0應就能夠判斷出需要對VI任務進行遷移，0咖向VI伺服器發送遷移請求，在接收到遷移請求後，VI伺服器將該遷移請求轉發給資源伺服器，以請求將第一目標工作節點上的穩任務進行遷移。其中遷移請求是由0咖在重新綁定的資源量超過第一目標工作節點生成的，並且遷移請求中攜帶穩任務遷移後所需的資源量大小。
[0062]306、資源伺服器根據所需的資源量大小從除第一目標工作節點之外的其他工作節點中選取目的工作節點。
[0063]由於資源伺服器對所有的工作節點進行實時監控，在獲取到遷移請求後，資源伺服器能夠獲取到遷移後穩所需的資源量大小，這樣資源伺服器就根據該所需的資源量大小以及所監控到的工作節點的狀態，從除第一目標工作節點之外的其他工作節點中選取一個目的工作節點，其中該目的工作節點的可用資源量的大小要大於遷移後VI所需的資源量大小。
[0064]307、資源伺服器在目的工作節點同意遷移後將目的工作節點的標識發送給VI伺服器，以使VI伺服器將目的工作節點的標識通知第一目標工作節點將VI任務遷移至目的工作節點。
[0065]在獲取到目的工作節點後，資源伺服器可以向目的節點發送請求詢問是否允許遷移VI任務，在目的工作節點同意遷移後，資源伺服器將目的工作節點的標識發送給VI伺服器，這樣VI伺服器就可以將目的工作節點的標識發送給第一目標工作節點。在得知目的工作節點的標識後，第一目標工作節點根據該標識將VI任務遷移至該目的工作節點上。
[0066]308、資源伺服器接收目的工作節點在遷移完VI任務發送的通知消息。
[0067]在第一目標工作節點將VI完全遷移至目的工作節點後，資源伺服器將接收到目的工作節點發送的通知消息。
[0068]309、資源伺服器根據通知消息釋放第一目標工作節點的資源。
[0069]本實施例中，在第一目標工作節點執行VI任務時，資源伺服器可以對其進行監控，根據VI任務實際的資源消耗量，動態的調整綁定的資源數量。在資源佔用量少於所需資源量時，能夠實時地根據第一目標工作節點所剩的可用資源滿足VI所需資源量時，重新對VI任務進行資源綁定，並且在第一目標工作節點所剩的可用資源較少不滿足需求時，將VI任務進行遷移，以保證VI任務的順利執行。
[0070]圖4為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖。當有至少2個VI任務請求資源時，如圖4所示，該方法包括:
[0071]401、資源伺服器接收VI伺服器發送的至少2個VI任務所需的全局資源量。
[0072]其中，所述全局資源量由VI伺服器對每個VI任務所需的資源量進行合併後得到的。
[0073]402、資源伺服器獲取每個工作節點上的資源情況，所述資源情況包括:每個工作節點的資源總量以及可用資源量。
[0074]步驟402參見上述實施例中步驟203，此處不再贅述。
[0075]403、資源伺服器將資源情況發送給VI伺服器，以使VI伺服器根據負載均衡原理以及每個工作節點的可用資源量，在所有工作節點選取第二目標工作節點，將第二目標工作節點反饋給資源伺服器。
[0076]404、資源伺服器將所述至少2個VI任務發送到第二目標工作節點上綁定資源並執行。
[0077]當有多個VI任務請求的時候，通過串行方式處理VI任務，不僅佔用的串口較多，而且對請求的響應等待時間變長，本實施例中，將請求資源的所有VI任務所需的資源量進行合併得到全局資源量，只需一次向資源伺服器請求全局資源量，就能為所有穩任務分配相應的所需資源，提高了效率。
[0078]圖5為本發明另一實施例提供的混合任務下的動態資源調度方法的流程示意圖。如圖5所示，該方法包括:
[0079]500、資源伺服器執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型。
[0080]步驟500可參見上述實施例中步驟100的相關記載，此處不再贅述。
[0081]501、如果判斷出任務類型為謝任務，資源伺服器將資源請求消息發送給位於第二工作節點上的謝伺服器。
[0082]當確定出物理任務的任務類型為服任務時，資源伺服器將接收到的資源請求消息發送給謝伺服器，其中該冊伺服器處於某一工作節點上，本實施例中將謝伺服器所在的工作節點稱為第二工作節點。具體地，資源伺服器將資源請求消息首先發送給第二工作節點，由第二工作節點轉發給伺服器。
[0083]502、資源伺服器接收謝伺服器反饋的第二指示消息。
[0084]在接收到資源請求消息後，II？伺服器可以向資源伺服器反饋一個第二指示消息。可選地，第二指示消息中攜帶有第三目標工作節點的標識，例如第三目標工作節點的地址。資源伺服器根據第二指示消息獲取到第三目標工作節點，其中，該第三目標工作節點為執行謝任務的工作節點。
[0085]503、資源伺服器根據第二指示消息獲取相應的第三目標工作節點。
[0086]504、資源伺服器將II？任務發送到第三目標工作節點上綁定資源並執行。
[0087]在獲取第三目標工作節點後，資源伺服器將請求資源的謝任務發送到第三目標工作節點上，由該第三目標工作節點執行該謝任務。其中在執行謝任務時，第三目標工作節點按照^1111框架中的資源調度策略對任務進行管理。
[0088]本實施例中，在物理任務為II？任務時，將資源請求消息發送給位於第二工作節點上的伺服器，接收伺服器反饋的第二指示消息，根據第二指示消息獲取第三目標工作節點，將謝任務發送到第三目標工作節點上執行。本實施例中資源伺服器不僅實現了對VI任務的統一管理，還可以統一為II？任務分配資源，從而提高了混合任務執行時資源的整體利用率。
[0089]圖6為本發明一實施例提供的混合任務下的動態資源調度系統的結構示意圖。如圖6所示，該系統包括:資源伺服器1、VI伺服器2和第一目標工作節點3。
[0090]其中，資源伺服器1，用於執行混合任務時接收物理任務發送的資源請求消息，並根據所述資源請求消息判斷所述物理任務的任務類型，其中混合任務包括謝任務和VI任務，如果判斷出任務類型為VI任務，將資源請求消息發送給位於第一工作節點上的VI伺服器2，接收VI伺服器2反饋的第一指示消息，根據第一指示消息獲取第一目標工作節點3，將VI任務發送到第一目標工作節點3上綁定資源並執行。
[0091]VI伺服器2，用於從資源伺服器1處接收資源請求消息，並向資源伺服器1發送第一指示消息，以指示資源伺服器1根據第一指示消息獲取第一目標工作節點3 ；
[0092]第一目標工作節點3，用於接收VI任務，並對VI任務進行資源綁定及執行。
[0093]本實施例提供的混合任務下的動態資源調度系統，資源伺服器在執行混合任務時接收物理任務發送的資源請求消息，並根據資源請求消息判斷物理任務的任務類型，其中混合任務包括謝和VI任務，在物理任務為VI任務時，將資源請求消息發送給位於第一工作節點上的VI伺服器，接收VI伺服器反饋的第一指示消息，根據所述第一指示消息獲取第一目標工作節點，將VI任務發送到第一目標工作節點上綁定資源並執行，本實施例中資源伺服器在執行謝任務的同時，也可以為VI任務分配資源，從而實現了對混合任務統一管理的目的，提高了執行混合任務時資源的整體利用率。
[0094]圖7為本發明另一實施例提供的混合任務下的動態資源調度系統的結構示意圖。如圖7所示，除了包括上述實施例中的資源伺服器1、VI伺服器2、第一目標工作節點3之夕卜，還包括0應4。
[0095]其中，資源伺服器1的一種可選的結構方式包括:第一接收模塊11、判斷模塊12、第一發送模塊13和確定模塊14。
[0096]VI伺服器2的一種可選的結構方式包括:第二接收模塊21和第二發送模塊22。
[0097]其中，第一接收模塊11接收物理任務發送的資源請求消息，與第一接收模塊11連接的判斷模塊12對物理任務的任務類型進行判斷，當判斷出任務類型為VI任務時，第一發送模塊13將資源請求消息發送給VI伺服器中的第二接收模塊21。第二接收模塊21接收到資源請求消息後，通過第二發送模塊22在第一接收模塊11接收第二發送模塊22反饋的第一指示消息之前，接收第二發送模塊22發送VI任務所需的目標資源量。
[0098]進一步地，資源伺服器1還包括:獲取模塊15。
[0099]其中，獲取模塊15用於在第一接收模塊11目標資源量之後，獲取每個工作節點上的資源情況，其中資源情況包括每個工作節點的資源總量以及可用資源量。第一發送模塊13將資源情況發送給第二接收模塊21。
[0100]進一步地，VI伺服器還包括:選取模塊23、加鎖模塊24和解鎖模塊25。
[0101]其中，選取模塊23，用於在第二接收模塊21接收到資源情況後，從所有工作節點中選取第一目標工作節點3，將第一目標工作節點3攜帶在第一指示消息中發送給第一接收模塊11。具體地，獲取模塊15將資源情況通過第一發送模塊13發送給第二接收模塊21後，加鎖模塊24對目標資源量進行加鎖，並且選取模塊23根據負載均衡原理以及每個工作節點的可用資源量，在所有工作節點中選取第一目標工作節點3，並將第一目標工作節點3攜帶在第一指示消息中發送給第一接收模塊11。可選地，第一目標工作節點3的標識攜帶在第一指示消息中，其中標識可以為第一目標工作節點3的地址。
[0102]本實施例中，由於加鎖模塊24對穩任務所請求的目標資源量進行了枷鎖，在將VI任務發送到第一目標工作節點3上執行之前，通過第一發送模塊13指示解鎖模塊25對加鎖後的目標資源量進行解鎖。
[0103]進一步地，資源伺服器還包括:監控模塊16和指示模塊17。
[0104]在資源伺服器1通過第一發送模塊13將VI任務發送到第一目標工作節點3上執行之後，監控模塊16對執行VI任務的第一目標工作節點3進行監控，獲取VI任務當前的資源佔用量，判斷模塊12還可以判斷所述資源佔用量與所述目標資源量是否一致。如果判斷結果為不一致，指示模塊17指示0應4對VI任務重新進行資源綁定。
[0105]第一接收模塊11接收0應4發送的綁定通知消息，所述綁定通知消息是由所述0應4在重新綁定的資源量未超過第一目標工作節點3的所述可用資源量時發送的。
[0106]進一步地，第一接收模塊11接收由0咖4經過VI伺服器2轉發的請求遷移VI任務的遷移請求，其中，所述遷移請求是由0應4在重新綁定的資源量超過第一目標工作節點3生成的，所述遷移請求中攜帶VI任務遷移後所需的資源量大小。
[0107]在接收0咖4發送的請求遷移VI任務的遷移請求之後，確定模塊14根據所需的資源量大小從除第一目標工作節點3之外的其他工作節點中選取目的工作節點5。
[0108]在目的工作節點5同意遷移後將目的工作節點5的標識發送給VI伺服器2中的第二接收模塊21，以使第二發送模塊22將目的工作節點5的標識通知第一目標工作節點3，使得第一目標工作節點3將VI任務遷移至目的工作節點5中。
[0109]在完成VI任務的遷移後，第一接收模塊11接收目的工作節點5發送的通知消息，此時，通過指示模塊17指示釋放模塊18根據通知消息釋放第一目標工作節點3的資源。
[0110]本實施例中，在第一目標工作節點執行VI任務時，資源伺服器可以對其進行監控，根據VI任務實際的資源消耗量，動態的調整綁定的資源數量。在資源佔用量少於所需資源量時，能夠實時地根據第一目標工作節點所剩的可用資源滿足VI所需資源量時，重新對VI任務進行資源綁定，並且在第一目標工作節點所剩的可用資源較少不滿足需求時，將VI任務進行遷移，以保證VI任務的順利執行。
[0111]進一步地，在資源調度系統還包括:第二目標工作節點6。
[0112]當有至少2個VI任務請求資源時，資源伺服器1中第一接收模塊11接收VI伺服器2中第二發送模塊22發送的所述至少2個VI任務所需的全局資源量，其中所述全局資源量由所述VI伺服器2對每個VI任務所需的資源量進行合併後得到的。
[0113]在接收到全局資源量之後，獲取模塊15獲取每個工作節點上的資源情況，其中資源情況包括每個工作節點的資源總量以及可用資源量，通過第一發送模塊13將資源情況發送給第二接收模塊21，以使選取模塊23根據負載均衡原理以及每個工作節點的可用資源量，在所有工作節點選取第二目標工作節點6，通過第二發送模塊22將第二目標工作節點6反饋給資源伺服器1中的第一接收模塊11，然後資源伺服器1通過第一發送模塊13將所述至少2個VI任務發送到第二目標工作節點6上綁定資源並執行。
[0114]當有多個VI任務請求的時候，通過串行方式處理VI任務，不僅佔用的串口較多，而且對請求的響應等待時間變長，本實施例中，將請求資源的所有VI任務所需的資源量進行合併得到全局資源量，只需一次向資源伺服器請求全局資源量，就能為所有穩任務分配相應的所需資源，提高了效率。
[0115]進一步地，在資源調度系統還包括:謝伺服器7和第三目標工作節點8。
[0116]如果在判斷模塊12判斷出物理任務的任務類型為映射歸屬II？任務，第一發送模塊13將資源請求消息發送給位於第二工作節點上的II？伺服器7。
[0117]第一接收模塊11接收II？伺服器7反饋的第二指示消息，確定模塊14根據第二指示消息獲取相應的第三目標工作節點8，通過第一發送模塊13將II？任務發送到第三目標工作節點8上綁定資源並執行。
[0118]本實施例中，在物理任務為II？任務時，將資源請求消息發送給位於第二工作節點上的伺服器，接收伺服器反饋的第二指示消息，根據第二指示消息獲取第三目標工作節點，將謝任務發送到第三目標工作節點上執行。本實施例中資源伺服器不僅實現了對VI任務的統一管理，還可以統一為II？任務分配工作節點，從而提高了混合任務執行時資源的整體利用率。
[0119]最後應說明的是:以上各實施例僅用以說明本發明的技術方案，而非對其限制；儘管參照前述各實施例對本發明進行了詳細的說明，本領域的普通技術人員應當理解:其依然可以對前述各實施例所記載的技術方案進行修改，或者對其中部分或者全部技術特徵進行等同替換；而這些修改或者替換，並不使相應技術方案的本質脫離本發明各實施例技術方案的範圍。
【權利要求】
1.一種混合任務下的動態資源調度方法，其特徵在於，包括: 資源伺服器在執行混合任務時接收物理任務發送的資源請求消息，並根據所述資源請求消息判斷所述物理任務的任務類型；所述混合任務包括映射歸屬MR任務和虛擬機VM任務; 如果判斷出所述任務類型為所述VM任務，所述資源伺服器將所述資源請求消息發送給位於第一工作節點上的VM伺服器； 所述資源伺服器接收所述VM伺服器反饋的第一指示消息； 所述資源伺服器根據所述第一指示消息獲取第一目標工作節點； 所述資源伺服器將所述VM任務發送到所述第一目標工作節點上綁定資源並執行。
2.根據權利要求1所述的混合任務下的動態資源調度方法，其特徵在於，所述資源伺服器接收所述VM伺服器反饋的第一指示消息之前，包括: 所述資源伺服器接收所述VM伺服器發送所述VM任務所需的目標資源量； 所述資源伺服器獲取每個工作節點上的資源情況，其中所述資源情況包括:每個工作節點的資源總量以及可用資源量； 所述資源伺服器將所述資源情況發送給所述VM伺服器，以使所述VM伺服器在所有工作節點中選取所述第一目標工作節點，將所述第一目標工作節點攜帶在所述第一指示消息中發送給所述資源伺服器。
3.根據權利要求2所述的混合任務下的動態資源調度方法，其特徵在於，所述資源伺服器將所述資源情況發送給所述VM伺服器，以使所述VM伺服器在所有工作節點中選取所述第一目標工作節點，將所述第一目標工作節點攜帶在所述第一指示消息中發送給所述資源伺服器，包括: 所述資源伺服器將所述資源情況發送給所述VM伺服器，以使所述VM伺服器對所述目標資源量進行加鎖，並且根據負載均衡原理以及每個工作節點的所述可用資源量，在所有工作節點中選取所述第一目標工作節點，將所述第一目標工作節點攜帶在所述第一指示消息中發送給所述資源伺服器。
4.根據權利要求3所述的混合任務下的動態資源調度方法，其特徵在於，所述資源伺服器將所述VM任務發送到所述第一目標工作節點上執行之前，還包括: 所述資源伺服器指示所述VM伺服器對加鎖後的目標資源量進行解鎖。
5.根據權利要求1-4任一項所述的混合任務下的動態資源調度方法，其特徵在於，所述資源伺服器將所述VM任務發送到所述第一目標工作節點上綁定資源並執行之後，還包括: 所述資源伺服器對執行所述VM任務的所述第一目標工作節點進行監控，獲取所述VM任務當前的資源佔用量； 所述資源伺服器判斷所述資源佔用量與所述目標資源量是否一致； 如果判斷結果為不一致，所述資源伺服器指示數字權限管理DRM對所述VM任務重新進行資源綁定； 所述資源伺服器接收所述DRM發送的綁定通知消息，所述綁定通知消息是由所述DRM在重新綁定的資源量未超過所述第一目標工作節點的所述可用資源量時發送的。
6.根據權利要求5所述的混合任務下的動態資源調度方法，其特徵在於，還包括: 所述資源伺服器接收由所述DRM經過所述VM伺服器轉發的請求遷移所述VM任務的遷移請求，其中，所述遷移請求是由所述DRM在重新綁定的資源量超過所述第一目標工作節點生成的，所述遷移請求中攜帶所述VM任務遷移後所需的資源量大小。
7.根據權利要求6所述的混合任務下的動態資源調度方法，其特徵在於，所述資源伺服器接收所述DRM發送的請求遷移所述VM任務的遷移請求之後，還包括: 所述資源伺服器根據所述所需的資源量大小從除所述第一目標工作節點之外的其他工作節點中選取目的工作節點； 所述資源伺服器在所述目的工作節點同意遷移後將所述目的工作節點的標識發送給所述VM伺服器，以使所述VM伺服器將所述目的工作節點的標識通知所述第一目標工作節點將所述VM任務遷移至所述目的工作節點； 所述資源伺服器接收所述目的節點在所述VM任務遷移完成後發送的通知消息； 所述資源伺服器根據所述通知消息釋放所述第一目標工作節點的資源。
8.根據權利要求2所述的混合任務下的動態資源調度方法，其特徵在於，還包括: 當有至少2個VM任務請求資源時，所述資源伺服器接收所述VM伺服器發送的所述至少2個VM任務所需的全局資源量，所述全局資源量由所述VM伺服器對每個VM任務所需的資源量進行合併後得到的； 所述資源伺服器獲取每個工作節點上的資源情況，所述資源情況包括:每個工作節點的資源總量以及可用資源量； 所述資源伺服器將所述資源情況發送給所述VM伺服器，以使所述VM伺服器根據負載均衡原理以及每個工作節點的所述可用資源量，在所有工作節點選取第二目標工作節點，將所述第二目標工作節點反饋給所述資源伺服器； 所述資源伺服器將所述至少2個VM任務發送到所述第二目標工作節點上綁定資源並執行。
9.根據權利要求1所述的混合任務下的動態資源調度方法，其特徵在於，還包括: 如果判斷出所述任務類型為所述MR任務，所述資源伺服器將所述資源請求消息發送給位於第二工作節點上的MR伺服器； 所述資源伺服器接收所述MR伺服器反饋的第二指示消息； 所述資源伺服器根據所述第二指示消息獲取相應的第三目標工作節點； 所述資源伺服器將所述MR任務發送到所述第三目標工作節點上綁定資源並執行。
10.一種混合任務下的動態資源調度系統，其特徵在於，包括:資源伺服器、虛擬機VM伺服器和第一目標工作節點； 所述資源伺服器，用於在執行混合任務時接收物理任務發送的資源請求消息，並根據所述資源請求消息判斷所述物理任務的任務類型，如果所述任務類型為虛擬機VM任務，將所述資源請求消息發送給位於第一工作節點上的VM伺服器，接收所述VM伺服器反饋的第一指示消息，根據所述第一指示消息獲取第一目標工作節點，所述VM任務發送到所述第一目標工作節點上綁定資源並執行；其中所述混合任務包括MR任務和VM任務； 所述VM伺服器，用於從所述資源伺服器處接收所述資源請求消息，並向所述資源伺服器發送第一指示消息，以指示所述資源伺服器根據所述第一指示消息獲取第一目標工作節佔.所述第一目標工作節點，用於接收所述VM任務，並對所述VM任務進行資源綁定及執行。
【文檔編號】G06F9/50GK104317635SQ201410538954
【公開日】2015年1月28日 申請日期:2014年10月13日 優先權日:2014年10月13日
【發明者】胡春明, 王聿達, 楊任宇, 沃天宇, 蔣文博 申請人:北京航空航天大學