正文 

当前位置： 首页 > 技术 > java教程

35activiti整合规则引擎drools(代码片段)

author author     2023-03-20     302

关键词：

喜欢关注公众号： java乐园

日常生活是由规则驱动的。红灯停绿灯行，这是我们的交通规则；我们站着往上跳，最终还是要落下来，这是地球的引力规则。规则在生活中无处不在。软件开发中我们也需要规则，满足什么规则应该进入什么分支。如果做过风控系统，就知道风控系统里存在非常多的规则（比如：age < 16 || age > 50 -> REJECT ）。最便捷的实现就是用 if-else 来写，但是随着规则的增加以及需求的变动，代码将变得越来越难阅读和理解，如果再去修改这些代码，然后测试不够充分的话，将产生严重的生产事故。这时候就要引入Drools等规则引擎了。Drools就是为了解决业务代码和业务规则分离的引擎。
? ? ? ? 要使用Drools规则引擎，需要先安装安装JBoss Drools Support插件，这里就不多说怎么安装安装JBoss Drools Support插件。下载地址如下：

https://download.jboss.org/drools/release/7.3.0.Final/droolsjbpm-tools-distribution-7.3.0.Final.zip

1、?新建项目sc-activiti-drools，对应的pom.xml文件如下

<?xml?version="1.0"?encoding="UTF-8"?>

<project?xmlns="http://maven.apache.org/POM/4.0.0"?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0?http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>

        <groupId>com.sc</groupId>
        <artifactId>sc-activiti-drools</artifactId>
        <version>0.0.1-SNAPSHOT</version>

        <name>sc-activiti-drools</name>
        <!--?FIXME?change?it?to?the?project‘s?website?-->
        <url>http://www.example.com</url>

        <properties>
                <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
                <maven.compiler.source>1.8</maven.compiler.source>
                <maven.compiler.target>1.8</maven.compiler.target>
        </properties>

        <parent>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>2.0.4.RELEASE</version>
        </parent>

        <dependencyManagement>
                <dependencies>
                        <dependency>
                                <groupId>org.springframework.cloud</groupId>
                                <artifactId>spring-cloud-dependencies</artifactId>
                                <version>Finchley.RELEASE</version>
                                <type>pom</type>
                                <scope>import</scope>
                        </dependency>

                </dependencies>
        </dependencyManagement>

        <dependencies>
                <dependency>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-web</artifactId>
                </dependency>

                <dependency>
                        <groupId>org.activiti</groupId>
                        <artifactId>activiti-engine</artifactId>
                        <version>6.0.0</version>
                </dependency>

                <dependency>
                        <groupId>org.activiti</groupId>
                        <artifactId>activiti-spring</artifactId>
                        <version>6.0.0</version>
                </dependency>
                <dependency>
                        <groupId>mysql</groupId>
                        <artifactId>mysql-connector-java</artifactId>
                        <scope>runtime</scope>
                </dependency>

                <dependency>
                        <groupId>org.drools</groupId>
                        <artifactId>drools-core</artifactId>
                        <version>7.0.0.Final</version>
                </dependency>

                <dependency>
                        <groupId>org.drools</groupId>
                        <artifactId>drools-compiler</artifactId>
                        <version>7.0.0.Final</version>
                </dependency>

                <dependency>
                        <groupId>org.drools</groupId>
                        <artifactId>knowledge-api</artifactId>
                        <version>6.5.0.Final</version>
                </dependency>

        </dependencies>

        <build>
                <pluginManagement><!--?lock?down?plugins?versions?to?avoid?using?Maven?
                                defaults?(may?be?moved?to?parent?pom)?-->
                        <plugins>
                                <plugin>
                                        <artifactId>maven-clean-plugin</artifactId>
                                        <version>3.0.0</version>
                                </plugin>
                                <!--?see?http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging?-->
                                <plugin>
                                        <artifactId>maven-resources-plugin</artifactId>
                                        <version>3.0.2</version>
                                </plugin>
                                <plugin>
                                        <artifactId>maven-compiler-plugin</artifactId>
                                        <version>3.7.0</version>
                                </plugin>
                                <plugin>
                                        <artifactId>maven-surefire-plugin</artifactId>
                                        <version>2.20.1</version>
                                </plugin>
                                <plugin>
                                        <artifactId>maven-jar-plugin</artifactId>
                                        <version>3.0.2</version>
                                </plugin>
                                <plugin>
                                        <artifactId>maven-install-plugin</artifactId>
                                        <version>2.5.2</version>
                                </plugin>
                                <plugin>
                                        <artifactId>maven-deploy-plugin</artifactId>
                                        <version>2.8.2</version>
                                </plugin>
                        </plugins>
                </pluginManagement>
        </build>
