使用 RabbitMQ,我怎样才能像 AWS SQS SetMessageVisibility 或 Azure 更新锁一样获得滚动消息过期?

问题描述 投票:0回答:0

我已经使用 AWS SQS 队列构建了一个解决方案,并定期调用 SetMessageVisibility 以保持消息在消费者中隐藏(即仍在处理)。队列中的这些消息可能需要几秒到几小时,而且无法知道它们需要多长时间。我通过调用更新锁在 Azure 中做了同样的事情。

我的问题是,在探索 RabbitMQ 时,我该如何做同样的事情?似乎一旦消息被传递给消费者,消费者就有一个可配置的传递确认超时(默认为 30 分钟)来手动确认,这样消息就可以被丢弃。

如果消费者需要几个小时来处理消息,RabbitMQ 将为另一个消费者重新排队消息。

我想要的是保持低数量,所以如果消费者死亡,另一个消费者可以接收消息。

rabbitmq amazon-sqs
© www.soinside.com 2019 - 2024. All rights reserved.