后台审核管理 ergo_Kogito，ergo规则—第2部分：规则的全面执行模型

不念不忘少年蓝@ 2023-02-25 07:01 34阅读 0赞

后台审核管理 ergo

这是*第二后* [一系列更新][Link 1]的Kogito主动性和我们的努力，使Drools的云。 在本文中，我们将深入研究**规则单元**的详细信息，并向您展示为什么我们对它们感到兴奋。

## 规则的全包执行模型 ##

如果您一直在仔细检查Drools手册，以在每个最新发行版中寻找新功能，则您可能已经注意到，该术语  
**统治单位**已经坐在那里一段时间了，这是一项*极为实验性的功能* 。 简而言之，规则单元既是规则的**模块**又是**执行**的**单元** —之所以不称其为*模块*是为了避免与*JVM模块*混淆。 在Kogito，我们正在重新研究并扩展我们的原始原型。

**规则单元**收集一组规则以及对该规则所作用的工作存储器的描述。 工作存储器的描述被编写为带有*DataSource*字段的常规Java类。 每个数据源代表工作存储器的*类型化分区* ，并且存在具有不同功能的不同类型的数据源。 例如，在下面的示例中，我们使用了仅附加数据源，称为  
*数据流。*

public class MonitoringService implements RuleUnitMemory {
       private final DataStream<Event> events = DataSource.createStream();
       private final DataStream<Alert> alerts = DataSource.createStream();
    }

给定规则单元的规则与**单元**声明一起收集在DRL文件中

package org.kie.kogito.rules.alerting
    unit MonitoringService
    rule IncomingEvent when
       // matches when a temperature higher than 30 °C is registered (OOPath syntax)
       $e : /events # Temperature[ value >= 30 ] // Temperature is an Event subclass
    then
       System.out.println("incoming event: "+ $e.getMessage());
       alerts.append( new WarningHighTemperature($e) );
    end

单位中的每个规则都可以查看在相应类中声明的*所有*数据源。 实际上，一个单元的类和DRL文件的集合构成一个*整体* ：您可以将这样的整体视为  
*一个单一的* *类* ，其中*字段*是范围限于当前单位的*全局变量* ， *方法*是*规则* 。 实际上，字段的使用取代了DRL全局变量的使用。

![format_png][]

规则单元被提交给[**调度程序**][Link 2]执行**。** 规则单元可以决定**产生**其执行给其他单位的规则，有效地将其付诸实施。 例如：

rule IncomingEvent when
       // matches when a temperature higher than 30 °C is registered (OOPath syntax)
       $e : /events # Temperature[ value >= 30 ] // Temperature is an Event subclass
    then
      // Suspend execution of this unit, yield to the HighTemperatureUnit
      HighTemperatureUnit.createInstance(events).run(); 
    end

但是规则单元也可能处于**长期运行状态** 。 在这种情况下，  
*其他规则单元*可以*同时在同一时间*运行; 由于可以跨单元**共享**数据源，因此可以通过交换消息来协调单元。

![format_png 1][]

考虑以下示例：

**规则单元以**某种方式**充当交换消息的“参与者”** 。 但是，以一种非常独特的方式，规则单元允许执行更复杂的执行链，这适合基于规则的推理。 例如，  
[考虑一下Akka手册中的示例][Akka] ：

override def receive: Receive = {
        case RecordTemperature(id, value) =>
          log.info("Recorded temperature reading {} with {}", value, id)
          lastTemperatureReading = Some(value)
          sender() ! TemperatureRecorded(id)
    
        case ReadTemperature(id) =>
          sender() ! RespondTemperature(id, lastTemperatureReading)
      }

如您所见，Akka中的模式匹配严格只针对**单个消息** 。 这并不奇怪，因为参与者一次处理一条消息。 在规则引擎中，我们可以编写几个规则，在执行时**对工作内存**的**整个状态**做出React：这明显不同于纯粹的参与者模型设计，但同时在创建时提供了很大的灵活性。您可以编写应用程序的业务逻辑的方式。

