同步队列的所有消费者一次只处理一条消息
Synchronize all consumers of a queue to process only one message at a time
我是 运行 一个 Spring Cloud Stream 应用程序,使用来自 RabbitMq 的消息。我想实现一种行为,其中具有三个消费者实例的给定队列只向其中任何一个传递一条消息,并等待下一条消息被传递,直到当前被确认(所有消费者之间的某种同步)。
我认为这可以使用此 https://www.rabbitmq.com/consumer-prefetch.html 并启用全局选项来完成,但我找不到使用 spring 云流实现此目的的方法。任何帮助将不胜感激。
Spring 为每个消费者使用单独的通道,因此全局通道预取不会有任何影响。
请记住,即使它被支持,它也只有在消费者都在同一个实例中时才有效。
我是 运行 一个 Spring Cloud Stream 应用程序,使用来自 RabbitMq 的消息。我想实现一种行为,其中具有三个消费者实例的给定队列只向其中任何一个传递一条消息,并等待下一条消息被传递,直到当前被确认(所有消费者之间的某种同步)。
我认为这可以使用此 https://www.rabbitmq.com/consumer-prefetch.html 并启用全局选项来完成,但我找不到使用 spring 云流实现此目的的方法。任何帮助将不胜感激。
Spring 为每个消费者使用单独的通道,因此全局通道预取不会有任何影响。
请记住,即使它被支持,它也只有在消费者都在同一个实例中时才有效。