Drools Fusion(CEP)定义及使用方法讲解

发布时间: 2019-07-13 19:31:48 来源: 互联网 作者: 双斜杠少年 栏目: Java 点击: 280

今天小编就为大家分享一篇关于Drools Fusion(CEP)定义及使用方法讲解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧

从 Drools 统一行为建模平台的视野看，Drools Fusion 是负责启用事件处理行 为的一个模块。

定义

支持复杂事件处理，是比简单的理解事件是什么要更多得多，cep场景具有几个共同而明显的特点：

http://www.cppcns.com
  • 通常需要处理巨量的事件，但是只有少部分事件是真正关心的。
  • 事件通常是不变的，因为它们是状态改变的一条记录。
  • 通常有关事件的规则和查询必须是运行在被动模式(reactive modes)，即，对事件模式(patterns)的检测作出反应。
  • 通常在相关的事件之间有强烈的时间关系。
  • 个别事件通常是不重要的。系统关心相关事件的模式(patterns)和它们的关系
  • 通常，要求系统执行组合和聚合的事件。

用fusion,要把插入drools的数据声明为事件。

drools处理数据有两种方式，云模式和流模式，默认是云模式，用fusion,需要设置为流模式。流模式，插入的数据叫事件，有时间顺序，云模式没有，

流(stream)支持

大部分 CEP 用例必须处理事件流(stream)。

流的特性：

  • 在流中的事件通过时间戳被排序。
  • 事件的数量(volumes)总是很高的。
  • 原子事件自己是很少有用的。通常根据多个事件之间的相关性或流或其他来源提取含义。
  • 流可以是相似的，即包含单一类型的事件;或者是异类的，即包含多种类型的事件。

声明流模式

在kmodule.xml 中添加配置 eventProcessingMode=“stream” 为流模式

  1. <kbase name="fusionAge" eventProcessingMode="stream" packages="com.us.fusion">
  2.         <ksession name="fusionAgeKS" type="stateful"/>
  3. </kbase>

事件声明

用fusion,要把插入drools的数据声明为事件，声明事件使用@role标签

@role

把@role元数据标签指派给该事实类行

例如：

Person 为java bean 也就是一个事实类型

  1. declare Person
  2.       @role(event)
  3. end

