[發明專利]一種實時告警數據定制轉發方法

在審

• 申請號: 202111314208.7
• 申請日: 2021-11-08
• 公開（公告）號: CN114064270A
• 公開（公告）日: 2022-02-18
• 發明（設計）人: 牛雪朋;李永照;鐵永奎;孫振;包芳;陳哲;沈志廣;李宏川;張海庭;郭利軍;胡斌
• 申請（專利權）人: 許繼集團有限公司;許昌許繼軟件技術有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54
• 代理公司: 北京中創云知識產權代理事務所(普通合伙) 11837
• 代理人: 任必為

1.一種實時告警數據定制轉發方法，其特征在于，包括如下步驟：

1)變電站告警數據的生產者向消息中心發送包含告警數據的生產消息；

2)從消息中心接收消息中心發出的告警消息，根據訂閱方式處理所述告警消息；

3)向告警接收客戶端發送處理后的告警消息。

2.如權利要求1所述的一種實時告警定制轉發方法，其特征在于，步驟1)中消息中心包括Kafka消息總線，變電站告警數據的生產者向Kafka消息總線發送包含告警數據的生產消息；Kafka消息總線的消費者包括實時告警數據定制轉發模塊；根據Kafka消息總線的生產者與消費者協議定義Kafka消息總線的告警主題，實時告警數據定制轉發模塊向Kafka消息總線訂閱所述告警主題。

3.如權利要求2所述的一種實時告警定制轉發方法，其特征在于，步驟2)從消息中心接收消息中心發出的告警消息，根據訂閱方式處理所述告警消息具體包括步驟：

步驟2.1)實時告警數據定制轉發模塊中定義一個消息接收棧，用于從Kafka消息總線中消費所述告警消息并存放到消息接收棧；

步驟2.2)將消息接收棧中的告警消息發送到線程池中的線程；

步驟2.3)告警接收客戶端向實時告警數據定制轉發模塊訂閱告警消息，訂閱時包含告警接收客戶端的訂閱方式；

步驟2.4)線程根據所述訂閱方式處理告警消息。

4.如權利要求1所述的一種實時告警定制轉發方法，其特征在于，步驟3)向告警接收客戶端發送處理后的告警消息具體包括步驟：當實時告警數據定制轉發模塊發現滿足告警接收客戶端要求的告警消息時向告警接收客戶端發送處理后的告警消息。

5.如權利要求3所述的一種實時告警定制轉發方法，其特征在于，步驟2.1)中消息接收棧內每條告警消息有唯一的告警消息ID，告警消息ID從1開始遞增，告警消息ID最大條目為可存入的告警消息條目，告警消息ID達到最大條目則重新從1開始遞增。

6.如權利要求5所述的一種實時告警定制轉發方法，其特征在于，步驟2.2)將消息接收棧中的消息發送到線程池中的線程具體包括：

告警消息出棧時，首先判斷線程池中當前是否存在未處理任務的線程，如果存在則直接將告警消息發送給未處理任務的線程，如果不存在未處理任務的線程，則判斷當前線程個數是否小于2倍的CPU核數，小于時創建新線程處理告警消息，不小于時對告警消息ID進行取模操作，將告警消息平均分配給所有的線程。

7.如權利要求3所述的一種實時告警定制轉發方法，其特征在于，所述告警接收客戶端至少包括告警客戶端、圖形插件和錄波召喚之一。

8.如權利要求7所述的一種實時告警定制轉發方法，其特征在于，步驟2)所述訂閱方式至少包括：全部訂閱、告警類型訂閱、數據參引訂閱、數據ID訂閱以及其他特殊訂閱方式之一。

9.如權利要求8所述的一種實時告警定制轉發方法，其特征在于，步驟2.4)線程根據所述訂閱方式處理告警消息具體包括：

全部訂閱時：對告警消息按照固有的方式處理后即可向告警接收客戶端發送處理后的告警消息；

告警類型訂閱時：對告警消息按照固有的方式處理后，根據訂閱告警消息的告警接收客戶端指定的類型進行告警過濾，發送指定類型的告警消息；

數據參引訂閱時：對告警消息按照固有的方式處理后，根據訂閱告警消息的告警接收客戶端指定的數據參引進行告警過濾，發送指定數據參引的告警消息；

數據ID訂閱時：對告警消息按照固有的方式處理后，根據訂閱告警消息的告警接收客戶端指定的數據ID進行告警過濾，發送指定數據ID的告警消息。

其他特殊訂閱方式時：根據預先設置的規則自定義告警消息處理規則，對告警消息處理發送處理后的告警消息。

10.一種計算機設備，包括存儲器和處理器，所述存儲器存儲有計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求1-9任一項所述方法的步驟。