rabbitMQ实现延迟消息队列

延迟消息实现的两种方式

• 通过Rabbitmq本身队列的特性来实现，需要使用Rabbitmq的死信交换机（Exchange）和消息的存活时间TTL
• 通过插件（rabbitmq-delayed-message-exchange）来实现

消息的TTL

RabbitMQ可以针对Queue和Message设置 x-message-tt，来控制消息的生存时间，如果超时，则消息变为dead letter

针对队列的过期时间

通过队列属性设置，队列中所有消息都有相同的过期时间。

针对消息的过期时间

对消息进行单独设置，每条消息TTL可以不同。

注意

如果同时使用，则消息的过期时间以两者之间TTL较小的那个数值为准。消息在队列的生存时间一旦超过设置的TTL值，就成为dead letter

DLX (Dead-Letter-Exchange)

Queue可以配置x-dead-letter-exchange 和x-dead-letter-routing-key（可选）两个参数，如果队列内出现了dead letter，则按照这两个参数重新路由

x-dead-letter-exchange: 出现dead letter之后将dead letter重新发送到指定exchange
x-dead-letter-routing-key:指定routing-key发送

队列出现dead letter的情况

• 消息或者队列的TTL过期
• 队列达到最大长度
• 消息被消费端拒绝（basic.reject or basic.nack）并且requeue=false

reference

• rabbitmq 怎么实现延迟消息队列？
• RabbitMQ实战指南