[發(fā)明專利]購供售一體化電能量采集與監(jiān)控系統(tǒng)中基于分布式緩存的采集任務(wù)調(diào)度方法

無效

• 申請?zhí)枺?/td>: 201110389356.5
• 申請日: 2011-11-30
• 公開（公告）號: CN102508709A
• 公開（公告）日: 2012-06-20
• 發(fā)明（設(shè)計）人: 嚴小文;王軍;唐如意;陶曉峰;高魯鑫;徐俊杰;張潔;張穎琦;楊文生;許浩
• 申請（專利權(quán)）人: 國電南瑞科技股份有限公司;河北省電力公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 石家莊新世紀專利商標事務(wù)所有限公司 13100
• 代理人: 陳建民

1.一種購供售一體化電能量采集與監(jiān)控系統(tǒng)中基于分布式緩存的采集任務(wù)調(diào)度方法，其特征在于所述方法由分布式緩存、任務(wù)管理器、前置采集集群及消息總線組成的采集任務(wù)調(diào)度系統(tǒng)完成；具體步驟如下：

（一）由所述任務(wù)管理器根據(jù)任務(wù)模板生成采集任務(wù)，將所述采集任務(wù)放到所述分布式緩存的任務(wù)數(shù)據(jù)區(qū)：

（1）由所述采集與監(jiān)控系統(tǒng)將數(shù)據(jù)庫中的任務(wù)模板加載到所述分布式緩存的任務(wù)數(shù)據(jù)區(qū)，由任務(wù)管理器從所述任務(wù)數(shù)據(jù)區(qū)獲取任務(wù)模板，并對任務(wù)模板的狀態(tài)進行判斷，過濾掉無效和停用的任務(wù)模板；

（2）對任務(wù)模板進行增加或/和刪除修改：

對任務(wù)模板根據(jù)需要進行增加或/和刪除修改，由任務(wù)管理器對作出修改的任務(wù)模板進行監(jiān)測，并通過消息總線獲取相應(yīng)的信息；

（3）創(chuàng)建任務(wù)線程池：

通過分析任務(wù)模板的內(nèi)容，根據(jù)任務(wù)需要執(zhí)行的時間和周期創(chuàng)建任務(wù)線程池，任務(wù)管理器根據(jù)任務(wù)時間要求屬性動態(tài)地生成采集任務(wù)，并將所生成的采集任務(wù)放入所述任務(wù)線程池中，由任務(wù)管理器統(tǒng)一管理；

所述采集任務(wù)由任務(wù)ID號和任務(wù)信息體組成，一個任務(wù)ID號對應(yīng)唯一一個任務(wù)信息體；

（二）由任務(wù)管理器通過權(quán)重輪詢算法對所述采集任務(wù)進行調(diào)度，將采集任務(wù)通過消息總線分發(fā)給各個采集結(jié)點，采集結(jié)點獲取采集任務(wù)后進行報文組裝、下發(fā)和接收解析操作，采集任務(wù)結(jié)束后更新采集任務(wù)狀態(tài)：

（1）所述權(quán)重輪詢算法根據(jù)每臺采集服務(wù)器的不同處理能力，給每臺采集服務(wù)器分配不同的權(quán)值，使其能夠接收相應(yīng)權(quán)值數(shù)的任務(wù)請求；

（2）分配好的采集任務(wù)會標記上采集結(jié)點的任務(wù)ID號標識，把分配的任務(wù)發(fā)送到消息總線上，同時在分布式緩存的任務(wù)數(shù)據(jù)區(qū)中記錄下這個采集任務(wù)的狀態(tài)，包括已經(jīng)分配給哪臺采集結(jié)點執(zhí)行和采集任務(wù)的執(zhí)行狀態(tài)和時間；

（3）采集結(jié)點獲取任務(wù)后，根據(jù)任務(wù)信息體的內(nèi)容進行報文的組裝、下發(fā)及接收解析操作，然后根據(jù)采集任務(wù)執(zhí)行結(jié)果通過消息總線返回到分布式緩存的任務(wù)數(shù)據(jù)區(qū)；所述采集任務(wù)執(zhí)行結(jié)果包括成功、失敗和超時；

（三）任務(wù)管理器對執(zhí)行完成的采集任務(wù)進行相應(yīng)的處理：

任務(wù)管理器定時地對所述任務(wù)數(shù)據(jù)區(qū)進行監(jiān)測，對執(zhí)行成功的任務(wù)進行清理，對執(zhí)行失敗和超時的任務(wù)進行重新進行分配；當前置采集集群里的某個采集結(jié)點突然退出時，任務(wù)管理器監(jiān)測到采集結(jié)點工況變化信息，對這個采集結(jié)點上正在執(zhí)行的采集任務(wù)和未執(zhí)行的采集任務(wù)進行回收，將這些采集任務(wù)重新分配到其他在線的采集結(jié)點上。

2.根據(jù)權(quán)利要求1所述的購供售一體化電能量采集與監(jiān)控系統(tǒng)中基于分布式緩存的采集任務(wù)調(diào)度方法，其特征在于所述任務(wù)信息體包括采集任務(wù)所要采集或者設(shè)置的數(shù)據(jù)項、采集的開始和結(jié)束時間、以及采集的通訊方式和通訊協(xié)議。

3.根據(jù)權(quán)利要求2所述的購供售一體化電能量采集與監(jiān)控系統(tǒng)中基于分布式緩存的采集任務(wù)調(diào)度方法，其特征在于所述任務(wù)數(shù)據(jù)區(qū)里的數(shù)據(jù)是以MAP方式存儲的。