java营销活动动态引擎规则_JAVA规则引擎 Drools 教程

我们的日常生活是由规则驱动的。每次我们在开车的时候停在红灯处，之所以这样做，因为我们遵循一条规则，灯变红时我们应该停下来。如果你跳起来，最终会落到地面，这是由地球引力所决定的，它可以被表示成简单的数学方程。然而，对于我们生活日常中的规则，我们使用更加简单的结构来表示：当 XXX 的时候，做 XXX 的事。

1 2

when 满足什么样的条件 then 最终结果

在程序中普遍的存在一些业务逻辑规则。比如下面的代码：

1 2 3

if (){} else if (){} else {}

在这些规则不变的情况下，我们的程序能完成正常的需求规则。但是程序中的一些规则经常是需要变动的，这些变动我们可以通过代码来更改。但是往往一些需求规则变动太频繁，常改代码不是常事，因此我们需要一种更灵活的方法来实现。在这时 Drools 规则引擎框架诞生了，它能极大的方便我们更改一些程序中的规则。

Drools 简介

JBoss Rules 的前身是Codehaus的一个开源项目叫Drools。最近被纳入JBoss门下，更名为JBoss Rules，成为了JBoss应用服务器的规则引擎。

Drools是为Java量身定制的基于Charles Forgy的RETE算法的规则引擎的实现。具有了OO接口的RETE,使得商业规则有了更自然的表达。

Drools的用 XML 的、 节点表达If–Then句式，而里面可以嵌入上述语言的代码作为判断语句和执行语句。

其中Java代码会使用Antlr进行解释，而 Groovy 和 Python 本身就是脚本语言，可以直接调用。

Drools的聪明之处在于，用 XML 节点来规范 If–Then 句式和事实的定义，使引擎干起活来很舒服。

而使用Java，Groovy等原生语言来做判断和执行语句，让程序员很容易过渡、移植，学习曲线很低。

下面我们进入实战系列，实现一个手机话费的例子。

定义规则

首先要分析自己的业务逻辑，根据业务而制定出不同的规则，这里我们假设有3个规则。

对于新开户的手机用户送20元话费。

在10月到12期间充值的用户，不论金额多少充值满3次就赠送5元话费。

当月充值金额达到100以上，每达到一次赠送话费10元。

Drools 教程

分析这些规则，并把他们抽象成一个 EntityRule 对象。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

package com.core.drools; import java.util.UUID; /** * EntityRule-Model * @author */ public class EntityRule { private String username; private boolean account; private int addtime; private double currentmoney; private double totailaddmoney; public void getSerialnumber(String username, double currentmoney){ System.out.println( "Account：" +username+ " Balance：￥" +currentmoney); System.out.println( "Serial Number：" +UUID.randomUUID().toString()); } }

定义规则引擎

业务和规则都整理清楚了我们就可以开始规则引擎的核心部分啦，这里我定义的是接口和实现类。

1 2 3 4 5 6 7 8 9 10

package com.core.drools; /** * RuleEngine-Interface * @author */ public interface RuleEngine { public void init(); public void refresh(); public void execute( final EntityRule entityRule); }

实现规则引擎

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89

