Drools融合多个流

Question

我目前正在撰写硕士论文，涉及使用Drools Fusion来处理来自多个XML文件流的事件（因此我将每个文件“重放”为一个流）。这些文件记录的是一场足球比赛，比赛中球员身上安装了GPS传感器，监测他们的加速度和速度，以及球员负荷等其他信息。

每个XML文件都包含事件实例，声明ID、开始时间、结束时间和代码，如下所示：

<file>
<SESSION_INFO>
<start_time>2015-09-17 19:02:31.31 +100</start_time>
</SESSION_INFO>
<SORT_INFO>
<sort_type>sort order</sort_type>
</SORT_INFO>
<ALL_INSTANCES>

<instance>
<ID>1</ID>
<start>0</start>
<end>1.51</end>
<code>Accel : 0.00 - 2.00</code>
</instance>

<instance>
<ID>2</ID>
<start>1.52</start>
<end>3.01</end>
<code>Accel : -2.00 - 0.00</code>
</instance>

<instance>
<ID>3</ID>
<start>3.02</start>
<end>4.01</end>
<code>Accel : 0.00 - 2.00</code>
</instance>

<instance>
<ID>4</ID>
<start>4.02</start>
<end>4.21</end>
<code>Accel : 2.00 - 4.00</code>
</instance>
</ALL_INSTANCES>

我有9个这样的文件，它们都需要同时处理，并将这些事件同时输入到引擎中。我当前的实现是一个JAXB解组器，用于将这些事件馈送到流中，但不知道如何同时进行（即：在每个流中馈送第一个事件，然后在每个流中馈送第二个事件等）。我正在考虑在实现的这一部分使用线程，除非它们是我在Drools中错过的另一个帮助实现这一点的工具。但是，在同时处理多个流方面，搜索得相当彻底，并且没有全面的示例。

我的另一个问题是关于伪时钟。因为我有这9个不同的流，事件发生在不同的时间，所以我不能提前每次插入后的时间，因为每个流中的每个事件都发生在不同的时间，因此，这些事件不会排队。所有这些流开始的时间是相同的。例如，如果我在XML中的实例1发生在1.51的持续时间内，而另一个流中的另一个事件的持续时间为。比如说。4秒，并假设我要提前这两个事件，那么它们将彼此不同步。

然而，所有与时间相关的数据都存在于每个流中。启动时间为19:02:31，每个事件在该流中都有一个时间戳，以启动后的秒为单位，通过“结束”时间戳，每个事件的持续时间为（结束时间戳-开始时间戳）。我需要对这些流进行的处理包括，每当两个或更多玩家以大致相同的持续时间/时间间隔以相同的速度加速时，将这些加速事件与其他流关联起来。

有人能给我任何指导或帮助吗？总而言之，我需要知道一种更好的同时将流插入引擎的方法，并且需要知道我是否需要伪时钟来实现/处理。我几乎是编程的初学者，所以我只想让系统运行。

谢谢！

斯图。

Answer 1

您不需要同时处理这九个XML文件，即分布在线程上<代码>

这样，与伪时钟相关的问题也就不再是问题了。一旦确定了下一个实例事件，就可以轻松地将时钟提前到下一个实例事件。

在不知道所有细节的情况下，我认为每个