文档章节

JAVA规则引擎[Drools]--实例篇

Candy_Desire
 Candy_Desire
发布于 2014/11/07 16:32
字数 995
阅读 3401
收藏 29

随着互联网应用的飞速发展,各种业务需求也应运而生,对于不断变更和革新的业务规则而言,项目的开发就很有必要把规则部分独立提取出来,此时Drools的价值就得到了体现。废话不多说,看一个简单的例子。

这里举一个手机话费的例子。

一、定义规则:

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

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

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

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

二、创建Fact对象:

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

package com.core.drools;

import java.util.UUID;

/**
 * EntityRule-Model
 * @author Candy
 *
 */
public class EntityRule {
	
	private String username;
	
	/** Whether for new account. */
	private boolean account;
	
	/** The number of add. */
	private int addtime;
	
	/** The sum of the current account. */
	private double currentmoney;
	
	/** The totail amount added. */
	private double totailaddmoney;
	
	/**
	 * Record the serial number of the operation.
	 * @param username
	 * @param currentmoney
	 */
	public void getSerialnumber(String username,double currentmoney){
		System.out.println("Account:"+username+" Balance:¥"+currentmoney);
		System.out.println("Serial Number:"+UUID.randomUUID().toString());
	}

三、定义规则引擎:

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

package com.core.drools;

/**
 * RuleEngine-Interface
 * @author Candy
 * 
 */
public interface RuleEngine {
	
	/**
	 * Initializes the rules engine.
	 */
	public void init();
	
	/**
	 *  Refresh the rules engine.
	 */
	public void refresh();
	
	/**
	 * Execute the rules engine.
	 */
	public void execute(final EntityRule entityRule);

}

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 org.drools.compiler.DroolsParserException;
import org.drools.compiler.PackageBuilder;
import org.drools.rule.Package;
import org.drools.spi.Activation;

/**
 * RuleEngine-Implements
 * @author Candy
 *
 */
public class RuleEngineImpl implements RuleEngine{
	
	private RuleBase ruleBase;
	
     /*
     * (non-Javadoc)
     * @see com.core.drools.RuleEngine#init()
     */
	@Override
	public void init() {
		/** Sets the system time format. */
		System.setProperty("drools.dateformat", "yyyy-MM-dd HH:mm:ss");
		/** Get the base factory. */
		ruleBase =SingleRuleFactory.getRuleBase();
		try {
			/** Get the rule files has bean read. */
			PackageBuilder backageBuilder = getPackageBuilderFile();
			/** Add the package to the 'RuleBase'. */
			ruleBase.addPackages(backageBuilder.getPackages());
		} catch (DroolsParserException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
     /*
     * (non-Javadoc)
     * @see com.core.drools.RuleEngine#refresh()
     */
	@Override
	public void refresh() {
		ruleBase = SingleRuleFactory.getRuleBase();
		Package[] packages = ruleBase.getPackages();
		for(Package items :packages){
			ruleBase.removePackage(items.getName());
		}
		init();
	}

	/*
	 * (non-Javadoc)
	 * @see com.core.drools.RuleEngine#execute(com.core.drools.EntityRule)
	 */
	@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();
	}
	
	/**
	 * Read the rule files.
	 * @return
	 * @throws Exception
	 */
	private PackageBuilder getPackageBuilderFile()throws Exception {
		/** Get the rule files. */
		List<String> drlFilePath = getRuleFile();
		/** Sets the file to 'readers'. */
		List<Reader> readers = loadRuleFile(drlFilePath);
		/** To create the 'backageBuilder'. */
		PackageBuilder backageBuilder = new PackageBuilder();
		for (Reader r : readers) {
			backageBuilder.addPackageFromDrl(r);
		}
		/** Check if the script has a problem. */
		if(backageBuilder.hasErrors()) {
			throw new Exception(backageBuilder.getErrors().toString());
		}
		return backageBuilder;
	}
	
	/**
	 * Load the script files.
	 * @param drlFilePath 
	 * @return
	 * @throws FileNotFoundException
	 */
	private List<Reader> loadRuleFile(List<String> drlFilePath)
		throws FileNotFoundException {
		if (null == drlFilePath || 0 == drlFilePath.size()) {
			return null;
		}
		List<Reader> readers = new ArrayList<Reader>();
		for (String ruleFilePath : drlFilePath) {
			readers.add(new FileReader(new File(ruleFilePath)));
		}
		return readers;
	}

	/**
	 * Get the rule files.
	 * @return
	 */
	private List<String> getRuleFile(){
		List<String> drlFilePath = new ArrayList<String>();
		String path="D:/utils/my/DroolsProject/src/com/core/drools/drools_rule.drl";
		drlFilePath.add(path);
		return drlFilePath;
	}

}

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

package com.core.drools;

import org.drools.RuleBase;
import org.drools.RuleBaseFactory;

/**
 * To create a singleton factory.
 * @author Candy
 *
 */
public class SingleRuleFactory {
	
