[發(fā)明專利]分布式系統(tǒng)的調(diào)度方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 200810239118.4
• 申請日: 2008-12-09
• 公開（公告）號: CN101753608A
• 公開（公告）日: 2010-06-23
• 發(fā)明（設(shè)計）人: 錢嶺;郭磊濤;趙鵬;徐萌;羅治國
• 申請（專利權(quán)）人: 中國移動通信集團公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京中譽威圣知識產(chǎn)權(quán)代理有限公司 11279
• 代理人: 王正茂;張靜軒

1.一種分布式系統(tǒng)的調(diào)度方法，其特征在于，包括：

步驟A：數(shù)據(jù)調(diào)度器接收調(diào)度請求，所述調(diào)度請求包括對數(shù)據(jù)的 讀取操作；所述數(shù)據(jù)保存在分布式系統(tǒng)中的至少一個提供數(shù)據(jù)服務(wù)的 實體上；

步驟B：所述數(shù)據(jù)調(diào)度器確定所述調(diào)度請求對應(yīng)的各數(shù)據(jù)服務(wù)的 狀態(tài)，并在所述各數(shù)據(jù)服務(wù)為空閑或讀取狀態(tài)時，發(fā)送同意對各數(shù)據(jù) 服務(wù)進行讀取操作的調(diào)度響應(yīng)；所述各數(shù)據(jù)服務(wù)為至少一個相同的數(shù) 據(jù)服務(wù)；

在所述步驟A之前，還包括：所述數(shù)據(jù)調(diào)度器確定并保存各數(shù)據(jù) 服務(wù)的狀態(tài)信息，所述狀態(tài)信息包括：讀取、寫入、空閑；

所述數(shù)據(jù)調(diào)度器確定并保存各數(shù)據(jù)服務(wù)的狀態(tài)信息的操作具體 包括：

所述數(shù)據(jù)調(diào)度器由設(shè)置的數(shù)據(jù)鎖確定并保存各數(shù)據(jù)服務(wù)的狀態(tài)；

所述數(shù)據(jù)鎖用于標(biāo)識所述各數(shù)據(jù)服務(wù)的狀態(tài)信息，且所述各相同 數(shù)據(jù)服務(wù)的數(shù)據(jù)鎖信息相同。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述數(shù)據(jù)調(diào)度器包 括文件調(diào)度器，所述步驟B還包括：

若所述狀態(tài)為寫入狀態(tài)，則發(fā)送不同意對各數(shù)據(jù)服務(wù)進行操作的 調(diào)度響應(yīng)，或者發(fā)送同意對正在執(zhí)行寫入操作的數(shù)據(jù)服務(wù)進行讀取操 作的調(diào)度響應(yīng)；

若所述狀態(tài)為寫入狀態(tài)且所述調(diào)度請求中攜帶優(yōu)先信息，則發(fā)送 同意對數(shù)據(jù)服務(wù)進行讀取操作的調(diào)度響應(yīng)，并修改所述各數(shù)據(jù)服務(wù)的 狀態(tài)信息為讀取；

若所述狀態(tài)為讀取狀態(tài)且所述調(diào)度請求為寫入操作，則正在執(zhí)行 讀取操作的數(shù)據(jù)服務(wù)執(zhí)行完畢后，發(fā)送同意對數(shù)據(jù)服務(wù)進行寫入操作 的調(diào)度響應(yīng)，并修改所述各數(shù)據(jù)服務(wù)的狀態(tài)信息為寫入；或者發(fā)送同 意對數(shù)據(jù)服務(wù)進行寫入操作的調(diào)度響應(yīng)，并將正在執(zhí)行讀取操作的數(shù) 據(jù)服務(wù)轉(zhuǎn)移至進行寫入操作的數(shù)據(jù)服務(wù)上，并修改所述各數(shù)據(jù)服務(wù)的 狀態(tài)信息為寫入；

若所述狀態(tài)為空閑狀態(tài)，發(fā)送同意對數(shù)據(jù)服務(wù)進行讀取或?qū)懭氩? 作的調(diào)度響應(yīng)，并修改所述各數(shù)據(jù)服務(wù)的狀態(tài)信息對應(yīng)為讀取或?qū)? 入。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述數(shù)據(jù)調(diào)度器包 括小表調(diào)度器和文件調(diào)度器，所述方法具體包括：

