如何在spring集成中聚合拆分器拆分的消息？
使用Spring Integr中的拆分器，我拆分了从数据库中的表中选择的数据行。每条消息完成处理后，我想像旧消息一样将每条消息聚合到一条消息中。我该怎么办？我不知道拆分器拆分了多少条消息。我只知道拆分消息头中的相关ID。即使我聚合消息，我也无法制定发布策略。
我如何解决这个问题？
以及是否有任何方法可以使用jdbc-out站网关或jdbc-out站通道适配器一次插入多行数据，而无需使用拆分器插入每一行？
共有1个答案
实际上，如果使用默认拆分器策略，它将填充整个SequenceDetails，包括sequenceSize。最终，具有默认策略的聚合器可以关联消息并使用这些序列详细信息发布它们。
当然，如果使用自定义拆分逻辑，则应手动提供这些标头。如果您知道大小，当然-对于每个拆分的消息，请单击MessageBuilder#pushSequenceDetails。
在这一部分中，我们需要了解有关您案例的更多信息。您的代码的一些示例也会很好。
重新。批量插入：https://jira.spring.io/browse/INT-3364.正如您所看到的，我们还没有实现它。但使用直接的JdbcTemplate解决这个问题非常简单
-
目前，我正在与spring integration合作开发新的应用程序，并启动了poc，以了解如何处理故障案例。在我的应用程序中，spring integration将接收来自IBM mq的消息，并根据消息类型验证头信息和到不同队列的路由。传入的消息可能是批量消息，所以我使用了spring integration的拆分器和聚合器，并且对技术工作流程有很好的进展和控制。目前我面临的问题很少，我们有I
-
我有一个用例，我的消息被拆分两次，我想聚合所有这些消息。如何才能最好地实现这一点，我应该通过引入不同的序列头来聚合消息两次，还是有办法通过重写消息分组的方法在单个聚合步骤中聚合消息？
-
我正在尝试做一个GroupBy基于共享ID的GeoJSON功能列表，以便通过使用拆分/聚合来聚合这些功能的单个字段，如下所示： 除非我取消对这三行的注释，否则聚合器永远不会发布组，数据库也不会收到任何更新。如果我将groupTimeout设置为小于5秒，则会丢失部分结果。 我预计发布策略默认为，我预计在处理完所有（拆分）功能后会自动释放所有组（REST服务消息中总共只有129个功能）。手动将其设置
-
我有以下XML负载，我正试图将其用于Spring集成和Spring集成AMQP： 我正在使用xpath拆分器拆分消息： 我工作正常，消息被分成3条新消息，例如使用此有效负载： 在此步骤之后，将使用此设置聚合消息： 作为最后一步，消息将使用此出站通道适配器发送到交换机： 不幸的是，出现了一些问题，因为我最终得到了这样的有效载荷。我需要它保持XML格式。
-
我有一个基于DSL的流，它使用拆分迭代对象列表并发送Kafka消息： 在所有消息发出后，我需要调用服务，还需要记录处理了多少消息。我知道一种方法是使用publishSubscribeChannel，其中第一个subscribe执行实际的Kafka发送，然后聚合执行服务调用： 我在弄清楚如何使用DSL在pubSubChannel中实际执行部分时遇到了问题。到目前为止，我已经尝试过： 有什么指示吗？