【发布时间】:2016-08-16 14:14:11
【问题描述】:
我有一个 spring 集成流程,其中一个消费者从 Rabbit MQ 中获取一个作业,并将其拆分为多个较小的作业,这些作业排回 Rabbit MQ 的队列,由不同服务器上的其他消费者获取。有没有什么好的方法可以在完成后聚合较小的作业?
【问题讨论】:
标签: design-patterns architecture rabbitmq spring-integration
我有一个 spring 集成流程,其中一个消费者从 Rabbit MQ 中获取一个作业,并将其拆分为多个较小的作业,这些作业排回 Rabbit MQ 的队列,由不同服务器上的其他消费者获取。有没有什么好的方法可以在完成后聚合较小的作业?
【问题讨论】:
标签: design-patterns architecture rabbitmq spring-integration
您可以将结果发送回第一个应用并使用aggregator。
【讨论】:
correlationId 标头。如果您有已知数量的消费者,您可以使用默认的SequenceSizeReleaseStrategy,它使用序列* 标头。