Person 的属性如下：

  1. public class Person {
  2.       private String name;
  3.       private Integer age;
  4.       private String like;
  5.       private String sex;
  6.       private String desc;
  7.       private String address;
  8.       private Date createTime;
  9.       // getter setter 省略

@timestamp

每一个事件都要有一个关联的时间戳指派给它。默认时，一个给定事件的时间戳是在事件被插入到工作内存时，从 Session Clock 读取，并且分配给该事件。有些时候，事件用时间戳作为它自己的一个属性。在这情况下，用户可以用@timestamp 标记用户属性为时间戳

例如：用Person的 createTime 属性为时间戳

  1. declare Person
  2.       @role(event)
  3.       @timestamp( createTime )
  4. end

@expires

重要:这个标签只有引擎运行在流(STREAM)模式之下才会被考虑.

该标签显示定义 一个事件在什么时候应该到期，事件到期,事件可能不再匹配和激活任何规则时。

使用如下

    @expires( 1h35m )

在person 例子中假设过期时间为20S

  1. declare Person
  2.       @role(event)
  3.       @timestamp( createTime )
  4.       @expires(20s)
  5. end

滑动时间窗口

滑动时间窗口允许用户编写规则，其将仅匹配在最近的 X 时间单元内发生的事件

  1. rule "boy"
  2.        when
  3.               $p : Person(age < 25) over window:time(3s)
  4.        then
  5.               $p.setDesc("少年");
  6.               retract($p);
  7. end

例如：只匹配最近3秒内，vlCgOmw年龄小于25的人

调用代码如下：

  1. package com.us.fusion;
  2. import com.us.model.Person;
  3. import org.kie.api.KieServices;
  4. import org.kie.api.runtime.KieContainer;
  5. import org.kie.api.runtime.KieSession;
  6. import java.util.Date;
  7. /**
  8.      * Created by yangyibo on 17/1/3.
  9.      * @author yangyibo
  10.      */
  11. public class Application {
  12.       private static KieSession getSession() {
  13.         KieServices ks = KieServices.Factory.get();
  14.         KieContainer kc = ks.getKieClasspathContainer();
  15.         return kc.newKieSession("fusionAgeKS");
  16.       }
  17.       public static void run() {
  18.         KieSession ks = getSession();
  19.         Person p1 = new Person("白展堂", 2,new Date());
  20.         Person p2 = new Person("佟湘玉", 7,new Date());
  21.         try {
  22.               Thread.sleep(4000);
  23.         } catch (InterruptedException e) {
  24.               System.out.println(e);
  25.         }
  26.         Person p3 = new Person("李大嘴", 16,new Date());
  27.         ks.insert(p1);
  28.         ks.insert(p2);
  29.         ks.insert(p3);
  30.         int count = ks.fireAllRules();
  31.         System.out.println("总执行了" + count + "条规则------------------------------");
  32. //    ks.dispose();
  33.       }
  34.       public static void main(String[] args) {
  35.         run();
  36.       }
  37. }

规则代码如下：

  1. package com.us.fusion7
  2. import com.us.model.Person
  3. function void printName(String streamName,String name,int age,String desc) {
  4.               System.out.println("streamName:"+streamName+" name:"+name+" age:"+age+" desc:"+vlCgOmw desc);
  5.         }
  6. declare Person
  7.       @role(event)
  8.       @timestamp( createTime )
  9.       @expires(20s)
  10. end
  11. rule "boy"
  12.        when
  13.               $p : Person(age > 0) over window:time(3s)
  14.        then
  15.               $p.setDesc("少年");
  16.               retract($p);
  17.               printName("boy",$p.getName(),$p.getAge(),$p.getDesc());
  18. end

由于Thread.sleep(4000);所以最近3秒内只有李大嘴一条记录所以

结果如下：

streamName:boy  name:李大嘴 age:16 desc:少年
总执行了1条规则------------------------------

范例2 10S 内的平均年龄

滑动长度窗口

和滑动时间窗口很类似，其将仅匹配最近几次发生的事件，用法如图，只匹配最近1次发生的事件。

  1. rule "old"
  2.        when
  3.               $p : Person(age > 49) over window:length(2)
  4.        then
  5.               $p.setDesc("老年");
  6.               retract($p);
  7. end

例如年领大于49岁的最近两条记录

调用代码：

  1. public class Application {
  2.       private static KieSession getSession() {
  3.         KieServices ks = KieServices.Factory.get();
  4.         KieContainer kc = ks.getKieClasspathContainer();
  5.         return kc.newKieSession("fusionAgeKS");
  6.       }
  7.       public static void run() {
  8.         KieSession ks = getSession();
  9.         Person p1 = new Person("白展堂", 52,new Date());
  10.         Person p2 = new Person("佟湘玉", 57,new Date());
  11.         try {
  12.               Thread.sleep(4000);
  13.         } catch (InterruptedException e) {
  14.               System.out.println(e);
  15.         }
  16.         Person p3 = new Person("李大嘴", 56,new Date());
  17.         ks.insert(p1);
  18.         ks.insert(p2);
  19.         ks.insert(p3);
  20.         int count = ks.fireAllRules();
  21.         System.out.println("总执行了" + count + "条规则------------------------------");
  22.       http://www.cppcns.com  ks.dispose();
  23.       }
  24.       public static void main(String[] args) {
  25.         run();
  26.       }
  27. }

规则代码

  1. package com.us.fusion7
  2. import com.us.model.Person
  3. function void printName(String streamName,String name,int age,String desc) {
  4.               System.out.println("streamName:"+streamName+" name:"+name+" age:"+age+" desc:"+ desc);
  5.         }
  6. declare Person
  7.       @role(event)
  8.       @timestamp( createTime )
  9.       @expires(20s)
  10. end
  11. rule "old"
  12.        when
  13.               $p : Person(age > 49) over window:length(2)
  14.        then
  15.               $p.setDesc("老年");
  16.               retract($p);
  17.               printName("boy",$p.getName(),$p.getAge(),$p.getDesc());
  18. end

只匹配符合规则的最近的两条记录，所以舍弃“白展堂记录”

执行结果

streamName:boy  name:李大嘴 age:56 desc:老年
streamName:boy  name:佟湘玉 age:57 desc:老年
总执行了2条规则------------------------------

本文所有测试例子的pom 依赖

  1.         <dependency>
  2.               <groupId>org.kie</groupId>
  3.               <artifactId>kie-api</artifactId>
  4.               <version>6.5.0.Final</version>
  5.         </dependency>
  6.         <dependency>
  7.               <groupId>org.drools</groupId>
  8.               <artifactId>drools-core</artifactId>
  9.               <version>6.5.0.Final</version>
  10.         </dependency>
  11.         <dependency>
  12.               <groupId>org.drools</groupId>
  13.               <artifactId>drools-compiler</artifactId>
  14.               <version>6.5.0.Final</version>
  15.         </dependency>
  16.         <dependency>
  17.               <groupId>org.drools</groupId>
  18.               <artifactId>drools-decisiontables</artifactId>
  19.               <version>6.5.0.Final</version>
  20.         </dependency>
  21.         <dependency>
  22.               <groupId>org.drools</groupId>
  23.               <artifactId>drools-templates</artifactId>
  24.               <version>6.5.0.Final</version>
  25.         </dependency>

本文所有测试例子的kmodule.xml 配置

  1.      <kbase name="fusionAge" eventProcessingMode="stream" packages="com.us.fusion">
  2.         <ksession name="fusionAgeKS" type="stateful"/>
  3.      </kbase>
www.cppcns.com

其他关键字： After, Before, During, Meet 等关键字 都是用于比较两个事件的发生时间顺序，用法待以后再叙

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我们的支持。如果你想了解更多相关内容请查看下面相关链接