[發明專利]電力調控系統分布式實時數據處理方法

有效

• 申請號: 201910060935.1
• 申請日: 2019-01-22
• 公開（公告）號: CN109871271B
• 公開（公告）日: 2020-10-30
• 發明（設計）人: 趙國建;梁君帥;林國春;王建功;劉吉鐸;徐敏
• 申請（專利權）人: 積成電子股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06Q50/06
• 代理公司: 濟南舜源專利事務所有限公司 37205
• 代理人: 苗峻;孟繁修

1.電力調控系統分布式實時數據處理方法，其特征在于，包括以下步驟：

步驟1、分布式協調處理服務模塊加載電網模型并以廠站為單位將電網模型拆分為多個數據處理單元，接收實時數據處理服務注冊并為其分配數據處理單元，實時檢測數據處理服務狀態及負載情況，根據負載均衡策略動態調整數據處理單元分配情況，實現數據處理單元、實時數據處理服務的統一管理、統一協調；所述的分布式協調處理服務模塊的處理過程分以下四部分：

(1)分布式協調處理服務模塊初始運行時，根據副本數量配置信息將一個數據處理單元并行分配到多個實時數據處理服務，并選擇一個實時數據處理服務作為此數據處理單元的主處理節點，其他實時數據處理服務作為輔處理節點，僅主處理節點數據對外發布，實時數據處理服務個數大于等于副本數量；所述的副本數量是指每個數據處理單元由多個實時數據處理服務冗余處理其相關數據，處理該數據處理單元數據的一個實時數據處理服務稱為一個副本，同時處理同一個數據處理單元數據的實時數據處理服務個數稱為副本數量；

(2)當某一實時數據處理服務異常時，分布式協調處理服務模塊自動將其處理的數據處理單元分配到其他實時數據處理服務，分布式協調處理服務模塊在對數據處理單元重新分配時根據各實時數據處理服務的負載情況進行負載均衡計算，當故障實時數據處理服務上的數據處理單元無法全部重新分配時，分布式協調處理服務模塊自動發送告警事件請求運維人員干預；

(3)當某一數據處理單元的主處理節點異常時，分布式協調處理服務模塊自動將某一輔處理節點升級為主處理節點；

(4)正常運行過程中，分布式協調處理服務模塊根據實時數據處理服務注冊變化情況，以及各實時數據處理服務的負載情況，動態調整數據處理單元分配，從負載較重的實時數據處理服務卸載數據處理單元，并重新分配到負載較輕的實時數據處理服務；

步驟2、實時數據處理服務接受分布式協調服務模塊的統一調度，其接收分布式協調服務模塊下發的數據處理單元，啟動數據處理線程并從消息總線訂閱相關廠站實時消息，并完成消息處理。

2.根據權利要求1所述的電力調控系統分布式實時數據處理方法，其特征在于，步驟1所述的分布式協調處理服務模塊實現數據處理單元、實時數據處理服務的統一管理、統一協調的詳細操作步驟如下：

S1.1、分布式協調處理服務模塊啟動后加載電網模型；

S1.2、以廠站為單位將電網模型拆分為多個數據處理單元；

S1.3、同步啟動數據處理單元管理線程、服務注冊管理線程，啟動數據處理單元管理線程后執行步驟S1.3.1，啟動服務注冊管理線程后執行步驟S1.3.2；

S1.3.1、數據處理單元管理線程循環檢測數據處理服務狀態及服務負載情況，并接收服務注冊管理線程發送的服務注冊通知，根據負載均衡策略調整數據處理單元分配情況，并通知相應的數據處理服務；

S1.3.2、服務注冊管理線程接收實時數據處理服務注冊請求，并通知數據處理單元管理線程有數據處理服務注冊；

S1.4、分布式協調處理服務模塊執行過程中，如果接收到外部退出命令，開始退出所有線程，待所有線程退出后分布式協調處理服務模塊退出。

3.根據權利要求2所述的電力調控系統分布式實時數據處理方法，其特征在于，步驟S1.3.1的具體操作步驟如下：

S1.3.1.1、數據處理單元管理線程循環檢測數據處理服務狀態及負載信息；

S1.3.1.2、判斷是否有數據處理服務退出請求，如果是、轉步驟S1.3.1.6，如果否、轉下一步；

S1.3.1.3、判斷是否有數據處理服務注冊請求，如果是、轉步驟S1.3.1.5，如果否、轉下一步；

S1.3.1.4、判斷各數據處理單元的冗余處理副本數量是否小于小于設定值，如果是、轉步驟1.3.1.7，如果否、轉下一步；

S1.3.1.5、根據負載均衡策略進行一次負載均衡計算，判斷是否需要進行負載均衡調整，如果是、轉下一步，如果否、轉步驟S1.3.1.1；

S1.3.1.6、數據處理單元管理線程回收相應的數據處理單元；

S1.3.1.7、數據處理單元管理線程尋找可用的數據處理服務，并分配數據處理單元；

S1.3.1.8、數據處理單元管理線程下發數據處理單元，轉步驟S1.3.1.1，同時消息通知循環等待接收任務的實時數據處理服務。