(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210352580.5 (22)申请日 2022.04.06 (65)同一申请的已公布的文献号 申请公布号 CN 114490091 A (43)申请公布日 2022.05.13 (73)专利权人 江苏金恒信息科技股份有限公司 地址 211500 江苏省南京市江北新区中山 科技园科创大道 9号A5栋五层 (72)发明人 王玮玮　李福存　王苏扬　张波　 (74)专利代理 机构 北京弘权知识产权代理有限 公司 11363 专利代理师 逯长明　许伟群 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/54(2006.01)H04L 67/10(2022.01) 审查员 崔景妹 (54)发明名称 工业数据采集管理系统中监控规则引擎性 能的方法及装置 (57)摘要 本申请提供一种工业数据采集管理系统中 监控规则引擎性能的方法及装置。 所述方法通过 定期监测规则引擎订阅的消息队列的生产速度 和消费速度， 来判断当前规则引擎的处理性能是 否能够满足当前工业数据的规则处理的性能需 求， 并根据判断结果来确定是否增设规则引擎服 务器集群节 点， 能够有效避免出现规则引擎处理 性能跟不上导致数据处理滞后或者数据丢失的 问题。 权利要求书3页 说明书8页 附图3页 CN 114490091 B 2022.07.08 CN 114490091 B 1.一种工业数据采集管理系统中监控规则引擎性 能的方法， 所述工业数据采集管理系 统包括多个数据采集器、 消息队列和规则引擎服务器集群， 其特征在于， 所述工业数据采集 管理系统还包括监控规则引擎性能的装置， 所述装置按照预设的监控周期开启性能监控进 程， 所述性能监控进程用于执 行所述方法， 所述方法包括： 获取消息队列的生产速度和消费速度； 其中， 所述生产速度是指消息队列每秒接收工 业数据的条数， 所述消费速度是指规则引擎服务器集群每秒从消息队列中读取工业数据的 条数； 根据所述 生产速度和所述消费速度， 确定消费不及时比例值； 判断所述消费不及时比例值是否小于预设消费不及时比例值； 若所述消费不及时比例值大于或者等于预设的消费不及时比例值， 则增设规则引擎服 务器集群节点； 在判断所述消费不及时比例值是否小于预设消费不及时比例值之后， 增设规则引擎服 务器集群节点之前， 所述方法还 包括： 若所述消费不及时比例值大于或者等于预设的消费不及时比例值， 则记录当前消费不 及时触发时间； 根据所述当前消费不及时触发时间进行计算， 得到消费不及时状态持续时间； 判断所述消费不及时状态持续时间是否小于第一预设状态持续时间； 若所述消费不及时状态持续 时间大于或者等于所述第 一预设状态持续 时间， 则执行所 述增设规则引擎 服务器集群节点的操作； 若所述消费不及时状态持续 时间小于所述第 一预设状态持续 时间， 则终止所述性能监 控进程； 其中， 根据以下公式确定所述消费不及时比例值： ， 其中， E1为所述消费不及时比例值， A为所述 生产速度， B为所述消费速度。 2.根据权利要求1所述的工业数据采集管理系统中监控规则引擎性能的方法， 其特征 在于， 所述方法还 包括： 若所述消费不及时比例值小于预设的消费不及时比例值， 则根据 所述生产速度和所述 消费速度， 确定生产不及时比例值； 判断所述 生产不及时比例值是否小于预设生产不及时比例值； 若所述生产不及时比例值大于或者等于预设生产不及时比例值， 则删减规则引擎服务 器集群节点， 其中， 根据以下公式确定所述 生产不及时比例值： ， 其中， E2为所述生产不及时比例值， A为所述 生产速度， B为所述消费速度。 3.根据权利要求1所述的工业数据采集管理系统中监控规则引擎性能的方法， 其特征权　利　要　求　书 1/3 页 2 CN 114490091 B 2在于， 所述根据所述当前消费不及时触发时间进 行计算， 得到消费不及时状态持续时间， 包 括： 获得首次消费不及时触发时间； 使用所述当前消费不及时触发时间减去所述首次消费不及时触发时间， 得到所述消费 不及时状态持续时间； 其中， 在第一字段中记录首次消费不及时触发时间； 当记录所述当前消费不及时触发时间时， 判断所述第一字段 是否为空； 若所述第一字段为空， 则将所述当前消费不及时触发时间写入所述第一字段， 将所述 当前消费不及时触发时间记录为所述首次消费不及时触发时间； 若所处第一字段不为空， 则读取所述第一字段， 获取 所述首次消费不及时触发时间； 当所述消费不及时比例值小于预设的消费不及时比例值 时， 清空所述第 一字段中的数 据。 4.根据权利要求2所述的工业数据采集管理系统中监控规则引擎性能的方法， 其特征 在于， 在判断所述生产不及时比例值是否小于预设生产不及时比例值之后， 删减规则引擎 服务器集群节点之前， 所述方法还 包括： 若所述生产不及时比例值大于或者等于预设生产不及时比例值， 则记录当前生产不及 时触发时间； 根据所述当前生产不及时触发时间进行计算， 得到生产不及时状态持续时间； 判断所述 生产不及时状态持续时间是否小于第二预设状态持续时间； 若所述生产不及时状态持续 时间大于或者等于所述第 二预设状态持续 时间， 则执行所 述删减规则引擎 服务器集群节点的操作； 若所述生产不及时状态持续 时间小于所述第 二预设状态持续 时间， 则终止所述性能监 控进程。 5.根据权利要求4所述的工业数据采集管理系统中监控规则引擎性能的方法， 其特征 在于， 所述根据所述当前生产不及时触发时间进 行计算， 得到生产不及时状态持续时间， 包 括： 获得首次生产不及时触发时间； 使用所述当前生产不及时触发时间减去所述首次生产不及时触发时间， 得到所述生产 不及时状态持续时间； 其中， 在第二字段中记录首次生产不及时触发时间； 当记录所述当前生产不及时触发时间时， 判断所述第二字段 是否为空； 若所述第二字段为空， 则将所述当前生产不及时触发时间写入所述第二字段， 将所述 当前生产不及时触发时间记录为所述首次生产不及时触发时间； 若所处第二字段不为空， 则读取所述第二字段， 获取 所述首次生产不及时触发时间； 当所述生产不及时比例值小于预设的生产不及时比例值 时， 清空所述第 二字段中的数 据。 6.一种工业数据采集管理系统中监控规则引擎性能的装置， 其特征在于， 所述装置按 照预设的监控周期开启性能监控进程， 以执行权利要求1 ‑5中任一项所述的工业数据采集 管理系统中监控规则引擎性能的方法的步骤， 所述装置包括： 速度获取模块、 计算模块、 判权　利　要　求　书 2/3 页 3 CN 114490091 B 3