[發明專利]多水域的水質監控方法、系統、存儲介質以及電子設備

有效

• 申請號: 202210755551.3
• 申請日: 2022-06-30
• 公開（公告）號: CN114817339B
• 公開（公告）日: 2022-10-11
• 發明（設計）人: 戈燕紅;黃輝勤;李建華;舒少君;彭芳
• 申請（專利權）人: 廣東盈峰科技有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06Q50/06;G06F16/2458;G06F16/28;G01N33/18;H04Q9/00;H04L67/1001;H04L67/12
• 代理公司: 深圳智匯遠見知識產權代理有限公司 44481
• 代理人: 聶磊

1.一種多水域的水質監控方法，其特征在于，包括：

由多個水域的每一個水域中的多個監測設備收集水域的水質數據，包括：每一個所述監測設備按照自身的時間周期，每一個時間周期收集一次所在水域的所述水質數據，確定每一個所述監測設備所要收集的所在水域的所述水質數據的類型；按照所述類型所要求的格式，記錄所收集到的所述水質數據，其中，每一個水域的多個監測設備中，每一個監測設備用于收集所在水域的一種水質數據，每個監測設備的采集水質數據的時間周期不同；

在任意一個監測設備收集所述水質數據后，根據當前所述水質數據相對于上一次收集的水質數據的變化量，確定當前所述水質數據的風險等級，并將所述水質數據發送到處理設備，其中，所述變化量大于第一閾值的情況下，將所述風險等級確定為高風險等級，所述變化量小于或等于所述第一閾值的情況下，將所述風險等級確定為低風險等級；

所述處理設備實時接收每一個所述監測設備發送的所述水質數據；

所述處理設備在接收到任意一個所述監測設備發送的所述水質數據的情況下，記錄所述監測設備的設備標簽和所述水質數據的收集時間，并在所述水質數據的風險等級為所述高風險等級的情況下，將所述水質數據負載均衡到多個第一應用程序框架中的第一目標應用程序框架，并由所述第一目標應用程序框架將所述水質數據存儲到分布式發布訂閱系統中，在所述水質數據的風險等級為所述低風險等級的情況下，將所述水質數據負載均衡到多個第二應用程序框架中的第二目標應用程序框架，并由所述第二目標應用程序框架將所述水質數據存儲到分布式發布訂閱系統中，其中，所述第一應用程序框架處理所述水質數據的速度高于所述第二應用程序框架處理所述水質數據的速度；

對所述分布式發布訂閱系統中的所述水質數據進行分析處理，得到水質結果；

將所述水質結果存儲到緩存數據庫和數據倉庫中；

按照所述設備標簽和所述收集時間，從所述緩存數據庫和數據倉庫中獲取到單個水域的水質結果；

所述方法還包括：

在多臺服務器的每一臺服務器各部署一個Netty數據收集程序，在所述多臺服務器中的一臺目標服務器部署負載均衡應用代理程序Haproxy，并將每一臺服務器的所述Netty數據收集程序配置到所述目標服務器的負載均衡應用代理程序Haproxy中，其中，每一臺服務器的所述Netty數據收集程序按照處理速度分為第一應用程序框架和第二應用程序框架；

在Flink集群部署數據實時計算應用程序；

在接收到所述監測設備采集的所述水質數據的情況下，將所述水質數據發送給所述負載均衡應用代理程序Haproxy，由所述負載均衡應用代理程序Haproxy根據服務器負載情況將所述水質數據轉發給不同的Netty數據收集程序，由所述Netty數據收集程序將所述水質數據存儲到消息組件Kafka中，由所述實時計算應用程序對所述消息組件Kafka中的所述水質數據進行解析、清洗、去重、異常處理及計算后，將結果分別存儲到緩存數據庫Redis和數據倉庫Hive中。

2.根據權利要求1所述的方法，其特征在于，由所述監測設備收集所述水質數據包括：

由所述監測設備收集水質成分數據并對所述水質成分數據進行分析；

將分析結果作為所述水質數據。

3.根據權利要求1所述的方法，其特征在于，將所述水質數據負載均衡到多個應用程序框架中的目標應用程序框架包括：

根據負載均衡加權最小連接數調度算法從多個第一應用程序框架中選擇一個應用程序框架作為所述第一目標應用程序框架或者根據負載均衡加權最小連接數調度算法從多個第二應用程序框架中選擇一個應用程序框架作為所述第二目標應用程序框架。

4.根據權利要求1所述的方法，其特征在于，將所述水質數據負載均衡到多個應用程序框架中的目標應用程序框架包括：

根據負載均衡基于權重的輪詢動態調度算法從多個第一應用程序框架中選擇一個應用程序框架作為所述第一目標應用程序框架或者根據負載均衡基于權重的輪詢動態調度算法從多個第二應用程序框架中選擇一個應用程序框架作為所述第二目標應用程序框架。