</project>

2、新建spring配置文件application.yml

spring:
    datasource:
        driver-class-name:?com.mysql.jdbc.Driver
        url:?jdbc:mysql://127.0.0.1:3306/sc?characterEncoding=utf8&useSSL=true
        username:?root
        password:?root
    activiti:
        check-process-definitions:?false?#自动部署验证设置:true-开启（默认）、false-关闭
    jpa:
        properties:
            hibernate:
                hbm2ddl:
                    auto:?update
    show-sql:?true

server:
    port:?8081
    context-path:?/
    session:
        timeout:?10
    tomcat:
        uri-encoding:?UTF-8

3、新建activiti对应的配置文件activiti.cfg.xml

<?xml?version="1.0"?encoding="UTF-8"?>

<beans?xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.springframework.org/schema/beans???http://www.springframework.org/schema/beans/spring-beans.xsd">

        <bean?id="dataSource"?class="org.springframework.jdbc.datasource.SimpleDriverDataSource">
                <property?name="driverClass"?value="com.mysql.jdbc.Driver"?/>
                <property?name="url"?value="jdbc:mysql://localhost:3306/act?useUnicode=true&amp;characterEncoding=UTF-8"?/>
                <property?name="username"?value="root"?/>
                <property?name="password"?value="root"?/>
        </bean>

        <bean?id="transactionManager"?class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
                <property?name="dataSource"?ref="dataSource"?/>
        </bean>

        <bean?id="processEngineConfiguration"?class="org.activiti.spring.SpringProcessEngineConfiguration">
                <property?name="dataSource"?ref="dataSource"?/>
                <property?name="transactionManager"?ref="transactionManager"?/>
                <property?name="databaseSchemaUpdate"?value="true"?/>
                <property?name="customPostDeployers">
                        <list>?
                                    <bean?class="org.activiti.engine.impl.rules.RulesDeployer"?/>
                        </list>?
                </property>
                <!--?
                        <property?name="deploymentResources"?value="classpath*:/bpmn/*.bpmn"?/>??
                 -->
        </bean>

        <bean?id="processEngine"?class="org.activiti.spring.ProcessEngineFactoryBean">
                <property?name="processEngineConfiguration"?ref="processEngineConfiguration"?/>
        </bean>

        <bean?id="repositoryService"?factory-bean="processEngine"?factory-method="getRepositoryService"?/>
        <bean?id="runtimeService"?factory-bean="processEngine"?factory-method="getRuntimeService"?/>
        <bean?id="taskService"?factory-bean="processEngine"?factory-method="getTaskService"?/>
        <bean?id="historyService"?factory-bean="processEngine"?factory-method="getHistoryService"?/>
        <bean?id="managementService"?factory-bean="processEngine"?factory-method="getManagementService"?/>

</beans>

4、新建请假流程对应的bpmn文件如下

