文章目錄

• • 學前
  • 規則引擎
  • • 作用
    • 優勢
    • Drools
    • • 項目搭建流程
      • 項目結構
      • pom.xml
      • 配置文件
      • 規則文件
      • • 語法說明
        • 規則說明
      • 規則執行代碼
      • 規則調用接口

學前

有這樣一串代碼，代表著積分策略業務，計算額外積分金額：

100 以下, 不加分；

100-500 加100分；

500-1000 加500分；

1000 以上 加1000分；

public class JavaScoreExample {public static void main(String[] args) throws Exception { List<Order> orderList = getInitData();for (int i=0; i<orderList.size(); i++){ Order order = orderList.get(i); if (order.getAmout() <= 100){ order.setScore(0); addScore(order); }else if(order.getAmout() > 100 && order.getAmout() <= 500){ order.setScore(100); addScore(order); }else if(order.getAmout() > 500 && order.getAmout() <= 1000){ order.setScore(500); addScore(order); }else{ order.setScore(1000); addScore(order); } } } private static void addScore(Order o){ System.out.println("用戶" + o.getUser().getName() + "享受額外增加積分: " + o.getScore()); } private static List<Order> getInitData() throws Exception { List<Order> orderList = new ArrayList<Order>();DateFormat df = new SimpleDateFormat("yyyy-MM-dd");{Order order = new Order(); order.setAmout(80); order.setBookingDate(df.parse("2015-07-01")); User user = new User();user.setLevel(1); user.setName("Name1"); order.setUser(user); orderList.add(order); }{Order order = new Order(); order.setAmout(200); order.setBookingDate(df.parse("2015-07-02")); User user = new User();user.setLevel(2); user.setName("Name2"); order.setUser(user); orderList.add(order); } return orderList; } }

綜上，如果這時由于市場需求變化，又要調整規則時候，則又要進行業務層面的代碼修改、部署，十分麻煩。

那該怎么辦呢？

規則引擎

作用

我們可以把決策規則從應用程序中分離出來，將對系統提供很大的便利

優勢

簡化系統架構，優化應用

提高系統的可維護性和維護成本

減少編寫“硬代碼”業務規則的成本和風險

Drools

Drools是一個基于java的規則引擎，它是開源的，可以將復雜多變的規則從硬編碼中解放出來，以規則腳本的形式存放在文件中，使得規則的變更不需要修正代碼重啟機器就可以立即在線上環境生效。具有易于訪問企業策略、易于調整以及易于管理的特點，作為開源業務規則引擎，符合業內標準，速度快、效率高。

項目搭建流程

以下項目基于Springboot搭建

項目結構

項目存放：image/drool.rar

pom.xml

<!--drools規則引擎--> <dependency><groupId>org.drools</groupId><artifactId>drools-core</artifactId><version>7.6.0.Final</version> </dependency> <dependency><groupId>org.drools</groupId><artifactId>drools-compiler</artifactId><version>7.6.0.Final</version> </dependency> <dependency><groupId>org.drools</groupId><artifactId>drools-templates</artifactId><version>7.6.0.Final</version> </dependency> <dependency><groupId>org.kie</groupId><artifactId>kie-api</artifactId><version>7.6.0.Final</version> </dependency> <dependency><groupId>org.kie</groupId><artifactId>kie-spring</artifactId><version>7.6.0.Final</version> </dependency>

配置文件

@Configuration public class RuleEngineConfig {private static final Logger LOGGER = LoggerFactory.getLogger(RuleEngineConfig.class) ;private static final String RULES_PATH = "droolRule/";private final KieServices kieServices = KieServices.Factory.get();@Beanpublic KieFileSystem kieFileSystem() throws IOException {KieFileSystem kieFileSystem = kieServices.newKieFileSystem();ResourcePatternResolver resourcePatternResolver = new PathMatchingResourcePatternResolver();Resource[] files = resourcePatternResolver.getResources("classpath*:" + RULES_PATH + "*.*");String path = null;for (Resource file : files) {path = RULES_PATH + file.getFilename();LOGGER.info("path="+path);kieFileSystem.write(ResourceFactory.newClassPathResource(path, "UTF-8"));}return kieFileSystem;}@Beanpublic KieContainer kieContainer() throws IOException {KieRepository kieRepository = kieServices.getRepository();kieRepository.addKieModule(kieRepository::getDefaultReleaseId);KieBuilder kieBuilder = kieServices.newKieBuilder(kieFileSystem());kieBuilder.buildAll();return kieServices.newKieContainer(kieRepository.getDefaultReleaseId());}@Beanpublic KieBase kieBase() throws IOException {return kieContainer().getKieBase();}@Beanpublic KieSession kieSession() throws IOException {return kieContainer().newKieSession();}@Beanpublic KModuleBeanFactoryPostProcessor kiePostProcessor() {return new KModuleBeanFactoryPostProcessor();} }

