【问题标题】:Spring Integration and Rabbit MQ: Aggregation of multiple jobsSpring Integration 和 Rabbit MQ:多个作业的聚合
【发布时间】:2016-08-16 14:14:11
【问题描述】:

我有一个 spring 集成流程,其中一个消费者从 Rabbit MQ 中获取一个作业,并将其拆分为多个较小的作业,这些作业排回 Rabbit MQ 的队列,由不同服务器上的其他消费者获取。有没有什么好的方法可以在完成后聚合较小的作业?

【问题讨论】:

    标签: design-patterns architecture rabbitmq spring-integration


    【解决方案1】:

    您可以将结果发送回第一个应用并使用aggregator

    【讨论】:

    • 如何从不同的消费者中汇总?
    • 你只需要某种关联和发布策略。默认关联策略使用correlationId 标头。如果您有已知数量的消费者,您可以使用默认的SequenceSizeReleaseStrategy,它使用序列* 标头。
    最近更新 更多