如何在 Spring Integration 中并行处理多个进程中的消息，同时必须在相关 ID 上顺序处理消息

Question

具有多个进程的集群必须在接收时间顺序处理相同相关 ID 的消息。对于不同的相关 ID，必须并行处理它们。如何通过 Spring 集成解决这个问题？

Answer 1

这与Spring无关，是一个设计问题。这里有一个想法：创建一个

Map<CorrelationId, List<Nessage>>

并在列表中按接收时间对消息进行排序。然后创建一些与您的 Map 大小（id 数量）相等的消息处理进程。每个进程应按顺序处理一个特定 ID 的消息列表，但对于不同的 ID，您的进程将并行运行。