使用反应流作为Drools的数据源

几个月前,我们开始重新设计Drools最低级别的可执行模型 ,并使最终用户可以使用Java 8 API进行访问。 为了证明这种方法的灵活性,我尝试将其与反应流集成在一起,尤其是将该流用作Drools的数据源。

为了说明这是如何工作的,我创建了一个简单的温度服务器,该服务器提供RxJava Observable , 每秒发射给定镇的温度,并在5秒钟后终止。 还有第二种工厂方法,该方法允许合并更多的这些Observable,以使一个Observable可以同时发射一个以上城镇的温度。

public class TempServer {public static Observable<TempInfo> getFeed(String town) {return Observable.create(subscriber ->Observable.interval(1, TimeUnit.SECONDS).subscribe(i -> {if (i > 5) subscriber.onCompleted();try {subscriber.onNext(TempInfo.fetch(town));} catch (Exception e) {subscriber.onError(e);}}));}public static Observable<TempInfo> getFeeds(String... towns) {return Observable.merge(Arrays.stream(towns).map(TempServer::getFeed).collect(toList()));}
}

其中TempInfo.fetch方法仅返回-20至50度之间的随机温度

public TempInfo(String town, int temp) {this.town = town;this.temp = temp;
}public static TempInfo fetch(String town) {return new TempInfo(town, random.nextInt(70) - 20);
}

使用前一篇文章中介绍的Java 8 DSL的改进版本,我定义了以下2条规则:

Variable<TempInfo> temp = any( TempInfo.class );
Variable<Person> person = any( Person.class );Rule r1 = rule("low temp").view(subscribe(temp, "tempFeed"),expr(temp, t -> t.getTemp() < 0),input(person, "persons"),expr(person, temp, (p, t) -> p.getTown().equals(t.getTown()))).then(on(person, temp).execute((p, t) -> System.out.println(p.getName() + " is freezing in " + p.getTown() + " - temp is " + t.getTemp())));Rule r2 = rule("high temp").view(subscribe(temp, "tempFeed"),expr(temp, t -> t.getTemp() > 30),input(person, "persons"),expr(person, temp, (p, t) -> p.getTown().equals(t.getTown()))).then(on(person, temp).execute((p, t) -> System.out.println(p.getName() + " is sweating in " + p.getTown() + " - temp is " + t.getTemp())));

在这里,我使用2种不同的数据源:一个被动的数据源,可以将其视为事实的存储:

DataStore persons = storeOf(new Person("Mark", 37, "London"),new Person("Edson", 35, "Toronto"),new Person("Mario", 40, "Milano"));

可以绑定到特定的Drools KieSession与

bindDataSource(ksession, "persons", persons);

以及从上面实现的TempServer中获取的一个响应式

Observable<TempInfo> tempFeed = TempServer.getFeeds( "Milano", "London", "Toronto" );

也可以以类似的方式绑定到相同的KieSession

bindRxObservable( ksession, "tempFeed", tempFeed );

完成此操作后,您可以触发这两个规则并获得如下输出:

Mark is freezing in London - temp is -9
Edson is sweating in Toronto - temp is 42
Mario is sweating in Milano - temp is 42
Mario is sweating in Milano - temp is 49
Mark is freezing in London - temp is -17
Edson is sweating in Toronto - temp is 40
Edson is sweating in Toronto - temp is 47
Mario is freezing in Milano - temp is -14
Mark is freezing in London - temp is -8
Mark is freezing in London - temp is -17
  • 可在此处找到运行此示例的完整测试用例。

翻译自: https://www.javacodegeeks.com/2015/11/using-a-rective-stream-as-a-data-source-for-drools.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/355531.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java jsonobject 转对象_解析JSON中JSONObject的高级使用

文末会有读者福利简介:在程序开发过程中&#xff0c;在参数传递&#xff0c;函数返回值等方面&#xff0c;越来越多的使用JSON。JSON(JavaScript Object Notation)是一种轻量级的数据交换格式&#xff0c;同时也易于机器解析和生成、易于理解、阅读和撰写&#xff0c;而且Json采…