規則文件

語法說明

文件格式：可以 .drl、xml文件，也可以Java代碼塊硬編碼

package：規則文件中，package是必須定義的，必須放在規則文件第一行

import：規則文件使用到的外部變量，可以是一個類，也可以是類中的可訪問的靜態方法

rule：定義一個規則。paramcheck1規則名。規則通常包含三個部分：屬性、條件、結果

規則說明

salience 的值越大，越優先執行

規則流程：如果paramId不為null，參數標識是+號，執行添加規則，-號，執行移除規則操作

dialect "java" rule "paramcheck1"salience 99when queryParam : QueryParam(paramId != null && paramSign.equals("+"))resultParam : RuleResult()thenfinal Logger LOGGER = LoggerFactory.getLogger("param-check-one 規則引擎") ;LOGGER.info("參數:getParamId="+queryParam.getParamId()+";getParamSign="+queryParam.getParamSign());RuleEngineServiceImpl ruleEngineService = new RuleEngineServiceImpl() ;ruleEngineService.executeAddRule(queryParam);resultParam.setPostCodeResult(true); end dialect "java" rule "paramcheck2"salience 88when queryParam : QueryParam(paramId != null && paramSign.equals("-"))resultParam : RuleResult()thenfinal Logger LOGGER = LoggerFactory.getLogger("param-check-two 規則引擎") ;LOGGER.info("參數:getParamId="+queryParam.getParamId()+";getParamSign="+queryParam.getParamSign());RuleEngineServiceImpl ruleEngineService = new RuleEngineServiceImpl() ;ruleEngineService.executeRemoveRule(queryParam);resultParam.setPostCodeResult(true); end

規則執行代碼

@Service public class RuleEngineServiceImpl implements RuleEngineService {private static final Logger LOGGER = LoggerFactory.getLogger(RuleEngineServiceImpl.class) ;@Overridepublic void executeAddRule(QueryParam param) {LOGGER.info("參數數據:"+param.getParamId()+";"+param.getParamSign());ParamInfo paramInfo = new ParamInfo() ;paramInfo.setId(param.getParamId());paramInfo.setParamSign(param.getParamSign());paramInfo.setCreateTime(new Date());paramInfo.setUpdateTime(new Date());ParamInfoService paramInfoService = (ParamInfoService)SpringContextUtil.getBean("paramInfoService") ;paramInfoService.insertParam(paramInfo);}@Overridepublic void executeRemoveRule(QueryParam param) {LOGGER.info("參數數據:"+param.getParamId()+";"+param.getParamSign());ParamInfoService paramInfoService = (ParamInfoService)SpringContextUtil.getBean("paramInfoService") ;ParamInfo paramInfo = paramInfoService.selectById(param.getParamId());if (paramInfo != null){paramInfoService.removeById(param.getParamId()) ;}} }

規則調用接口

@RestController @RequestMapping("/rule") public class RuleController {@Resourceprivate KieSession kieSession;@Resourceprivate RuleEngineService ruleEngineService ;@RequestMapping("/param")public void param (){QueryParam queryParam1 = new QueryParam() ;queryParam1.setParamId("1");queryParam1.setParamSign("+");QueryParam queryParam2 = new QueryParam() ;queryParam2.setParamId("2");queryParam2.setParamSign("-");// 入參kieSession.insert(queryParam1) ;kieSession.insert(queryParam2) ;kieSession.insert(this.ruleEngineService) ;// 返參RuleResult resultParam = new RuleResult() ;kieSession.insert(resultParam) ;kieSession.fireAllRules() ;} }

由于水平有限，本博客難免有不足，懇請各位大佬不吝賜教！

總結

以上是生活随笔為你收集整理的Drools规则引擎讲解的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。