[發明專利]用于綜合監控系統的大規模實時數據更新發布系統及方法

在審

• 申請號: 201811054803.X
• 申請日: 2018-09-11
• 公開（公告）號: CN109271395A
• 公開（公告）日: 2019-01-25
• 發明（設計）人: 鄧敏;于洋;李上;趙明桂;劉濤;嚴崎;王正
• 申請（專利權）人: 南京軌道交通系統工程有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/25;G06F16/248
• 代理公司: 江蘇圣典律師事務所 32237
• 代理人: 賀翔

1.一種用于綜合監控系統的大規模實時數據更新發布系統，其特征在于，包括：

訂閱查詢模塊，用于接收訂閱、查詢請求信息，及輸出訂閱、查詢結果信息；

實時動態影響因素庫，用于存儲實時動態影響因素；

策略合成模塊，用于根據靜態更新發布策略及實時動態影響因素生成動態更新發布策略；

預處理模塊，根據動態更新發布策略對數據點數據進行預處理；

策略執行模塊，用于根據上述動態更新發布策略控制對預處理后的數據點數據的更新和發布；

數據存儲模塊，用于存儲實時更新和發布的結果數據，并將發送給實時動態影響因素庫。

2.根據權利要求1所述的用于綜合監控系統的大規模實時數據更新發布系統，其特征在于，所述訂閱查詢模塊接收訂閱、查詢請求信息，并于數據存儲模塊中得到訂閱、查詢結果數據后，通過查詢和信息發布接口的方式進行相應結果數據的輸出；及還將接收訂閱、查詢請求信息反饋至實時動態影響因素庫。

3.根據權利要求1所述的用于綜合監控系統的大規模實時數據更新發布系統，其特征在于，所述動態更新發布策略具體為：若數據點當前已被訂閱，則該數據點的更新不得拒絕或放棄，根據訂閱次數和除訂閱次數以外的實時動態影響因素確定優先級；若數據點最近一段時間內被多次查詢，則該數據點的更新不得拒絕或放棄，根據查詢次數和除查詢次數以外的實時動態影響因素確定優先級；若數據點最近有訂閱或查詢，則該數據點的更新不得拒絕或放棄，根據最近的訂閱或查詢時間和除最近訂閱時間及查詢時間以外的實時動態影響因素確定優先級；根據數據點的特點和數據關聯關系，確定特殊數據點，特殊數據點的更新不得拒絕或放棄，并且優先更新；根據數據點的更新結果、更新次數和更新時間間隔，調整數據點優先級；根據特殊點的更新情況和短時間全部并發更新數據量，確定當前工況，當發生特點數據更新并且短時間并發更新數據達到異常工況要求，按異常工況策略處理。

4.根據權利要求1所述的用于綜合監控系統的大規模實時數據更新發布系統，其特征在于，所述預處理模塊根據動態更新發布策略對數據點數據進行預處理，即拒絕數據點數據更新和直接放棄數據點數據，并將結果信息反饋至實時動態影響因素庫中。

5.根據權利要求1所述的用于綜合監控系統的大規模實時數據更新發布系統，其特征在于，所述策略執行模塊根據動態更新發布策略對預處理后的數據點數據進行多線程處理，更新并存儲實時數據點數據至數據存儲模塊，然后信息發布，即拒絕、放棄或直接發布數據點數據。

6.一種用于綜合監控系統的大規模實時數據更新發布方法，其特征在于，包括步驟如下：

1）根據靜態更新發布策略及實時動態影響因素生成動態更新發布策略；

2）根據上述動態更新發布策略控制實時數據點數據的更新和發布，并將更新和發布結果數據反饋至實時動態影響因素庫中；

3）對上述更新和發布結果數據進行存儲；

4）將訂閱、查詢信息更新至實時動態影響因素；

5）直接返回查詢結果至查詢接口；

6）根據動態更新發布策略，完成對步驟3）中結果數據的信息發布狀態。

7.根據權利要求6所述的用于綜合監控系統的大規模實時數據更新發布方法，其特征在于，所述步驟1）中的靜態更新發布策略包含：拒絕數據點數據更新，直接放棄數據點數據，低優先級處理數據點數據，正常處理數據點數據，高優先級處理數據點數據以及異常工況處理數據點數據。

8.根據權利要求6所述的用于綜合監控系統的大規模實時數據更新發布方法，其特征在于，所述步驟1）中的實時動態影響因素分為四類，一類是根據查詢和訂閱情況，包括數據點訂閱次數、數據點最近訂閱時間、數據點一定時間內查詢次數、數據點最近查詢時間；一類是根據預處理情況，包括短時間全部并發更新數量、數據點一定時間內更新次數及數據點最近更新時間；一類是數據處理情況，包括數據處理結果、最近處理時間；一類是根據實時結果數據存儲，包括數據優先級、數據關聯關系、數據最后被使用時間、數據最新變化時間、一定時間內數據更新發布結果記錄。