oracle 数据执行计划,Oracle 常见的执行计划步骤(explain结果的Description数据参考)...

在PL/SQL中 执行explain plain for select ...查看Description 数据参考&#xff1a;Oracle常见的执行计划步骤这里我们介绍一些常见的执行计划中的步骤及算法。1、表访问路径(1)TABLE ACCESSFULL&#xff1a;全表扫描。它会访问表中的每一条记录(读取高水位线以内的每一个数据…

CSS3实现Loading动画特效

查看效果&#xff1a;http://hovertree.com/texiao/css3/43/代码如下&#xff1a; <!DOCTYPE html> <html> <head><meta charset"UTF-8"><title>css3 loading等待加载代码 - 何问起</title><style>keyframes move {from {…

xfs支持oracle,让linux内核支持xfs文件系统

作/译者&#xff1a;叶金荣(Email:)&#xff0c;来源&#xff1a;http://imysql.cn&#xff0c;转载请注明作/译者和出处&#xff0c;并且不能用于商业用途&#xff0c;违者必究。 XFS 简介XFS 最初是由 Silicon Graphics&#xff0c;Inc. 于 90 年代初开发的。那时&#xff0c…

c语言打印菱形_没事了,搞一下C语言打印大小可变的菱形图案?

问题分析&#xff1a;菱形的大小size其实就是中间行中*号的个数&#xff0c;也是整个菱形的行数&#xff0c;其值必是奇数。问题的关键之一是如何确定每行中*号的个数。经过分析得知&#xff1a;当行i<(size1)/2时&#xff0c;该行的*号个数为n2*i-1&#xff0c;否则n2*&…

ListView 与 RecyclerView的创建与使用的异同

相同&#xff1a;1.在使用时&#xff0c;都需要先获取&#xff0c;再新建适配器&#xff0c;再用serAdapter方法绑定适配器 2.创建数据List&#xff0c;都是新建ArrayList 不同&#xff1a;1.在新建适配器类时&#xff0c;listview的适配器继承自ArrayAdapter,recyclerview的适…

测试驱动开发 测试前移_测试驱动开发–双赢策略

测试驱动开发 测试前移敏捷从业人员谈论测试驱动开发 &#xff08;TDD&#xff09;&#xff0c;所以许多关心代码质量和可操作性的开发人员也是如此。 我曾几何时&#xff0c;不久前设法阅读了有关TDD的文章。 据我了解&#xff0c;TDD的关键是&#xff1a; 编写测试&#xff0…

android timer后函数继续执行_Android内存异常机制(用户空间)_JE

常见的Android稳定性异常&#xff0c;有内核异常和Android层异常。内核异常也就是常说的“kernel panic”&#xff0c;简称KE异常&#xff1b;Android层异常又分为java层crash和Native层crash&#xff0c;简称JE、NE异常。此外&#xff0c;Android层异常还有应用ANR和system_Se…

server数据库与oracle,浅析Oracle和SQL Server-数据库专栏,ORACLE

t-sql是sql server的语言引擎&#xff0c;而oracle的语言引擎却是plsql。这两种查询语言都对ansi sql-92标准进行了扩展以提供额外的支持力度。你所创建的应用程序几乎都要用到这些补充特性。本文就对最常用的、非标准的oracle扩展进行了说明&#xff0c;同时还要介绍下如何对这…

AutoMapper

先说说DTO DTO是个什么东东&#xff1f; DTO&#xff08;Data Transfer Object&#xff09;就是数据传输对象&#xff0c;说白了就是一个对象&#xff0c;只不过里边全是数据而已。 为什么要用DTO? 1、DTO更注重数据&#xff0c;对领域对象进行合理封装&#xff0c;从而不会将…

Wildfly Swarm,朝着成熟和一小部分贡献

