Drools（8）：WorkBench使用

<dependency>
    <groupId>org.droolsgroupId>
    <artifactId>drools-compilerartifactId>
    <version>7.10.0.Finalversion>
dependency>
<dependency>
    <groupId>junitgroupId>
    <artifactId>junitartifactId>
    <version>4.12version>
dependency>

第⼆步：在项目中创建⼀个数据对象Order，需要和WorkBench中创建的Order包名、类名完全相 同，属性也需要对应，我这边是com.xiong.order_rules.fact

package com.xiong.order_rules.fact;
 
public class Order {
    private Integer amout;//订单原价⾦额
    private Integer score;//积分
 
    @Override
    public String toString() {
        return "Order{" +
                "amout=" + amout +
                ", score=" + score +
                '}';
    }
 
    public Integer getAmout() {
        return amout;
    }
 
    public void setAmout(Integer amout) {
        this.amout = amout;
    }
 
    public Integer getScore() {
        return score;
    }
 
    public void setScore(Integer score) {
        this.score = score;
    }
}

第三步：编写单元测试，远程加载maven仓库中的jar包最终完成规则调⽤

package com.xiongpeng.test;
 
import com.xiong.order_rules.fact.Order;
import org.drools.core.io.impl.UrlResource;
import org.junit.Test;
import org.kie.api.KieServices;
import org.kie.api.builder.KieModule;
import org.kie.api.builder.KieRepository;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
 
import java.io.InputStream;
 
public class TestWorkBench {
 
    @Test
    public void test1() throws Exception {
        //通过此URL可以访问到maven仓库中的jar包
        // URL地址构成：http://ip地址:Tomcat端⼝号/WorkBench⼯程名/maven2/坐标/版 本号/xxx.jar
        String url = "http://localhost:8080/kie-drools-wb/maven2/com/xiong/order-rules/1.0.0/order-rules-1.0.0.jar";
        KieServices kieServices = KieServices.Factory.get();
        // 通过Resource资源对象加载jar包
        UrlResource resource = (UrlResource) kieServices.getResources().newUrlResource(url);
        // 通过Workbench提供的服务来访问maven仓库中的jar包资源，需要先进⾏Workbench 的认证
        resource.setUsername("kie");
        resource.setPassword("kie");
        resource.setBasicAuthentication("enabled");
        //将资源转换为输⼊流，通过此输⼊流可以读取jar包数据
        InputStream inputStream = resource.getInputStream();
        //创建仓库对象，仓库对象中保存Drools的规则信息
        KieRepository repository = kieServices.getRepository();
        //通过输⼊流读取maven仓库中的jar包数据，包装成KieModule模块添加到仓库中
        KieModule kieModule = repository.addKieModule(kieServices.getResources().newInputStreamResource(inputStream));
        //基于KieModule模块创建容器对象，从容器中可以获取session会话
        KieContainer kieContainer = kieServices.newKieContainer(kieModule.getReleaseId());
        KieSession session = kieContainer.newKieSession();
        Order order = new Order();
        order.setAmout(500);
        session.insert(order);
        session.fireAllRules();
        session.dispose();
 
    }
}

执⾏单元测试可以发现控制台已经输出了相关内容。通过WorkBench修改规则输出内容并发布，再次执⾏单元测试可以发现控制台输出的内容也发⽣了变化。

通过上⾯的案例可以发现，我们在IEDA中开发的项⽬中并没有编写规则⽂件，规则⽂件是我们通过WorkBench开发并安装部署到maven仓库中，我们⾃⼰开发的项⽬只需要远程加载maven仓库中的jar 包就可以完成规则的调⽤。这种开发⽅式的好处是我们的应⽤可以和业务规则完全分离，同时通过WorkBench修改规则后我们的应⽤不需要任何修改就可以加载到最新的规则从⽽实现规则的动态变更。