java—同步队列的所有使用者,以便一次只处理一条消息

dluptydi  于 2021-07-07  发布在  Java
关注(0)|答案(1)|浏览(464)

我正在运行一个spring云流应用程序,使用来自rabbitmq的消息。我想实现一种行为,在这种行为中,一个给定的队列(有三个使用者示例)只向其中任何一个传递一条消息,然后等待下一条消息被传递,直到确认当前消息为止(所有使用者之间的某种同步)。
我认为这可以用这个来完成https://www.rabbitmq.com/consumer-prefetch.html 启用了全局选项,但我找不到使用springcloudstream实现这一点的方法。任何帮助都将不胜感激。

7hiiyaii

7hiiyaii1#

spring为每个消费者使用一个单独的通道,因此全局通道预取不会产生任何影响。
请记住,即使它得到支持,也只有当消费者都在同一个示例中时,它才会起作用。

相关问题