(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211246907.7 (22)申请日 2022.10.12 (71)申请人 中水三立数据技 术股份有限公司 地址 230000 安徽省合肥市蜀山 新产业园 稻香路1号 (72)发明人 常仁凯　秦福蝶　唐建　汪永娟　 牛卓勋　高月潘　 (74)专利代理 机构 合肥律众知识产权代理有限 公司 34147 专利代理师 赵娟 (51)Int.Cl. H04L 67/568(2022.01) H04L 67/02(2022.01) H04L 67/1097(2022.01) H04L 69/22(2022.01)H04L 67/12(2022.01) (54)发明名称 一种基于水利物联网的水利数据采集方法 (57)摘要 本发明涉及水利数据采集， 具体涉及一种基 于水利物联网的水利数据采集方法， 在数据接收 服务器上搭建监听服务， 同时在实时通讯服务器 上搭建消息队列服务； 对水利采集终端进行配 置， 水利采集终端向监听服务发送报文信息； 数 据接收服务器接收报文信息， 并将报文信息推送 至消息队列； 数据解析服务 从消息队列中获取报 文信息， 对报文信息进行数据解析， 并将解析数 据推送至解析消息队列； 数据存储服务从解析消 息队列中获取解析数据， 并将解析数据存入数据 库； 本发明提供的技术方案能够 有效克服现有技 术所存在的不便查看采集数据及维护终端设备， 无法应对水利采集终端高并发大批量上报监测 数据的情况， 采集数据展示的时效性较差， 数据 解析效率较低的缺陷。 权利要求书2页 说明书5页 附图2页 CN 115550444 A 2022.12.30 CN 115550444 A 1.一种基于水利物联网的水利数据采集方法， 其特 征在于： 包括以下步骤： S1、 在数据接收服 务器上搭建监听服 务， 同时在实时通讯服 务器上搭建消息队列服 务； S2、 对水利采集终端 进行配置， 水利采集终端向监听服 务发送报文信息； S3、 数据接收服 务器接收报文信息， 并将 报文信息推送至消息队列； S4、 数据解析服务从消息队列中获取报文信息， 对报文信息进行数据解析， 并将解析数 据推送至解析消息队列； S5、 数据存 储服务从解析消息队列中获取解析 数据， 并将解析 数据存入数据库； S6、 平台从数据库中获取解析 数据并展示； 其中， 数据解析服务从消息队列中获取报文信 息， 对报文信 息进行数据解析时， 依据阿 姆达尔加速比获取数据解析服务最优数量， 并根据当前已启用数据解析服务进程数对数据 解析服务进行动态调配。 2.根据权利要求1所述的基于水利物联网的水利数据采集方法， 其特征在于： S1中在数 据接收服 务器上搭建监听服 务， 同时在实时通讯服 务器上搭建消息队列服 务， 包括： 在数据接收服务器上开通外网IP和端口A， 将socket监听服务的监听IP、 端口分别配置 为外网IP、 端口A， 并打开 监听软件； 同时在实时通讯服 务器上搭建消息队列服 务， 创建i ot_messag消息队列。 3.根据权利要求2所述的基于水利物联网的水利数据采集方法， 其特征在于： S2中对水 利采集终端 进行配置， 水利采集终端向监听服 务发送报文信息， 包括： 将水利采集终端的IP、 端口分别配置为外网IP、 端口A； 水利采集终端将监测传感器产生的监测数据生成指定格式的报文信 息， 并将报文信 息 发送至socket监听服 务。 4.根据权利要求3所述的基于水利物联网的水利数据采集方法， 其特征在于： S3 中数据 接收服务器接收报文信息， 并将 报文信息推送至消息队列， 包括： 数据接收服 务器接收报文信息， 并将 报文信息推送至i ot_messag消息队列。 5.根据权利要求4所述的基于水利物联网的水利数据采集方法， 其特征在于： S4中数据 解析服务从消息队列中获取报文信息， 对报文信息进行数据解析， 并将解析数据推送至解 析消息队列， 包括： 数据解析服务按照报文协议从iot_messag消息队列中获取报文信息， 对报文信息进行 数据解析， 并将解析 数据推送至i ot_data解析消息队列。 6.根据权利要求5所述的基于水利物联网的水利数据采集方法， 其特征在于： 所述数据 解析服务从消息队列中获取报文信息， 对报文信息进行数据解析时， 依据阿姆达尔加速比 获取数据解析服务最优数量， 并根据当前已启用数据解析服务进程数对数据解析服务进 行 动态调配， 包括： 采用下式计算阿姆达尔加速比τ： 权　利　要　求　书 1/2 页 2 CN 115550444 A 2其中， t1为未使用动态扩展数据解析服务时完成数据解析任务消耗时间； t2为使用动 态 扩展数据解析服务时完成数据解析任务消耗时间； 增强比例为t2在完成数据解析任务总执 行时间中所占比例， 增强比例永远小于1； 增强加速比为在原条件下完成数据解析任务消耗 时间与使用动态扩展功能后程序执 行时间的比值； 当阿姆达尔加速比τ不小于设定阈值时， 则认为数据解析任务遇到瓶颈， 影响数据解析 效率， 此时开始动态扩展数据解析服 务； 当阿姆达尔加速比τ小于设定阈值时， 停止动态扩展数据解析服 务。 7.根据权利要求6所述的基于水利物联网的水利数据采集方法， 其特征在于： 所述动态 扩展数据解析服务时， 动态扩展后的数据解析服务进程数小于服务器可承载最大进程数， 并在数据解析任务完成后关闭动态扩展的数据解析服 务； 其中， 服务器可承载最大进程数从服 务器配置中获取。 8.根据权利要求5所述的基于水利物联网的水利数据采集方法， 其特征在于： S5 中数据 存储服务从解析消息队列中获取解析 数据， 并将解析 数据存入数据库， 包括： 数据存储服务从iot_data解析消息队列中获取解析数据， 并按照指定存储逻辑存入数 据库。 9.根据权利要求8所述的基于水利物联网的水利数据采集方法， 其特征在于： S6 中平台 从数据库中获取解析 数据并展示， 包括： 平台按照展示逻辑从指定的数据库中获取解析 数据并展示。 10.根据权利要求9所述的基于水利物联网的水利数据采集方法， 其特征在于： 还包括 平台下发控制指令 至水利采集终端， 对水利采集终端 进行远程控制， 具体包括： 平台下发控制指令至iot_control指令消息队列， socket监听服务从iot_control指令 消息队列中获取控制指令并存 入缓存中； 当水利采集终端与socket监听服务建立连接后， socket监听服务将控制指令下发至水 利采集终端， 对水利采集终端 进行远程控制， 并反馈执 行结果。权　利　要　求　书 2/2 页 3 CN 115550444 A 3