个人中心
gpt4 book ai didi

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

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 29 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Drools Fusion(CEP)定义及使用方法讲解由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

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

定义 。

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

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

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

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

流(stream)支持 。

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

流的特性:

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

声明流模式 。

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

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

事件声明 。

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

@role 。

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

例如:

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

declare Person  @role(event)end

Person 的属性如下:

public class Person {  private String name;  private Integer age;  private String like;  private String sex;  private String desc;  private String address;  private Date createTime;  // getter setter 省略

@timestamp 。

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

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

declare Person  @role(event)  @timestamp( createTime )end

@expires 。

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

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

使用如下 。

    @expires( 1h35m ) 。

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

declare Person  @role(event)  @timestamp( createTime )  @expires(20s)end

滑动时间窗口 。

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

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

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

调用代码如下:

package com.us.fusion;import com.us.model.Person;import org.kie.api.KieServices;import org.kie.api.runtime.KieContainer;import org.kie.api.runtime.KieSession;import java.util.Date;/** * Created by yangyibo on 17/1/3. * @author yangyibo */public class Application {  private static KieSession getSession() {    KieServices ks = KieServices.Factory.get();    KieContainer kc = ks.getKieClasspathContainer();    return kc.newKieSession("fusionAgeKS");  }  public static void run() {    KieSession ks = getSession();    Person p1 = new Person("白展堂", 2,new Date());    Person p2 = new Person("佟湘玉", 7,new Date());    try {      Thread.sleep(4000);    } catch (InterruptedException e) {      System.out.println(e);    }    Person p3 = new Person("李大嘴", 16,new Date());    ks.insert(p1);    ks.insert(p2);    ks.insert(p3);    int count = ks.fireAllRules();    System.out.println("总执行了" + count + "条规则------------------------------");//    ks.dispose();  }  public static void main(String[] args) {    run();  }}

规则代码如下:

package com.us.fusion7import com.us.model.Personfunction void printName(String streamName,String name,int age,String desc) {      System.out.println("streamName:"+streamName+" name:"+name+" age:"+age+" desc:"+ desc);    }declare Person  @role(event)  @timestamp( createTime )  @expires(20s)endrule "boy"   when      $p : Person(age > 0) over window:time(3s)   then      $p.setDesc("少年");      retract($p);      printName("boy",$p.getName(),$p.getAge(),$p.getDesc());end

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

结果如下:

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

范例2 10S 内的平均年龄 。

滑动长度窗口 。

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

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

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

调用代码:

public class Application {  private static KieSession getSession() {    KieServices ks = KieServices.Factory.get();    KieContainer kc = ks.getKieClasspathContainer();    return kc.newKieSession("fusionAgeKS");  }  public static void run() {    KieSession ks = getSession();    Person p1 = new Person("白展堂", 52,new Date());    Person p2 = new Person("佟湘玉", 57,new Date());    try {      Thread.sleep(4000);    } catch (InterruptedException e) {      System.out.println(e);    }    Person p3 = new Person("李大嘴", 56,new Date());    ks.insert(p1);    ks.insert(p2);    ks.insert(p3);    int count = ks.fireAllRules();    System.out.println("总执行了" + count + "条规则------------------------------");    ks.dispose();  }  public static void main(String[] args) {    run();  }}

规则代码 。

package com.us.fusion7import com.us.model.Personfunction void printName(String streamName,String name,int age,String desc) {      System.out.println("streamName:"+streamName+" name:"+name+" age:"+age+" desc:"+ desc);    }declare Person  @role(event)  @timestamp( createTime )  @expires(20s)endrule "old"   when      $p : Person(age > 49) over window:length(2)   then      $p.setDesc("老年");      retract($p);      printName("boy",$p.getName(),$p.getAge(),$p.getDesc());end

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

执行结果 。

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

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

    <dependency>      <groupId>org.kie</groupId>      <artifactId>kie-api</artifactId>      <version>6.5.0.Final</version>    </dependency>    <dependency>      <groupId>org.drools</groupId>      <artifactId>drools-core</artifactId>      <version>6.5.0.Final</version>    </dependency>    <dependency>      <groupId>org.drools</groupId>      <artifactId>drools-compiler</artifactId>      <version>6.5.0.Final</version>    </dependency>    <dependency>      <groupId>org.drools</groupId>      <artifactId>drools-decisiontables</artifactId>      <version>6.5.0.Final</version>    </dependency>    <dependency>      <groupId>org.drools</groupId>      <artifactId>drools-templates</artifactId>      <version>6.5.0.Final</version>    </dependency>

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

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

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

总结 。

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我的支持.

最后此篇关于Drools Fusion(CEP)定义及使用方法讲解的文章就讲到这里了,如果你想了解更多关于Drools Fusion(CEP)定义及使用方法讲解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

29 4 0
文章推荐： Linux中使用ln命令在文件之间建立连接的用法讲解
文章推荐： SpringBoot与Quartz集成实现分布式定时任务集群的代码实例
文章推荐： 解决dubbo错误ip及ip乱入问题的方法
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com