我最近关注的项目之一是Wildfly Swarm 。 最终&#xff0c;在今年的JBoss BOF Devoxx期间&#xff0c;我的考虑更改项目名称的请求没有通过&#xff08;由于与著名的Docker Swarm发生冲突&#xff09;。 那么什么是Wildfly Swarm&#xff1f; 简而言之&#xff0c;就是Wildfly…

oracle10 数据库审计,Oracle数据库审计用法实例

本节是从ORACLE METALINK的DOC:167293.1翻译整理而来的。通过举例的方式来说明ORACLE审计的用法。ORACLE的审计可以从语句级、对象本节是从Oracle METALINK的DOC:167293.1翻译整理而来的。通过举例的方式来说明ORACLE审计的用法。ORACLE的审计可以从语句级、对象级和权限级几个…

cefsharp 发送请求服务器_超高性能管线式HTTP请求(实践·原理·实现)

来源:https://www.cnblogs.com/lulianqi/p/8167526.html这里的高性能指的就是网卡有多快请求发送就能有多快&#xff0c;基本上一般的服务器在一台客户端的压力下就会出现明显延时。该篇实际是介绍pipe管线的原理&#xff0c;下面主要通过其高性能的测试实践&#xff0c;解析背…

(Oracle)DDL及其数据泵导入导出(impdp/expdp)

create tablespace ybp_dev datafile G:\app\Administrator\oradata\health\ybp_dev1.dbf size 10m autoextend on;create user 用户名 default tablespace 表空间名 identified by 用户密码;grant connect,resource to 用户;测试连接 conn mpi/1234删除表空间 drop tablespace…

查看oracle的块大小,查看操作系统块大小

查看操作系统块大小oracle建库一般设置数据库块大小8192K&#xff0c;一般是OS块大小的整数倍&#xff0c;要避免数据库块大小小于系统块大小的情况。1.在WINDOWS系统上&#xff0c;可以用命令fsutil来查看&#xff0c;测试如下&#xff1a;C:\Documents and Settings\administ…

java jsr_分叉并加入Java 7 – JSR 166并发实用程序

java jsrJava 7最有趣的改进之一是对并发的更好支持。 借助JSR 166并发实用程序&#xff0c;我们获得了一些非常有用的并发改进。 在我看来&#xff0c;fork-join库在软件工程中具有很高的实际应用潜力。 Fork and join为算法提供了非常简单的编程模型&#xff0c;可以将其实现…

python标准库模块_Python标准库模块之heapq

该模块提供了堆排序算法的实现。堆是二叉树&#xff0c;最大堆中父节点大于或等于两个子节点&#xff0c;最小堆父节点小于或等于两个子节点。 创建堆 heapq有两种方式创建堆&#xff0c; 一种是使用一个空列表&#xff0c;然后使用heapq.heappush()函数把值加入堆中&#xff0…

quartz Cron-Expression的表达式

关于quartz Cron-Expression的表达式&#xff0c;这个博客写的很好 ttp://www.cnblogs.com/yaowen/p/3779284.html CronTrigger配置完整格式为&#xff1a; [秒] [分] [小时] [日] [月] [周] [年] Q&#xff1a; C# quartz设置job间隔5min执行一次 A:0 30/5 16 * * ? 每…

oracle 启用闪回数据库,如何启用Oracle10g闪回数据库特性

为什么80%的码农都做不了架构师&#xff1f;>>>1.确认当前模式SYS AS SYSDBA on 29-MAR-05 >select flashback_on from v$database;FLA---NO2.检查/修改恢复区设置SYS AS SYSDBA on 29-MAR-05 >show parameter db_recovery_file_destNAME TYPE VALUE-----------…

nvme通用驱动_对领域驱动设计的理解与实践

领域驱动设计(Domain-Driven-Design)是一种针对大型复杂系统的领域建模与分析方法论。2003 年&#xff0c;Eric Evans 发布《Domain-Driven Design: Tackling Complexity in the Heart of Software》(领域驱动设计&#xff1a;软件核心复杂性应对之道)&#xff0c;其中定义了DD…