DroolsJAVA规则引擎(非常好的一篇教程)

1、DroolsJA VA 规则引擎（非常好的一篇教程）Drools 是一个基于java 的规则引擎，开源的，可以将复杂多变的规则从硬编码中解放出来，以规则脚本的形式存放在文件中，使得规则的变更不需要修正代码重启机器就可以立即在线上环境生效。本文所使用的demo 已上传 HYPERLINK /source/3002213 /source/3002213Drools 语法开始语法之前首先要了解一下drools 的基本工作过程，通常而言我们使用一个接口来做事情，首先要穿进去参数，其次要获取到接口的实现执行完毕后的结果，而drools 也是一样的，我们需要传递进去数据，用于规则的检查，调用外部接口，同时

2、还可能需要获取到规则执行完毕后得到的结果。在drools 中， 这个传递数据进去的对象，术语叫 Fact对象。 Fact对象是一个普通的java bean，规则中可以对当前的对象进行任何的读写操作，调用该对象提供的方法，当一个java bean插入到 workingMemory 中，规则使用的是原有对象的引用，规则通过对fact 对象的读写，实现对应用数据的读写，对于其中的属性，需要提供getter setter 访问器，规则中，可以动态的往当前workingMemory 中插入删除新的fact 对象。规则文件可以使用.drl 文件，也可以是xml 文件，这里我们使用 drl 文件。规则语法：

3、package：对一个规则文件而言，package是必须定义的，必须放在规则文件第一行。特别的是，package的名字是随意的， 不必必须对应物理路径，跟 java 的package的概念不同，这里只是逻辑上的一种区分。同样的package下定义的function 和 query等可以直接使用。比如： package com.drools.demo.pointimport：导入规则文件需要使用到的外部变量，这里的使用方法跟 java 相同，但是不同于java 的是，这里的import 导入的不仅仅可以是一个类，也可以是这个类中的某一个可访问的静态方法。比如：import com.drools.

4、demo.point.PointDomain;import com.drools.demo.point.PointDomain.getById;rule：定义一个规则。rule ruleName 。一个规则可以包含三个部分：属性部分：定义当前规则执行的一些属性等，比如是否可被重复执行、过期时间、生效时间等。条件部分，即LHS，定义当前规则的条件，如whenMessage(); 判断当前workingMemory 中是否存在Message对象。结果部分，即RHS， 这里可以写普通java 代码， 即当前规则条件满足后执行的操作，可以直接调用Fact对象的方法来操作应用。规则事例：rule nam

5、eno-loop truewhen$message:Message(status = 0)thenSystem.out.println(fit);$message.setStatus(1);update($message);end上述的属性中：no-loop : 定义当前的规则是否不允许多次循环执行，默认是false，也就是当前的规则只要满足条件，可以无限次执行。什么情况下会出现一条规则执行过一次又被多次重复执行呢？ drools 提供了一些api， 可以对当前传入workingMemory中的 Fact 对象进行修改或者个数的增减，比如上述的update方法，就是将当前的workingMem

6、ory 中的 Message类型的Fact对象进行属性更新，这种操作会触发规则的重新匹配执行， 可以理解为Fact 对象更新了，所以规则需要重新匹配一遍， 那么疑问是之前规则执行过并且修改过的那些Fact对象的属性的数据会不会被重置？结果是不会，已经修改过了就不会被重置，update之后， 之前的修改都会生效。当然对 Fact对象数据的修改并不是一定需要调用update才可以生效，简单的使用set方法设置就可以完成，这里类似于java 的引用调用，所以何时使用update是一个需要仔细考虑的问题，一旦不慎， 极有可能会造成规则的死循环。上述的 no-loop true，即设置当前的规则，只执行

7、一次，如果本身的RHS 部分有update等触发规则重新执行的操作，也不要再次执行当前规则。但是其他的规则会被重新执行，岂不是也会有可能造成多次重复执行，数据紊乱甚至死循环？答案是使用其他的标签限制，也是可以控制的：lock-on-active truelock-on-active true ：通过这个标签，可以控制当前的规则只会被执行一次，因为一个规则的重复执行不一定是本身触发的，也可能是其他规则触发的，所以这个是no-loop 的加强版。当然该标签正规的用法会有其他的标签的配合，后续提及。date-expires：设置规则的过期时间，默认的时间格式：“日 -月 -年” ，中英文格式相同，但

