在Spring集成中分组和忽略消息

Question

我有一个spring集成应用程序，它处理数据库中的不同交易类型，我将其转换、过滤并路由到相应的tradeEventChannel

新建行ID-

对于一种特定的交易事件类型（repoTradeChannel），有两种可能的情况：

1. 用户交易开放式回购交易，这转化为一个回购（开放消息）TradeEvent，应该路由到repotradeconnel进行处理。当交易被称为（小时、天或周后）时，会收到第二条消息（术语消息），也应进行处理

在上述两种情况下，TradeEvent/消息可以按id和TradeEvent类上的其他属性进行分组。

我的问题是，我是否可以使用聚合器对第二种情况下的消息进行分组，而忽略第二种情况？例如，我可以查看id或action字段来确定哪些是不可接受的。在第二种情况下，消息/事件在几分钟内收到，而在第一种情况下，第二条消息（术语消息）可以延迟数小时、数天或数周。

由于我无法阻止传入消息并进行筛选，是否有策略可用于在聚合时处理这些情况。我需要依赖分组，然后确定第二条消息在第二种情况下没有用处。

实现是什么样子的？我应该使用不同的策略，比如缓存吗？

总之，问题实际上是如何区分在案例1和案例2中接收到的术语消息，其中案例2应该被抑制。




Answer 1

您的问题过于具体，如果没有任何简单的常见解释或代码，很难直接回答。

无论如何，您确实可以基于id或action字段，将聚合器与CorrelationsStrategy一起使用。发布策略应该像MessageCountReleaseStrategy一样简单，阈值为2。

从聚合器输出什么，您可以在消息组处理器实现中决定：您可以将两条消息合并为一条。您仍然可以生成它们的列表，或者只是忽略其中一条消息并只生成另一条。