小表調(diào)度器接收包括對數(shù)據(jù)服務(wù)進行讀取操作的調(diào)度請求后，確 定所述調(diào)度請求對應(yīng)的各數(shù)據(jù)服務(wù)所在的小表，若所述小表調(diào)度器保 存有所述小表的數(shù)據(jù)服務(wù)的狀態(tài)信息，則根據(jù)所述狀態(tài)信息發(fā)送對應(yīng) 小表的調(diào)度響應(yīng)；否則，

文件調(diào)度器接收包括對數(shù)據(jù)服務(wù)進行讀取操作的調(diào)度請求，及所 述小表調(diào)度器發(fā)送的所述調(diào)度請求對應(yīng)的各數(shù)據(jù)服務(wù)所在的小表后， 確定所述調(diào)度請求對應(yīng)的各數(shù)據(jù)服務(wù)的狀態(tài)信息，根據(jù)所述狀態(tài)信息 發(fā)送調(diào)度響應(yīng)，具體包括：

若所述狀態(tài)為空閑時，發(fā)送同意對各數(shù)據(jù)服務(wù)進行讀取或?qū)懭氩? 作的調(diào)度響應(yīng)，并修改所述各數(shù)據(jù)服務(wù)的狀態(tài)信息為讀取或?qū)懭耄?

若所述狀態(tài)為寫入狀態(tài)，則發(fā)送不同意對各數(shù)據(jù)服務(wù)進行操作的 調(diào)度響應(yīng)，或者發(fā)送同意對正在執(zhí)行寫操作的數(shù)據(jù)服務(wù)進行讀取操作 的調(diào)度響應(yīng)；

若所述狀態(tài)為寫入狀態(tài)且所述調(diào)度請求中攜帶優(yōu)先信息，則發(fā)送 同意對數(shù)據(jù)服務(wù)進行讀取操作的調(diào)度響應(yīng)，并修改所述各數(shù)據(jù)服務(wù)的 狀態(tài)信息為讀取；

若所述狀態(tài)為讀取狀態(tài)且所述調(diào)度請求為寫入操作，則正在執(zhí)行 讀取操作的數(shù)據(jù)服務(wù)執(zhí)行完畢后，發(fā)送同意對數(shù)據(jù)服務(wù)進行寫入操作 的調(diào)度響應(yīng)，并修改所述各數(shù)據(jù)服務(wù)的狀態(tài)信息為寫入；或者發(fā)送同 意對數(shù)據(jù)服務(wù)進行寫入操作的調(diào)度響應(yīng)，并將正在執(zhí)行讀取操作的數(shù) 據(jù)服務(wù)轉(zhuǎn)移至進行寫入操作的數(shù)據(jù)服務(wù)上，并修改所述各數(shù)據(jù)服務(wù)的 狀態(tài)信息為寫入；

若所述狀態(tài)為讀取狀態(tài)且所述調(diào)度請求為讀取操作，發(fā)送同意對 數(shù)據(jù)服務(wù)進行讀取操作的調(diào)度響應(yīng)；

所述小表調(diào)度器接收所述調(diào)度響應(yīng)后，確定各數(shù)據(jù)服務(wù)所在的小 表的狀態(tài)信息，發(fā)送對應(yīng)小表的調(diào)度響應(yīng)，具體包括：將提供數(shù)據(jù)服 務(wù)所在的小表的狀態(tài)信息修改為與提供數(shù)據(jù)服務(wù)的狀態(tài)信息一致。

4.根據(jù)權(quán)利要求1-3中任一項所述的方法，其特征在于，在所述 步驟A之前，還包括：

任務(wù)調(diào)度器接收任務(wù)后，確定所述任務(wù)的操作類型和所述任務(wù)對 應(yīng)的數(shù)據(jù)服務(wù)，向所述數(shù)據(jù)調(diào)度器發(fā)送所述調(diào)度請求；

其中，所述操作類型包括讀取、寫入操作。