package com.core.drools; import java.io.File; import java.io.FileNotFoundException; import java.io.FileReader; import java.io.IOException; import java.io.Reader; import java.util.ArrayList; import java.util.List; import org.drools.RuleBase; import org.drools.StatefulSession; import piler.DroolsParserException; import piler.PackageBuilder; import org.drools.rule.Package; import org.drools.spi.Activation; /** * RuleEngine-Implements * @author */ public class RuleEngineImpl implements RuleEngine{ private RuleBase ruleBase; @Override public void init() { System.setProperty( "drools.dateformat" , "yyyy-MM-dd HH:mm:ss" ); ruleBase =SingleRuleFactory.getRuleBase(); try { PackageBuilder backageBuilder = getPackageBuilderFile(); ruleBase.addPackages(backageBuilder.getPackages()); } catch (DroolsParserException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } @Override public void refresh() { ruleBase = SingleRuleFactory.getRuleBase(); Package[] packages = ruleBase.getPackages(); for (Package items :packages){ ruleBase.removePackage(items.getName()); } init(); } @Override public void execute( final EntityRule entityRule) { if ( null == ruleBase.getPackages() || 0 == ruleBase.getPackages().length) { return ; } StatefulSession statefulSession = ruleBase.newStatefulSession(); statefulSession.insert(entityRule); statefulSession.fireAllRules( new org.drools.spi.AgendaFilter() { public boolean accept(Activation activation) { return !activation.getRule().getName(). contains( "_test" ); } }); statefulSession.dispose(); } private PackageBuilder getPackageBuilderFile() throws Exception { List drlFilePath = getRuleFile(); List readers = loadRuleFile(drlFilePath); PackageBuilder backageBuilder = new PackageBuilder(); for (Reader r : readers) { backageBuilder.addPackageFromDrl(r); } if (backageBuilder.hasErrors()) { throw new Exception(backageBuilder.getErrors().toString()); } return backageBuilder; } private List loadRuleFile(List drlFilePath) throws FileNotFoundException { if ( null == drlFilePath || 0 == drlFilePath.size()) { return null ; } List readers = new ArrayList(); for (String ruleFilePath : drlFilePath) { readers.add( new FileReader( new File(ruleFilePath))); } return readers; } private List getRuleFile(){ List drlFilePath = new ArrayList(); String path="D:/utils/my/DroolsProject/src/ com/core/drools/drools_rule.drl"; drlFilePath.add(path); return drlFilePath; } }

再定义一个单例的RuleBase工厂类。

1 2 3 4 5 6 7 8 9 10 11 12

package com.core.drools; import org.drools.RuleBase; import org.drools.RuleBaseFactory; /** * @author */ public class SingleRuleFactory { private static RuleBase ruleBase; public static RuleBase getRuleBase(){ return null != ruleBase ? ruleBase : RuleBaseFactory.newRuleBase(); } }

编写规则文件

规则文件可以根据自己的业务需求定义多个文件，这里我只定义了一个。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38

package com.core.drools import com.core.drools.EntityRule; rule accountEntity //One salience 100 lock-on-active true when $entityRule : EntityRule(account == true) then System.out.println("The new account:Present￥20.0"); $entityRule.setCurrentmoney($entityRule.getCurrentmoney()+20); $entityRule.getSerialnumber($entityRule.getUsername(),$entityRule.getCurrentmoney()); System.out.println(); end rule billEntity //two salience 99 lock-on-active true date-effective "-010-01 00:00:00" date-expires "-012-31 23:59:59" when $entityRule : EntityRule(addtime >= 3) then System.out.println("Prepaid phone numberreach "+$entityRule.getAddtime()+" times:Present ￥"+$entityRule.getAddtime()/3*5); $entityRule.setCurrentmoney($entityRule.getCurrentmoney()+$entityRule.getAddtime()/3*5); $entityRule.getSerialnumber($entityRule.getUsername(),$entityRule.getCurrentmoney()); System.out.println(); end rule addMoney //Three salience 98 lock-on-active true when $entityRule : EntityRule(totailaddmoney >= 100) then System.out.println("The account for the month top-up totail amount is "+$entityRule.getTotailaddmoney()+":Present ￥"+(int)$entityRule.getTotailaddmoney()/100*10); $entityRule.setCurrentmoney($entityRule.getCurrentmoney()+(int)$entityRule.getTotailaddmoney()/100 * 10);$entityRule.getSerialnumber($entityRule.getUsername(),$entityRule.getCurrentmoney()); end

测试引擎

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

package com.test; import java.io.IOException; import com.core.drools.EntityRule; import com.core.drools.RuleEngine; import com.core.drools.RuleEngineImpl; /** * Test Drools * @author */ public class DroolsTest { public static void main(String[] args) throws IOException { RuleEngine engineImpl = new RuleEngineImpl(); engineImpl.init(); final EntityRule entityRule= new EntityRule(); entityRule.setCurrentmoney(350d); entityRule.setUsername( "Candy" ); entityRule.setAccount( true ); entityRule.setTotailaddmoney(350d); entityRule.setAddtime( 7 ); engineImpl.execute(entityRule); } }

测试结果

1 2 3 4 5 6 7 8 9 10 11

The new account:Present ￥20.0 Account：Candy Balance：￥370.0 Serial Number：0fd98593-caa2-444d-a4ff-b4001cfb3260 ------------------------------------------------------------------------------ Prepaid phone number reach 7 times:Present ￥10 Account：Candy Balance：￥380.0 Serial Number：a118b211-c28e-4035-aa60-2f417f62b2f3 ------------------------------------------------------------------------------ The account for the month top-up totail amount is 350.0: Present ￥30 Account：Candy Balance：￥410.0 Serial Number：2bfc02c2-267f-47a2-9cda-5a4196e2b7cf

Drools规则引擎就是这么简单，在实际的程序中能帮助我们解决很多现实问题。