<?xml?version="1.0"?encoding="UTF-8"?>
<definitions?xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"?xmlns:xsd="http://www.w3.org/2001/XMLSchema"
        xmlns:activiti="http://activiti.org/bpmn"?xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
        xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"?xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"
        typeLanguage="http://www.w3.org/2001/XMLSchema"?expressionLanguage="http://www.w3.org/1999/XPath"
        targetNamespace="http://www.activiti.org/test">

        <process?id="leave"?name="请假审批"?isExecutable="true">
                <startEvent?id="startevent1"?name="Start"></startEvent>
                <endEvent?id="endevent1"?name="End"></endEvent>
                <userTask?id="usertask1"?name="部门经理审批"></userTask>
                <busine***uleTask?id="busine***uletask1"?name="天数判断"?activiti:ruleVariablesInput="$leave"?activiti:rules="leave1,leave2"?activiti:resultVariable="reason"></busine***uleTask>
                <serviceTask?id="servicetask1"?name="获取变量"?activiti:class="sc.ad.service.DroolsService"></serviceTask>
                <userTask?id="usertask2"?name="HR审批"></userTask>
                <sequenceFlow?id="flow1"?sourceRef="startevent1"?targetRef="usertask1"></sequenceFlow>
                <sequenceFlow?id="flow2"?sourceRef="usertask1"?targetRef="busine***uletask1"></sequenceFlow>
                <sequenceFlow?id="flow3"?sourceRef="busine***uletask1"?targetRef="servicetask1"></sequenceFlow>
                <userTask?id="usertask3"?name="总经理审批"></userTask>
                <sequenceFlow?id="flow4"?sourceRef="servicetask1"?targetRef="usertask3">
                        <conditionExpression?xsi:type="tFormalExpression"><![CDATA[$reason[0].total?>=?10]]></conditionExpression>
                </sequenceFlow>
                <sequenceFlow?id="flow5"?sourceRef="servicetask1"?targetRef="usertask2">
                        <conditionExpression?xsi:type="tFormalExpression"><![CDATA[$reason[0].total?<?10]]></conditionExpression>
                </sequenceFlow>
                <sequenceFlow?id="flow6"?sourceRef="usertask3"?targetRef="usertask2"></sequenceFlow>
                <sequenceFlow?id="flow7"?sourceRef="usertask2"?targetRef="endevent1"></sequenceFlow>
        </process>
</definitions>

bpmn文件对应的图如下

技术图片

5、新建规则文件leave.drl

package?sc.ad;

import?sc.ad.model.Leave;

rule?"leave1"
        when
                u?:?Leave(day?<?3);
        then
                u.setTotal(u.getDay()?+?2);
end

rule?"leave2"
        when
                u?:?Leave(day?>=?3);
        then
                u.setTotal(u.getDay()?+?5);
end

对应的图如下
技术图片
6、新建springboot启动类文件

package?sc.ad;

import?org.springframework.boot.SpringApplication;
import?org.springframework.boot.autoconfigure.SpringBootApplication;
import?org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("activiti.cfg.xml")
public?class?ActivitiDroolsApp?
        public?static?void?main(String[]?args)
        
                SpringApplication.run(ActivitiDroolsApp.class,?args);

7、新建一个controller，用来发起请假请求

package?sc.ad.controller;

import?java.util.HashMap;
import?java.util.List;
import?java.util.Map;

import?org.activiti.engine.RepositoryService;
import?org.activiti.engine.RuntimeService;
import?org.activiti.engine.TaskService;
import?org.activiti.engine.repository.Deployment;
import?org.activiti.engine.repository.DeploymentBuilder;
import?org.activiti.engine.repository.ProcessDefinition;
import?org.activiti.engine.runtime.ProcessInstance;
import?org.activiti.engine.task.Task;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.web.bind.annotation.RequestMapping;
import?org.springframework.web.bind.annotation.RestController;

import?sc.ad.model.Leave;

@RestController
public?class?ADController?

        @Autowired
        private?RepositoryService?repositoryService;

        @Autowired
        private?RuntimeService?runtimeService;

        @Autowired
        private?TaskService?taskService;

