Drools规则引擎批量处理产品归属匹配问题求助

1. 规则写法错误导致批量执行异常 #

你遇到的核心问题是规则的条件写法不正确，导致批量插入产品后，规则引擎错误地只更新最后一个产品。

原规则的when部分拆分了多个Product()约束：

when
    $product: Product()
    Product(productName == "Jigsaw")
    Product(productType == "Resistor")
    Product(productManufacturerName == "Corp.Inc")

这种写法会触发Drools的笛卡尔积匹配：当插入多个Product事实时，引擎会将每个Product实例与所有符合单个属性条件的Product实例进行组合匹配，最终$product会被绑定到遍历到的最后一个Product实例，导致只有最后一个产品被更新，而非所有符合全部属性条件的产品。

修正后的规则写法 #

将所有属性约束合并到同一个Product()声明中，确保规则只匹配同时满足所有属性条件的单个Product实例：

rule "create drool rule from input values with rule id - rule_1"
    salience 110
    activation-group "product-owner-assignment-rules-group"
    when
        $product: Product(
            productName == "Jigsaw",
            productType == "Resistor",
            productManufacturerName == "Corp.Inc"
        )
    then
        $product.setOwnerName("Mr.X");
        $product.setRuleId("rule_1");
end

2. 正确的批量执行代码 #

修正规则后，使用有状态KieSession批量插入所有产品并执行规则即可保证结果正确，同时大幅提升性能：

public void executeRules(@NonNull final List<String> droolRules, @NonNull final List<Product> productOwners) {
    final KnowledgeBuilder knowledgeBuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
    for (final String rule : droolRules) {
        knowledgeBuilder.add(ResourceFactory.newByteArrayResource(rule.getBytes(StandardCharsets.UTF_8)),
                ResourceType.DRL);
    }
    if (knowledgeBuilder.hasErrors()) {
        String errorMessage = "Encountered errors while building rules into the Knowledge Builder:\n" + knowledgeBuilder.getErrors();
        log.error(errorMessage);
        throw new RuntimeException(errorMessage);
    }
    final InternalKnowledgeBase knowledgeBase = KnowledgeBaseFactory.newKnowledgeBase();
    knowledgeBase.addPackages(knowledgeBuilder.getKnowledgePackages());

    // 使用try-with-resources自动关闭会话，避免资源泄漏
    try (KieSession kieSession = knowledgeBase.newKieSession()) {
        // 批量插入所有产品事实
        productOwners.forEach(kieSession::insert);
        // 触发所有规则执行
        kieSession.fireAllRules();
    }
}

3. 关键注意事项 #

• 激活组（activation-group）的作用：同一激活组内的规则，只会执行优先级（salience）最高且匹配成功的那一条。如果你的业务逻辑是每个产品只能被一个规则匹配，这个设置是合理的；若需要多个规则叠加更新同一产品属性，需移除activation-group或改用agenda-group等其他分组方式。
• 性能优化：
  • 为Product的常用匹配属性（如productName、productType）添加索引，Drools会自动利用索引提升匹配速度，尤其在处理大量事实时效果明显。
  • 避免重复创建KnowledgeBase，可将其缓存复用，进一步降低开销。

内容的提问来源于stack exchange，提问作者Pinky Singri