	private static RuleBase ruleBase;
	
	/**
	 * Get the base factory.
	 * @return
	 */
	public static RuleBase getRuleBase(){
		return null != ruleBase ? ruleBase : RuleBaseFactory.newRuleBase();
	}

}

四、编写规则文件:

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

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 "2014-010-01 00:00:00"
	date-expires   "2014-012-31 23:59:59"
	when
	    $entityRule : EntityRule(addtime >= 3)
	then
	System.out.println("Prepaid phone number reach "+$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

五、测试引擎:

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 Candy
 *
 */
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);
	}
	
}

六、测试结果:

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

© 著作权归作者所有

共有 人打赏支持
Candy_Desire
粉丝 31
博文 71
码字总数 84592
作品 0
浦东
产品经理
加载中

评论(1)

达人不是我
达人不是我
Drools规则工作流引擎开发教程
网盘地址:http://pan.baidu.com/s/1boavEAN 密码:q4e0
备用地址(腾讯微云):http://url.cn/5NZUh5b 密码:rhO85Y
Drools7.x环境搭建与简单示例

Drools是个规则引擎的开源实现。官方文档比较长。这里提供一个方法,搭建最基本的Drools运行环境,并提供一个简单示例。 环境准备: JDK 至少需要JDK 1.5以上,JDK去这里下载:http://www.or...

supergao222
01/10
0
0
jboss规则引擎KIE Drools 6.3.0-集群篇

DROOLS集群的原理 Drools集群是架设在jboss集群之上的 Drools集群其实是WorkBench(WB)间的集群 KIE SERVER是JSON服务,它是架设在WB上的,一个WB可以挂1个、多个KIE SERVER WB除了HTTP间的...

lifetragedy
2017/07/04
0
0
原创 (第四章)Drools规则引擎系列之《规则文件》

原创 (第四章)Drools规则引擎系列之《规则文件》 Harries Blog™2018-08-241 阅读 代码http删除javamessageupdateIOJavaIDE

Harries Blog™
08/24
0
0
JBoss,Geronimo还是Tomcat?——三种开源Java应用服务器的比较

JBoss,Geronimo还是Tomcat? ——三种开源Java应用服务器的比较 作者:Jonathan Campbell 译者:李功健 原文:http://www.javaworld.com/javaworld/jw-12-2007/jw-12-appservers.html 目录 ...

晨曦之光
2012/03/09
0
0
drools实现自定义业务规则

最近做财务相关的积分规则,由于这个功能以后涉及到方方面面,所以想尽可能做的可维护,可扩展,平台其他人调用起来更加方便,联想到财务相关的功能会更多的规则配置,在这里打算用drools规则...

阿飞哥
2012/10/12
0
13

没有更多内容

加载失败,请刷新页面

加载更多

android -------- MVP+DataBinding 的使用

天来说说MVP+DataBinding 的使用 以一个登录案例来讲解 布局:(ConstraintLayout 作为根布局) <layout> <data> <variable name="onClick" ......

切切歆语
34分钟前
1
0
阿里十年Java架构经验总结,这几点尤为重要!

你有没有静下心来思考过:同样是做了x年Java开发,为什么你的技术比别人差很多?为什么别人每月28K你却只有10K? 其实技术水平的高低和个人智商关系不大(毕竟能做Java编程开发大家都不会差)...

别打我会飞
38分钟前
1
0
Ubuntu 中安装和配置 Caddy 服务

首先访问:https://caddyserver.com/download 选择操作系统、插件和授权类型,点击 Download 下载编译好的文件包,或者执行页面最下面的一键安装脚本,完成 caddy 的安装。 安装完成后,/us...

八风不动
53分钟前
2
0
java代码效率优化

1、 尽量指定类的final修饰符 带有final修饰符的类是不可派生的。 2、 尽量重用对象。 3、 尽量使用局部变量,调用方法时传递的参数以及在调用中创建的临时变量都保存在栈(Stack)中,速度较...

踏破铁鞋无觅处
今天
3
0
程序员的几款利器

1. 作为程序员,最希望的就是自己的代码能够在一个云平台上保留下来,gitlab等等这些很多。但是我这里推荐“码云平台”码云平台和开源中国可以直接关联起来。开源中国可以记录博客,当然也是...

ChinaHYF
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部