//????@RequestMapping("/ad")
//????public?void?ad()?
//
//????????//?根据bpmn文件部署流程
//????????Deployment?deployment?=?repositoryService.createDeployment()
//????????????????.addClasspathResource("holiday.bpmn").deploy();
//????????//?获取流程定义
//????????ProcessDefinition?processDefinition?=?repositoryService
//????????????????.createProcessDefinitionQuery()
//????????????????.deploymentId(deployment.getId()).singleResult();
//????????//?启动流程定义，返回流程实例
//????????ProcessInstance?pi?=?runtimeService
//????????????????.startProcessInstanceById(processDefinition.getId());
//????????String?processId?=?pi.getId();
//????????System.out.println("流程创建成功，当前流程实例ID："?+?processId);
//
//????????Task?task?=?taskService.createTaskQuery().processInstanceId(processId)
//????????????????.singleResult();
//????????System.out.println("第一次执行前，任务名称："?+?task.getName());
//????????taskService.complete(task.getId());
//
//????????task?=?taskService.createTaskQuery().processInstanceId(processId)
//????????????????.singleResult();
//????????System.out.println("第二次执行前，任务名称："?+?task.getName());
//????????taskService.complete(task.getId());
//
//????????task?=?taskService.createTaskQuery().processInstanceId(processId)
//????????????????.singleResult();
//????????System.out.println("task为null，任务执行完毕："?+?task);
//????

        @RequestMapping("/drl")
        public?void?drl()?
                /**
                 *?注意这里：必须要把drl文件一起deploy
                 */
                DeploymentBuilder?deploy?=?repositoryService.createDeployment();
                deploy.addClasspathResource("leave.bpmn").addClasspathResource("leave.drl");
                deploy.deploy();
                ProcessInstance?pi?=?runtimeService.startProcessInstanceByKey("leave");
                Map<String,?Object>?vars?=?new?HashMap<String,?Object>();??
                vars.put("leave",?new?Leave("白展堂",?12));
                /**
                 *?当前任务
                 */
                List<Task>?tasks?=?taskService.createTaskQuery().processInstanceId(pi.getId()).list();
                for(Task?task?:?tasks)
                
                        System.out.println(task.getId()?+?"?,?"?+?task.getName());
                        taskService.complete(task.getId(),?vars);
                
                /**
                 *?下一步任务
                 */
                tasks?=?taskService.createTaskQuery().processInstanceId(pi.getId()).list();
                for(Task?task?:?tasks)
                
                        System.out.println(task.getId()?+?"?,?"?+?task.getName());

8、启动并验证规则是否生效
从日志中看启动成功
技术图片
访问http://127.0.0.1:8081/drl后，再次查看日志：
技术图片
把修改controller的如下代码
? ? ? ? vars.put("leave", new Leave("白展堂", 12));
改成
? ?? vars.put("leave", new Leave("乔峰", 2));

技术图片

可以看到规则文件的规则已经生效：
技术图片

springboot2整合drools规则引擎，实现高效的业务规则

本文源码：GitHub·点这里||GitEE·点这里一、Drools引擎简介1、基础简介Drools是一个基于java的规则引擎，开源的，可以将复杂多变的规则从硬编码中解放出来，以规则脚本的形式存放在文件中，使得规则的变更不需要修正代码重启... 查看详情

drools整合springboot整合drools测试例子--个税计算器规则(代码片段)

规则引擎，主要作用，就是将规则与java代码分离，可通过修改规则实时生效。让非java程序员，只要熟悉业务，也可以写规则。规则引擎主要用在一些，打折、风控前置、后置、结算等模块地方。新建一个droolsdemo的maven工程。pom.... 查看详情

springboot+drools规则引擎整合

目的官方的Drools范例大都是基于纯Java项目或Maven项目，而基于SpringBoot项目的很少。本文介绍如何在SpringBoot项目上加上Drools规则引擎。POM依赖POM文件如下：<projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-i... 查看详情

java规则引擎drools急速入门

...则引擎简介​​​​2.DroolsAPI开发步骤​​​​3.SpringBoot整合Drools案例​​​​4.Drools基础语法​​​​5.Drools条件语法部分​​​​6.Drools结果操作部分​​​​7.Drools内置属性部分​​​​8.Drools高级语法部分​​1.Drools规则引... 查看详情

drools规则引擎一文读懂(代码片段)

目录一、Drools简介电商平台的促销活动规则引擎Drools简介二、Drools快速入门 电商平台促销积分规则开发实现三、Drools规则引擎构成及其核心类Drools规则引擎构成Drools规则引擎概念四、Drools基础语法规则文件构成 规则体语法结... 查看详情

drools规则引擎初探(代码片段)

