(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210779345.6 (22)申请日 2022.07.04 (71)申请人 东方合智数据科技 （广东） 有限责任 公司 地址 528237 广东省佛山市南海区狮山 镇 强狮路2号 （厂房A） C区 （住所申报） (72)发明人 王晓峰　邓秀东　 (74)专利代理 机构 深圳市君胜知识产权代理事 务所(普通 合伙) 44268 专利代理师 陈专　杨宏 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/28(2019.01) G06F 9/54(2006.01) G06F 9/455(2006.01) (54)发明名称 基于规则引擎的规则事件动态加载与更新 方法及相关 设备 (57)摘要 本发明公开了基于规则引擎的规则事件动 态加载与更新方法及相关设备， 本发 明引入了动 态规则引 擎模板和动态加载SQL模板， 整合实时 数据分析系统处理规则事件与数据库查询命中 匹配处理的形式， 整体系统运行实现动态加载的 技术实现不停机系统更新， 通过加入规则引擎和 实时数据分析改造后， 租户可根据个人需求添加 多种规则组合的行为查询条件， 并可实时反馈和 更新， 观察数据状态。 权利要求书2页 说明书10页 附图2页 CN 115129736 A 2022.09.30 CN 115129736 A 1.一种基于规则引擎的规则事件动态加载与更新方法， 其特征在于， 所述基于规则引 擎的规则事 件动态加载与更新方法包括： 调用Flink在无边界和有边界数据流上进行有状态的计算， 调用Kafka接收Canal的日 志并以json格式写入Flink中， 进行规则动态变化分析， 对租户新增和更新的规则进行监 控， 并在Fl ink中进行实时数据处 理； 调用规则引擎， 将业务决策从应用程序代码中分离， 并使用预定义的语义模块编写业 务决策， 接收数据输入， 解释业 务规则， 并根据业 务规则做出业 务决策； 使用Canal将Mysql数据库中新增、 删除或者更新的数据， 通过消息中间件Kafka传输到 实时分析系统中， 并保存为可解析的JSON数据格式； 实时分析系统接收消息队列数据， 创建Kafka规则事件流读取数据， 保存JSON， 创建广 播流添加并广播 规则状态信息给 数据分析系统共用； 当应用程序Class文件由类装载器装载后， 在JVM中形成一份描述Class结构的元信息 对象， 通过 元信息对象获知Clas s的结构信息 。 2.根据权利要求1所述的基于规则引擎的规则事件动态加载与 更新方法， 其特征在于， 所述Kafka还用于处 理消费者在网站中的所有动作流数据。 3.根据权利要求1所述的基于规则引擎的规则事件动态加载与 更新方法， 其特征在于， 所述规则引擎使用Rete算法对所编写的规则求 值。 4.根据权利要求1所述的基于规则引擎的规则事件动态加载与 更新方法， 其特征在于， 所述调用规则引擎， 将业务决策从应用程序代码 中分离， 并使用预定义的语义模块编写业 务决策， 接收数据输入， 解释业 务规则， 并根据业 务规则做出业 务决策， 之后还 包括： 加入规则引擎后， 在界面进行自定义规则， 根据用户需求制定规则和不同计算公式写 入系统后， 规则事件配置成动态的DRL文件模板， 并将DRL文件模板转为字符串形式写入 Mysql数据库。 5.根据权利要求1所述的基于规则引擎的规则事件动态加载与 更新方法， 其特征在于， 所述Mysql数据库用于 定义规则事件表； 所述规则事件表包括： 触发事件、 触发人、 所属规则、 触发次数限制、 用户实际已触发次 数、 事件次数阈值查询sql、 事件次数阈值查询s ql、 规则状态、 租户基本属性条件、 租户画像 标签条件、 行为阈值条件、 行为序列条件、 规则判断结果和表定义。 6.根据权利要求1所述的基于规则引擎的规则事件动态加载与 更新方法， 其特征在于， 所述Canal用于伪装成数据库从库， 模拟从库的交互协议向数据库主库发送dump协议， 数据 库主库收到Canal发送过来的dump请求后， 开始 推送数据库增量日志给Canal， Canal解析据 库增量日志， 再发送到存 储目的地。 7.根据权利要求1所述的基于规则引擎的规则事件动态加载与 更新方法， 其特征在于， 所述Clas s的结构信息包括： 构造函数， 属性和方法。 8.一种基于规则引擎的规则事件动态加载与更新系统， 其特征在于， 所述基于规则引 擎的规则事 件动态加载与更新系统包括： 组件调用模块， 用于调用Flink在无边界和有边界数据流上进行有状态的计算， 调用 Kafka接收Canal的日志并以json格式写入Flink中， 进行规则动态变化分析， 对租户新增和 更新的规则进行监控， 并在Fl ink中进行实时数据处 理；权　利　要　求　书 1/2 页 2 CN 115129736 A 2规则引擎调用模块， 用于调用规则引擎， 将业务决策从应用程序代码中分离， 并使用预 定义的语义模块编写业务决策， 接收数据输入， 解释业务规则， 并根据业务规则做出业务决 策； 数据变更模块， 用于使用Can al将Mysql数据库中新增、 删除或者更新的数据， 通过消息 中间件Kafka传输 到实时分析系统中， 并保存为可解析的JSON数据格式； 数据分析模块， 用于实时分析系统接收消息队列数据， 创建Kafka规则事件流读取数 据， 保存JSON， 创建广播 流添加并广播 规则状态信息给 数据分析系统共用； 编译加载模块， 用于当应用程序Class文件由类装载器装载后， 在JVM中形成一份描述 Class结构的元信息对象， 通过 元信息对象获知Clas s的结构信息 。 9.一种终端， 其特征在于， 所述终端包括： 存储器、 处理器及存储在所述存储器上并可 在所述处理器上运行的基于规则引擎的规则事件动态加载与更新程序， 所述基于规则引擎 的规则事件动态加载与更新程序被所述处理器执行时实现如权利要求 1‑7任一项所述的基 于规则引擎的规则事 件动态加载与更新方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有基于规则 引擎的规则事件动态加载与更新程序， 所述基于规则引擎的规则事件动态加载与更新程序 被处理器执行时实现如权利要求 1‑7任一项所述的基于规则引擎的规则事件动态加载与更 新方法的步骤。权　利　要　求　书 2/2 页 3 CN 115129736 A 3