我们有几个需求，需要使用BPM收集一定数量的消息。在ccBPM中，我们使用循环步骤来实现这一点，如下所示，大数据治理平台，我们定义了一个循环和一个计数器，一旦计数器到达结束条件，循环步骤就终止了。

那么如何使用循环步骤来实现类似的功能呢NWBPM.以下是流程视图。

在我的场景中，输入消息如下所示。

NWBPM是我将接受5条结构相同的消息，并将它们聚合到一条消息中。

我不打算进行PO ESR ID设计，因为这非常简单。我们只需要一个ICO将上述结构的消息传递给BPM，另一个ICO从BPM接收聚合的消息并将其写入文件中。

我将描述我在BPM中创建的步骤的属性。

计数器：

这是一个Integer类型的简单数据对象，用于计算BPM接收到的消息数流程如下是属性。

入站：

此DO是从数据类型DT\u SRC创建的，该数据类型在我们从导入相关服务接口时自动创建阿宝。这个充当变量/容器来保存BPM流程中的中间消息。

在输出映射属性中，企业服务软件，我们已经通过定义下面的函数将计数器初始化为1，物联网大赛，并将第一个输入文件/消息映射到先前创建的入站DO。

CountReached行的条件如下。

这里我们需要使用触发器来接收下一个消息。在在我的案例中，物联网是学什么的，我使用了与源文件结构相同的触发器消息是相同的，来自相同的服务接口。

在输出映射中，我们需要将新消息附加到流程中的现有消息中。

这里还需要设置相关性，大数据是什么概念，以便根据传入消息上的公司名称关联下一条消息。所以基本上，如果这个过程被多个实例调用，那么它将基于相同的公司名称生成聚合输出。

双击计数器映射行的[-]号将显示函数。

就是它！！

输出如下。

非常有趣的Arijit。