我尝试过同时使用max-length
和x-max-length
参数来限制队列长度,但没有效果。我不知道我是否错误地使用了这些参数,是否是由于使用RabbitMQ延迟消息插件的限制,或者RabbitMQ中是否存在实际的bug。
RabbitMQ Delayed Message Plugin使用一个交换,该交换附加了多个队列(这些队列仅通过此交换使用)。消息被发送到其中一个队列。
每当我重新部署应用程序服务器时,都会有两个示例运行一小段时间由于两个应用程序都将消息发布到队列中,因此每个队列中现在都有两条消息。即使max-length
和/或x-max-length
参数被设置为1
,仍然有另一个重复的消息被入队。我甚至尝试将它们设置为0
,但没有任何区别。
下面是我声明队列的方式:
下面是我应用于队列的策略:
1条答案
按热度按时间umuewwlo1#
尝试Message Deduplication Plugin。看起来它可以解决您的滚动更新用例。