(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210755551.3 (22)申请日 2022.06.30 (65)同一申请的已公布的文献号 申请公布号 CN 114817339 A (43)申请公布日 2022.07.29 (73)专利权人 广东盈峰科技有限公司 地址 528322 广东省佛山市顺德区勒流 街 道江村村慧商路8号 (72)发明人 戈燕红　黄辉勤　李建华　舒少君　 彭芳　 (74)专利代理 机构 深圳智汇远见知识产权代理 有限公司 4 4481 专利代理师 聂磊 (51)Int.Cl. G06F 16/2455(2019.01)G06Q 50/06(2012.01) G06F 16/2458(2019.01) G06F 16/28(2019.01) G01N 33/18(2006.01) H04Q 9/00(2006.01) H04L 67/1001(2022.01) H04L 67/12(2022.01) 审查员 邓丽婉 (54)发明名称 多水域的水质监控方法、 系统、 存储介质以 及电子设备 (57)摘要 本发明涉及水质监控 领域， 公开了一种多水 域的水质监控方法、 系统、 存储介质以及电子设 备。 该方法包括： 由多个水域的每一个水域中的 多个监测设备收集水域的水质数据， 确定水质数 据的风险等级； 在水质数据的风险等级为第一等 级的情况下， 将水质数据负载均衡到第一目标应 用程序框架， 在水质数据的风险等级为第二等级 的情况下， 将水质数据负载均衡到第二目标应用 程序框架； 对分布式发布订阅系统中的水质数据 进行分析处理， 得到水质结果； 将水质结果存储 到缓存数据库和数据仓库中； 按照设备标签和收 集时间， 从缓存 数据库和数据仓库中获取到单个 水域的水质结果。 本发明解决了多水域的水质数 据监控的过程中， 数据阻塞的技 术问题。 权利要求书3页 说明书12页 附图3页 CN 114817339 B 2022.10.11 CN 114817339 B 1.一种多水域的水质监控方法， 其特 征在于， 包括： 由多个水域的每一个水域中的多个监测设备收集水域的水质数据， 包括： 每一个所述 监测设备按照自身的时间周期， 每一个时间周期收集一次所在水域的所述水质数据， 确定 每一个所述监测设备所要收集的所在水域的所述水质数据的类型； 按照所述类型所要求的 格式， 记录所收集到的所述水质数据， 其中， 每一个水域的多个监测设备中， 每一个监测设 备用于收集所在水域的一种水质数据， 每 个监测设备的采集水质数据的时间周期不同； 在任意一个监测设备收集所述水质数据后， 根据当前所述水质数据相对于上一次收集 的水质数据的变化量， 确定当前所述水质数据的风险等级， 并将所述水质数据发送到处理 设备， 其中， 所述变化量大于第一阈值的情况下， 将所述风险等级确定为高风险等级， 所述 变化量小于或等于所述第一阈值的情况 下， 将所述 风险等级确定为低风险等级； 所述处理设备实时接收每一个所述 监测设备发送的所述水质数据； 所述处理设备在接收到任意一个所述监测设备发送的所述水质数据的情况下， 记录所 述监测设备的设备标签和所述水质数据的收集时间， 并在所述水质数据的风险等级为所述 高风险等级的情况下， 将所述水质数据负载均衡到多个第一应用程序框架中的第一目标应 用程序框架， 并由所述第一目标应用程序框架将所述水质数据存储到 分布式发布订阅系统 中， 在所述水质数据的风险等级为所述低风险等级的情况下， 将所述水质数据负载均衡到 多个第二应用程序框架中的第二目标应用程序框架， 并由所述第二目标应用程序框架将所 述水质数据存储到分布式发布订阅系统中， 其中， 所述第一应用程序框架处理所述水质数 据的速度高于所述第二应用程序框架处 理所述水质数据的速度； 对所述分布式发布订阅系统中的所述水质数据进行分析处 理， 得到水质结果； 将所述水质结果存 储到缓存数据库和数据仓库中； 按照所述设备标签和所述收集 时间， 从所述缓存数据库和数据仓库中获取到单个水域 的水质结果； 所述方法还 包括： 在多台服务器的每一台服务器各部署一个Netty数据收集程序， 在所述多台服务器中 的一台目标服务器部署负载均衡应用代理程序Hapr oxy， 并将每一台服务器的所述Netty数 据收集程序配置到所述目标服务器的负载均衡应用代理程序Hapr oxy中， 其中， 每一台服务 器的所述 Netty数据收集 程序按照处 理速度分为第一应用程序框架和第二应用程序框架； 在Flink集群部署数据实时计算应用程序； 在接收到所述监测设备采集的所述水质数据的情况下， 将所述水质数据发送给所述负 载均衡应用代理程序Hapr oxy， 由所述负载均衡应用代理程序Hapr oxy根据服务器负载情况 将所述水质数据转 发给不同的Netty数据收集程序， 由所述Netty数据收集程序将所述水质 数据存储到消息组件 Kafka中， 由所述实时计算应用程序对 所述消息组件 Kafka中的所述水 质数据进行解析、 清洗、 去重、 异常处理及计算后， 将结果分别存储到缓存 数据库Redis和数 据仓库Hive中。 2.根据权利要求1所述的方法， 其特 征在于， 由所述 监测设备收集所述水质数据包括： 由所述监测设备收集水质成分数据并对所述水质成分数据进行分析； 将分析结果作为所述水质数据。 3.根据权利要求1所述的方法， 其特征在于， 将所述水质数据负载均衡到多个应用程序权　利　要　求　书 1/3 页 2 CN 114817339 B 2框架中的目标应用程序框架包括： 根据负载均衡加权最小连接数调度算法从多个第一应用程序框架中选择一个应用程 序框架作为所述第一目标应用程序框架或者根据负载均衡加权最小连接数调度算法从多 个第二应用程序框架中选择一个 应用程序框架作为所述第二目标应用程序框架。 4.根据权利要求1所述的方法， 其特征在于， 将所述水质数据负载均衡到多个应用程序 框架中的目标应用程序框架包括： 根据负载均衡基于权重的轮询动态调度算法从多个第一应用程序框架中选择一个应 用程序框架作为所述第一目标应用程序框架或者根据负载均衡基于权重的轮询动态调度 算法从多个第二应用程序框架中选择一个 应用程序框架作为所述第二目标应用程序框架。 5.根据权利要求1所述的方法， 其特征在于， 将所述水质数据负载均衡到多个应用程序 框架中的目标应用程序框架包括： 根据负载均衡负载平衡算法从多个第一应用程序框架中选择一个应用程序框架作为 所述第一目标应用程序框架或者根据负载均衡负载平衡算法从多个第二应用程序框架中 选择一个 应用程序框架作为所述第二目标应用程序框架。 6.一种多水域的水质监控系统， 其特 征在于， 包括： 收集模块， 用于控制多个水域的每一个水域中的多个监测设备收集水域的水质数据， 包括： 每一个所述监测设备按照自身的时间周期， 每一个时间周期收集一次所在水域的所 述水质数据， 确定每一个所述监测设备所要收集的所在水域的所述水质数据的类型； 按照 所述类型所要求的格式， 记录所收集到的所述水质数据， 其中， 每一个水域的多个监测设备 中， 每一个监测设备用于 收集所在水域的一种 水质数据， 每个监测设备 的采集水质数据的 时间周期不同； 在任意一个监测设备收集所述水质数据后， 根据当前所述水质数据相对于 上一次收集的水质数据的变化量， 确定当前所述水质数据的风险等级， 并将所述水质数据 发送到处理设备， 其中， 所述变化量大于第一阈值的情况下， 将所述风险等级确定为高风险 等级， 所述变化 量小于或等于所述第一阈值的情况 下， 将所述 风险等级确定为低风险等级； 处理设备， 包括： 接收模块， 用于实时接收每一个所述监测设备发送 的所述水质数据； 负载均衡模块， 用于在接 收到任意一个所述监测设备发送的所述水质数据的情况下， 记录 所述监测设备的设备标签和所述水质数据的收集时间， 并在所述水质数据的风险等级为高 风险等级的情况下， 将所述水质数据负载均衡到多个第一应用程序框架中的第一目标应用 程序框架， 并由所述第一目标应用程序框架将所述水质数据存储到分布式发布订阅系统 中， 在所述水质数据的风险等级为所述低风险等级的情况下， 将所述水质数据负载均衡到 多个第二应用程序框架中的第二目标应用程序框架， 并由所述第二目标应用程序框架将所 述水质数据存储到分布式发布订阅系统中， 其中， 所述第一应用程序框架处理所述水质数 据的速度高于所述第二应用程序框架处 理所述水质数据的速度； 分析模块， 用于对所述分布式发布订阅系统中的所述水质数据进行分析处理， 得到水 质结果； 存储模块， 用于将所述水质结果存 储到缓存数据库和数据仓库中； 获取模块， 用于按照所述设备标签和所述收集时间， 从所述缓存数据库和数据仓库中 获取到单个水域的水质结果； 所述系统还 包括：权　利　要　求　书 2/3 页 3 CN 114817339 B 3