8、是写法要用各自对应的语言，比如中文：29-七月-2010，但是还是推荐使用更为精确和习惯的格式，这需要手动在java 代码中设置当前系统的时间格式，后续提及。属性用法举例：date-expires 2011-01-3123:59:59 / 这里我们使用了更为习惯的时间格式date-effective：设置规则的生效时间，时间格式同上。duration：规则定时，duration 30003 秒后执行规则salience：优先级，数值越大越先执行，这个可以控制规则的执行顺序。其他的属性可以参照相关的api 文档查看具体用法，此处略。规则的条件部分，即LHS 部分：when：规则条件开始。条件可以

9、单个，也可以多个，多个条件一次排列，比如wheneval(true)$customer:Customer()$message:Message(status=0)上述罗列了三个条件，当前规则只有在这三个条件都匹配的时候才会执行RHS 部分，三个条件中第一个eval(true)：是一个默认的api， true 无条件执行，类似于while(true)$message:Message(status=0) 这句话标示的：当前的workingMemory 存在 Message类型并且status 属性的值为0的 Fact 对象， 这个对象通常是通过外部java 代码插入或者自己在前面已经执行的规则的RH

10、S 部分中 insert进去的。前面的$message代表着当前条件的引用变量，在后续的条件部分和 RHS 部分中， 可以使用当前的变量去引用符合条件的FACT 对象，修改属性或者调用方法等。可选，如果不需要使用，则可以不写。条件可以有组合，比如：Message(status=0 | (status 1 & status=100)RHS中对 Fact对象 private属性的操作必须使用getter和 setter方法，而RHS 中则必须要直接用.的方法去使用，比如$order:Order(name=qu)$message:Message(status=0 & orders contains$

11、order & $=qu)特别的是，如果条件全部是& 关系， 可以使用 “ ,”来替代，但是两者不能混用如果现在Fact对象中有一个List，需要判断条件，如何判断呢？看一个例子：Message int status;List names;$message:Message(status=0 & names contains 网易 & names.size = 1)上述的条件中，status必须是0， 并且names列表中含有“网易”并且列表长度大于等于 1contains： 对比是否包含操作，操作的被包含目标可以是一个复杂对象也可以是一个简单的值。Drools 提供了十二中类型比较操作符： =

12、 = != contains / not contains /memberOf / not memberOf /matches/ not matches not contains：与 contains 相反。memberOf：判断某个Fact属性值是否在某个集合中，与contains 不同的是他被比较的对象是一个集合，而contains被比较的对象是单个值或者对象。not memberOf：正好相反。matches：正则表达式匹配，与java 不同的是，不用考虑/的转义问题not matches:正好相反。规则的结果部分当规则条件满足，则进入规则结果部分执行，结果部分可以是纯 java 代码，

13、比如：thenSystem.out.println(OK); / 会在控制台打印出okend 当然也可以调用Fact的方法， 比如$message.execute();操作数据库等等一切操作。 结果部分也有drools 提供的方法：insert：往当前workingMemory 中插入一个新的Fact对象，会触发规则的再次执行，除非使用no-loop 限定；update：更新 modify：修改，与update语法不同，结果都是更新操作retract：删除 RHS 部分除了调用Drools 提供的 api 和 Fact对象的方法，也可以调用规则文件中定义的方法，方法的定义使用function关

14、键字 function void console System.out.println(); StringUtils.getId();/ 调用外部静态方法，StringUtils 必须使用 import 导入， getId()必须是静态方法Drools 还有一个可以定义类的关键字：declare 可以再规则文件中定义一个class，使用起来跟普通java对象相似，你可以在RHS部分中 new一个并且使用getter和 setter 方法去操作其属性。declare Addressauthor(quzishen) / 元数据，仅用于描述信息createTime(2011-1-24)city :

15、String maxLengh(100)postno : intend上述的 是什么呢？是元数据定义，用于描述数据的数据，没什么执行含义你可以在RHS 部分中使用Address address = new Address()的方法来定义一个对象。更多的规则语法，可以参考其他互联网资料，推荐： HYPERLINK /view/a6516373f242336c1eb95e7c.html /view/a6516373f242336c1eb95e7c.html(写的很基础，但是部分语法写的有些简单，含糊不好理解)Drools 应用实例：现在我们模拟一个应用场景：网站伴随业务产生而进行的积分发放操作。比

16、如支付宝信用卡还款奖励积分等。发放积分可能伴随不同的运营策略和季节性调整，发放数目和规则完全不同，如果使用硬编码的方式去伴随业务调整而修改，代码的修改、管理、优化、测试、上线将是一件非常麻烦的事情，所以，将发放规则部分提取出来，交给Drools管理，可以极大程度的解决这个问题。（注意一点的是，并非所有的规则相关内容都建议使用Drools，这其中要考虑系统会运行多久，规则变更频率等一系列条件，如果你的系统只会在线上运行一周，那根本没必要选择 Drools 来加重你的开发成本，java 硬编码的方式则将是首选）我们定义一下发放规则：积分的发放参考因素有：交易笔数、交易金额数目、信用卡还款次数、生日

17、特别优惠等。定义规则：/ 过生日，则加10 分，并且将当月交易比数翻倍后再计算积分 TOC o 1-5 h z / 2011-01-08 - 2011-08-08 每月信用卡还款3 次以上，每满3笔赠送 30 分/ 当月购物总金额100 以上，每100 元赠送 10 分/ 当月购物次数5 次以上，每五次赠送50 分/ 特别的，如果全部满足了要求，则额外奖励100 分/ 发生退货，扣减10 分/ 退货金额大于100，扣减100 分在事先分析过程中，我们需要全面的考虑对于积分所需要的因素，以此整理抽象Fact 对象，通过上述的假设条件，我们假设积分计算对象如下：java view plaincop

18、y/* 积分计算对象* authorquzishen */ public class PointDomain / 用户名private String userName; / 是否当日生日privateboolean birthDay; / 增加积分数目private longpoint; / 当月购物次数private int buyNums;/ 当月退货次数private int backNums; / 当月购物总金额private double buyMoney; / 当月退货总金额private double backMondy; / 当月信用卡还款次数private int billT

19、hisMonth; TOC o 1-5 h z /* 记录积分发送流水，防止重复发放*param userName 用户名* param type 积分发放类型*/ public void recordPointLog(String userName,String type)System.out.println( 增加对+userName+ 的类型为+type+ 的积分操作记录.);public String getUserName() returnuserName; / 其他 getter setter 方法省略定义积分规则接口java view plaincopy/* * 规则接口* au

20、thor quzishen*/ public interface PointRuleEngine /* 初始化规则引擎*/ public void initEngine();/* 刷新规则引擎中的规则*/ publicvoid refreshEnginRule();/* 执行规则引擎* param pointDomain 积分 Fact */ public void executeRuleEngine(final PointDomain pointDomain); 规则接口实现，Drools 的 API 很简单， 可以参考相关API 文档查看具体用法：java view plaincopyim

21、port 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.Pa

22、ckageBuilder; import org.drools.spi.Activation; /* 规则接口实现类*author quzishen */ public class PointRuleEngineImpl implements PointRuleEngine private RuleBase ruleBase;/* (non-Javadoc) * seecom.drools.demo.point.PointRuleEngine#initEngine() */ public void initEngine() / 设置时间格式System.setProperty(drools.d

23、ateformat, yyyy-MM-dd HH:mm:ss);ruleBase =RuleBaseFacatory.getRuleBase();tryPackageBuilder backageBuilder = getPackageBuilderFromDrlFile();ruleBase.addPackages(backageBuilder.getPackages(); catch (DroolsParserException e) catch catche.printStackTrace();(IOException e)e.printStackTrace();(Exception e

24、)e.printStackTrace();/* (non-Javadoc) * see com.drools.demo.point.PointRuleEngine#refreshEnginRule()*/ public void refreshEnginRule() ruleBase= RuleBaseFacatory.getRuleBase();org.drools.rule.Package packages = ruleBase.getPackages();for(org.drools.rule.Package pg : packages)ruleBase.removePackage(pg

25、.getName();initEngine(); /* (non-Javadoc) * see com.drools.demo.point.PointRuleEngine#executeRuleEngine(co m.drools.demo.point.PointDomain) */ public void executeRuleEngine(final PointDomain pointDomain)if(null = ruleBase.getPackages() | 0 =ruleBase.getPackages().length)return;StatefulSession statef

26、ulSession = ruleBase.newStatefulSession(); statefulSession.insert(pointDomain);/firestatefulSession.fireAllRules(neworg.drools.spi.AgendaFilter() public booleanaccept(Activation activation) return !activation.getRule().getName().contains(_test););statefulSession.dispose(); /* 从 Drl规则文件中读取规则* return

27、* throwsException */ private PackageBuilder getPackageBuilderFromDrlFile() throws Exception / 获取测试脚本文件List drlFilePath = getTestDrlFile();/装载测试脚本文件List readers =readRuleFromDrlFile(drlFilePath); PackageBuilder backageBuilder = new PackageBuilder(); for (Reader r : readers) backageBuilder.addPackageF

28、romDrl(r);/ 检查脚本是否有问题if(backageBuilder.hasErrors() throw newException(backageBuilder.getErrors().toString();return backageBuilder; /* paramdrlFilePath 脚本文件路径* return * throwsFileNotFoundException */ privateList readRuleFromDrlFile(ListdrlFilePath) throws FileNotFoundException if (null = drlFilePath

29、| 0 = drlFilePath.size()return null;List readers = new ArrayList();for (String ruleFilePath : drlFilePath)readers.add(new FileReader(newFile(ruleFilePath);readers; * returngetTestDrlFile() return/* 获取测试规则文件*/private ListList drlFilePath =new ArrayList();drlFilePath.add(D:/workspace2/DroolsDemo/src/c

30、om/drools/demo/point/addpoint.drl);drlFilePath.add(D:/workspace2/DroolsDemo/src/com/drools/demo/point/subpoint.drl);return drlFilePath; 为了获取单实例的RuleBase，我们定义一个工厂类 java view plaincopyimport org.drools.RuleBase; importorg.drools.RuleBaseFactory; /* RuleBaseFacatory 单实例 RuleBase 生成工具* author quzishen *

31、/ publicclass RuleBaseFacatory private static RuleBase ruleBase;public static RuleBasegetRuleBase()return null != ruleBase ? ruleBase :RuleBaseFactory.newRuleBase(); 剩下的就是定义两个规则文件，分别用于积分发放和积分扣 减 addpoint.drljava view plaincopypackage com.drools.demo.point import com.drools.demo.point.PointDomain; ru

32、le birthdayPoint / 过生日，则加10 分，并且将当月交易比数翻倍后再计算积分salience 100lock-on-active true when$pointDomain :PointDomain(birthDay = true) then $pointDomain.setPoint($pointDomain.getPoint()+10);$pointDomain.setBuyNums($pointDomain.getBuyNums()*2); $pointDomain.setBuyMoney($pointDomain.getBuyMoney()*2); $pointDom

33、ain.setBillThisMonth($pointDomain.getBillThisMon th()*2);$pointDomain.recordPointLog($pointDomain.getUserName(), birthdayPoint); end rule billThisMonthPoint / 2011-01-08 - 2011-08-08 每月信用卡还款3 次以上，每满3笔赠送 30 分salience 99lock-on-active truedate-effective 2011-01-08 23:59:592011-08-08 23:59:59 whendate-

34、expires$pointDomain : thenPointDomain(billThisMonth = 3) $pointDomain.setPoint($pointDomain.getPoint()+$pointDomain .getBillThisMonth()/3*30);$pointDomain.recordPointLog($pointDomain.getUserName(), billThisMonthPoint); end rule buyMoneyPoint / 当月购物总金额100 以上， 每 100 元赠送 10 分salience 98 lock-on-active

35、true when $pointDomain : PointDomain(buyMoney = 100) then$pointDomain.setPoint($pointDomain.getPoint()+ (int)$pointDomain.getBuyMoney()/100 * 10);$pointDomain.recordPointLog($pointDomain.getUserName(), buyMoneyPoint); end rule buyNumsPoint / 当月 购物次数5 次以上，每五次赠送50 分salience 97lock-on-active true when$

36、pointDomain :PointDomain(buyNums = 5) then $pointDomain.setPoint($pointDomain.getPoint()+$pointDomain .getBuyNums()/5 * 50);$pointDomain.recordPointLog($pointDomain.getUserName(),buyNumsPoint); end rule allFitPoint / 特别的， 如果全部满足了要求，则额外奖励100 分salience 96lock-on-active true when$pointDomain:PointDomai

37、n(buyNums = 5 & billThisMonth = 3 & buyMoney = 100) then$pointDomain.setPoint($pointDomain.getPoint()+ 100);$pointDomain.recordPointLog($pointDomain.getUserName(),a llFitPoint); endsubpoint.drljava view plaincopypackage com.drools.demo.pointimport com.drools.demo.point.PointDomain; rule subBackNumsP

38、oint / 发生退货，扣减10 分salience 10 lock-on-active true when$pointDomain : PointDomain(backNums = 1)then$pointDomain.setPoint($pointDomain.getPoint()-10);$pointDomain.recordPointLog($pointDomain.getUserName(),s ubBackNumsPoint); end rule subBackMondyPoint / 退货金额大于100，扣减100 分salience 9lock-on-active true w

39、hen$pointDomain :PointDomain(backMondy = 100)then$pointDomain.setPoint($pointDomain.getPoint()-10);$pointDomain.recordPointLog($pointDomain.getUserName(),s ubBackMondyPoint); end测试方法：java view plaincopypublic static void main(String args) throws IOException PointRuleEnginepointRuleEngine = new PointRuleEngineImpl();while(true)InputStream is = System.in;BufferedReader br = new B