## 数据源 ##

值得在数据源上花一些时间。 数据源构造可以看作是对传统工作内存的**分区**和**抽象** 。 将提供不同类型的数据源：功能齐全的**数据存储区**可能支持添加，删除和更新值，从而允许在工作内存上进行更多传统操作； 而受限的仅追加**数据流**将更易于与外部数据源和数据接收器（例如Camel连接器）集成。 这样的约束对于启用更高级的用例（例如**并行，线程安全的执行**和  
在**OpenShift集群的**各个节点之间**持久共享通道** （例如：Kafka），实现了完全**分布式的规则引擎。**

## Kogito：ergo Cloud ##

并行和分布式用例很*有趣* ，但是我们需要一*步步走到*那里*。* 但是，这并不意味着第一步不会像以自己的方式那样令人兴奋。

对于[**Kogito，**][Kogito]我们要强调云原生的无状态用例，其中  
**控制流程**使用**流程**进行了**外部** **化，**并借助  
[Quarkus][]我们可以将其编译为超快速的本机二进制文件。 因此，我们将在接下来的几周内完成并发布以下规则单元 *自动化REST服务实施* 。

在此用例中， **规则单元**的基于Java的类型化声明为  
**自动**映射到REST端点的签名。 **POST**到端点意味着实例化该单元，将数据插入数据源，触发规则，返回响应有效负载。 使用*用户提供的查询*来计算响应。 例如，考虑以下示例：

package org.kie.kogito.rules.alerting
    unit MonitoringService
    query Alerts(Alert alert) 
       alert := /alerts # Warning // select all sub-type Warning
    end

用户可以使用自动生成的/ monitoring-service端点发布事件。回复将是查询的结果。 在我们的情况下：

{
      "events": [ 
        { "type": "WarningHighTemperature", "value": 40, "timestamp": "2019-07-12T18:25:45.000Z" }
      ]
    }

答复将是查询的结果。 在我们的情况下：

{
      "events": [ 
        { "type": "Temperature", "value": 10, "timestamp": "2019-07-12T18:25:43.000Z" },
        { "type": "Temperature", "value": 25, "timestamp": "2019-07-12T18:25:44.000Z" },
        { "type": "Temperature", "value": 40, "timestamp": "2019-07-12T18:25:45.000Z" }
      ]
    }

## 多云，有规则 ##

我们已经提出了对我们在Kogito及以后的下一代规则引擎的愿景。 无状态用例只是迈向迈向规则引擎真正创新之举的第一步。 在接下来的几个月中，我们将致力于为并行（本地）和分布式（在Openshift上）调度和部署单元提供更好的支持，敬请期待。 同时，我们确实希望听到您关于我们正在采取的方向的信息。

> 翻译自: [https://www.javacodegeeks.com/2019/08/kogito-ergo-rules-encompassing-execution-model.html][https_www.javacodegeeks.com_2019_08_kogito-ergo-rules-encompassing-execution-model.html]

后台审核管理 ergo

[Link 1]: http://blog.athico.com/2019/07/kogito-ergo-rules-part-1-bringing.html
[format_png]: /images/20230209/f6a16fc91dc24ccb9243940cabc02f51.png
[Link 2]: https://4.bp.blogspot.com/-M9raRmeKPNQ/XT7DDRWF-DI/AAAAAAAADMc/81Z4vgcOwms4ZFFlSTRr_mpZHEilUFfNACPcBGAYYCw/s1600/unitsm.png
[format_png 1]: /images/20230209/6339b7215ab24f86ac62128c0f89154d.png
[Akka]: https://doc.akka.io/docs/akka/2.5.23/guide/tutorial_3.html
[Kogito]: http://kogito.kie.org/
[Quarkus]: https://quarkus.io/
[https_www.javacodegeeks.com_2019_08_kogito-ergo-rules-encompassing-execution-model.html]: https://www.javacodegeeks.com/2019/08/kogito-ergo-rules-encompassing-execution-model.html