关于聚合消息

Question

我问一个关于 JMS 的简单问题，我正在通过 spring 集成和 spring 实现，但是我遇到了一种情况，请告诉我，假设我在队列中收到 5000 条消息，我想聚合成一组 20 条消息然后转发它，这意味着我想要某种聚合，它将从 5000 条消息中提取 20 条消息并转发这 20 条消息，请告知如何实现这一点。

我也经历过这种模式..http://www.eaipatterns.com/Aggregator.html

Answer 1

Spring Integration 参考手册的这一部分应该提供您需要的所有信息： http://static.springsource.org/spring-integration/docs/2.2.x/reference/htmlsingle/#aggregator

基本上，您想要一个在消息组大小达到 20 时返回 true 的发布策略，并且您想要一个简单地考虑所有消息都在同一个组中的相关性策略（除非您确实有其他组成员身份的指标)。

希望对您有所帮助。 -马克

Answer 2

我遇到了类似的问题，我解决了这个问题，并使用 atomicLong 在每条消息中创建了一个计数器。

然后，发布策略将根据该计数器（存储为 message_id 标头）每隔 X 条消息释放消息

    <int:aggregator ...
    release-strategy-expression="size() == ${max.size}"
     correlation-strategy-expression="new java.lang.Double(new java.lang.Double(headers.message_id) / ${max.size}).longValue()"
     />

嘿，它有效。