...么Drools是为Java量身定制的基于Charles Forgy的RETE算法的规则引擎的实现。具有了OO接口的RETE,使得商业规则有了更自然的表达。Rule是什么呢？ 一条规则是对商业知识的编码。一条规则有 attributes ，一个 LeftHandSide&... 查看详情

drools规则引擎环境搭建(代码片段)

一、关于drools规则引擎前面写过一篇Drools规则引擎相关的文章，这篇文章主要记录一下规则引擎的环境搭建和简单示例。不熟悉drools的朋友可以看看这篇文章：自己写个Drools文件语法检查工具——栈的应用之编译器检测语法错误... 查看详情

规则引擎drools的使用(代码片段)

引入maven<dependency><groupId>org.drools</groupId><artifactId>drools-templates</artifactId><version>7.14.0.Final</version></dependency><dependency>& 查看详情

java规则引擎--drools

Drools是一个基于java的规则引擎，开源的，可以将复杂多变的规则从硬编码中解放出来，以规则脚本的形式存放在文件中，使得规则的变更不需要修正代码重启机器就可以立即在线上环境生效。 本文所使用的demo已上传 http... 查看详情

疯狂讲义activiti6.x工作流进阶与项目实战，activiti整合drools

01Activiti介绍与搭建开发环境 02运行官方例子03编写第一个Activiti程序 04流程引擎配置与服务组件05Activiti数据库介绍06API（1）Activiti数据查询07API（2）流程文件部署08API（3）流程定义09API（4）任务操作10API（5）任务参数与附... 查看详情

drools规则引擎入门指南(代码片段)

本篇博客主要讲解Drools常用的属性以及函数属性首先我们在resourcesules文件夹下创建一个Property.drl，还有一个DroolsApplicationPropertyTests1.salience优先级salience属性的值默认为0，它的值越大执行的优先级就越高,看如下代码在执行的时候... 查看详情

规则引擎drools示例：个人所得税计算器信用卡申请保险产品准入规则(代码片段)

...一、Drools实战1.1个人所得税计算器1.1.1名词解释1.1.2计算规则1.1.3实现步骤1.2信用卡申请1.2.1计算规则1.2.2实现步骤1.3保险产品准入规则1.3.1决策表1.3.2规则介绍1.3.3实现步骤一、Drools实战1.1个人所得税计算器本小节我们需要通过Drool... 查看详情

drools只执行一个规则或者执行完当前规则之后不再执行其他规则（转）(代码片段)

...提高系统的可维护性和维护成本　　　　3、方便系统的整合　　　　4 查看详情

什么时候使用规则引擎drools

参考技术A规则引擎一般是一下情况使用1.为提高效率，管理流程必须自动化，即使现代商业规则异常复杂。2.市场要求业务规则经常变化，IT系统必须依据业务规则的变化快速、低成本的更新。3.为了快速、低成本的更新，业务人... 查看详情

规则引擎drools在贷后催收业务中的应用

...gXiang在日常业务开发工作中我们经常会遇到一些根据业务规则做决策的场景。为了让开发人员从大量的规则代码的开发维护中释放出来，把规则的维护和生成交由业务人员，为了达到这种目的通常我们会使用规则引擎来帮助我们... 查看详情

drools规则引擎中易混淆语法分析_循环触发导致死循环分析(代码片段)

...开发与测试阶段解决了，未波及到prod。首先看这样两条规则/***规则1_set默认利率*/rule"rate_default"no-looptruewhen$request:AmountRateRequest(calculateEnum==CalculateEnum.INTEREST||calculateEnum==CalculateEnu 查看详情

数据驱动规则引擎 - Drools

】数据驱动规则引擎-Drools【英文标题】：DataDrivenRulesEngine-Drools【发布时间】：2013-08-2322:51:57【问题描述】：我一直在评估Drools作为我们的业务Web应用程序中使用的规则引擎。我的用例是一个订单管理应用程序。规则如下：-如果... 查看详情

drools规则引擎因为内存泄露导致的内存溢出

...一下drools：在很多行业应用中比如银行、保险领域，业务规则往往非常复杂，并且规则处于不断更新变化中，而现有很多系统做法基本上都是将业务规则绑定在程序代码中。主要存在的问题有以下几个方面：1）当业务规则变更... 查看详情