📚 课程目录第2章规则引擎基础

2. 规则引擎基础：定义、核心组件与工作原理

规则引擎（Rule Engine）是一种将业务决策逻辑从应用程序代码中分离出来，并使用预定义的规则进行管理和执行的软件组件。在特征服务与冲突检测场景中，规则引擎是判断特征是否冲突、如何路由、是否降级的核心决策大脑。

2.1 规则引擎的定义

规则引擎通过“如果条件（Condition）则动作（Action）”的范式，对输入的事实（Fact）进行推理，并触发相应的操作。它使得业务分析师可以直接调整规则，而无需修改底层代码，从而提升系统的灵活性和可维护性。

  核心价值： 将“怎么做”与“做什么”分离，实现决策逻辑的集中管理与动态热更新。

2.2 三大核心组件

规则引擎由三个核心组件构成：规则库（Rule Base）、工作内存（Working Memory）和推理机（Inference Engine）。三者协同工作，形成完整的决策闭环。

组件	英文名称	职责描述	类比对象
规则库	Rule Base	存储所有业务规则的集合，包含条件（LHS）与动作（RHS）	法律条文汇编
工作内存	Working Memory	存放当前待处理的事实（Fact）对象，是规则匹配的数据源	案件证据台
推理机	Inference Engine	负责将事实与规则进行匹配、冲突消解、执行动作的核心引擎	法官/裁判员

2.3 工作原理：匹配-解决-执行循环

规则引擎的工作流程遵循经典的“匹配-解决-执行”循环（Match-Resolve-Execute Cycle），也称为Rete算法或顺序推理的变体。具体步骤如下：

事实断言（Assert）： 将特征数据、请求上下文等作为事实（Fact）插入到工作内存中。
模式匹配（Pattern Matching）： 推理机将工作内存中的事实与规则库中的条件部分（LHS）进行匹配，生成候选规则集合（Agenda）。
冲突消解（Conflict Resolution）： 当多条规则同时满足条件时，根据优先级、最近使用、复杂度等策略，选择一条规则准备执行。
动作执行（Action Execution）： 执行选中规则的结论部分（RHS），可能包括修改工作内存、触发外部服务、记录日志或返回决策结果。
循环迭代： 如果动作执行修改了工作内存中的事实，则触发新一轮的匹配，直到没有规则可激活或达到最大循环次数。

2.4 推理方式：前向链与后向链

推理机根据业务场景的不同，主要采用两种推理方式：

特性	前向链（Forward Chaining）	后向链（Backward Chaining）
驱动方式	数据驱动（Data-Driven）	目标驱动（Goal-Driven）
起始点	从已知事实出发，寻找匹配的规则	从假设结论出发，反向寻找支持事实
适用场景	实时监控、特征冲突检测、事件流处理	诊断系统、故障排查、合规性验证
典型引擎	Drools、EasyRules	Prolog、CLIPS（混合模式）

实操建议： 在特征服务联动场景中，推荐使用前向链推理。当新的特征数据进入工作内存时，引擎立即触发匹配，能够实现毫秒级的冲突检测与路由决策。

2.5 规则引擎在特征服务中的典型应用

在特征服务架构中，规则引擎通常位于特征计算层与在线服务层之间，承担以下职责：

特征准入控制： 检查请求的特征是否在允许列表中，防止非法特征注入。
冲突检测： 当多个特征源同时提供同一特征时，根据规则决定信任哪个源（例如：实时特征优先于离线特征）。
降级与熔断： 当特征服务响应超时或异常时，规则引擎可触发降级策略，返回默认值或缓存值。
动态路由： 根据请求的上下文（如用户等级、实验分组），将特征请求路由到不同的计算节点。

2.6 规则冲突的根源

在规则引擎中，冲突（Conflict）是指多条规则的条件部分同时被满足，但它们的动作可能相互矛盾或产生非预期结果。冲突的常见类型包括：

冗余冲突： 两条规则的条件和动作完全相同，造成重复执行。
矛盾冲突： 一条规则的动作否定另一条规则的条件或结果（例如：规则A要求返回特征X，规则B要求屏蔽特征X）。
优先级冲突： 多条规则均匹配，但未明确优先级，导致执行顺序不确定。
循环依赖： 规则A修改事实触发规则B，规则B又触发规则A，形成死循环。

注意： 在特征服务联动中，规则冲突可能导致特征值被错误覆盖、请求超时或服务雪崩。因此，在规则上线前必须进行静态冲突检测，并在运行时设置最大循环次数（Max Loop）作为安全阀。

2.7 规则定义示例（伪代码）

以下是一个简单的规则定义示例，用于演示“如果特征A来自实时源且值大于100，则使用实时值，否则使用离线值”的逻辑：

rule "实时特征优先级规则"
    when
        $feature : Feature(name == "user_score", source == "realtime", value > 100)
    then
        $feature.setPriority(10);
        $feature.setEffectiveValue($feature.getValue());
        update($feature);
end

rule "离线特征降级规则"
    when
        $feature : Feature(name == "user_score", source == "offline")
        not (Feature(name == "user_score", source == "realtime", value > 100))
    then
        $feature.setPriority(5);
        $feature.setEffectiveValue($feature.getValue());
        update($feature);
end

通过上述规则，规则引擎能够自动判断特征源的优先级，并在冲突发生时执行正确的降级策略，确保特征服务的稳定输出。