Rabbitmq实现耽误队列
在RabbitMQ中实现耽误队列（延时队列）可以有几种方案，此中常用的是通过死信队列（Dead Letter Queue，DLX）和rabbitmq_delayed_message_exchange插件来实现。以下是这两种方案的先容以及注意事项。1. 通过死信队列实现耽误队列
原理：
利用RabbitMQ的死信队列机制，将消息发送到一个普通队列，该队列设置TTL（Time To Live，过期时间）。消息在TTL到期后会进入死信队列，而死信队列再绑定到目标消费队列，消息到期后会从死信队列转发到目标消费队枚举行消费。
实现步调：
创建普通队列并设置TTL： 给普通队列（例如queue_A）设置消息TTL和死信交换机，消息过期后进入死信队列。
rabbitmqctl set_policy TTL "queue_A" '{"x-message-ttl":60000, "x-dead-letter-exchange":"dlx_exchange"}' --apply-to queues
创建死信交换机和队列： 创建一个死信交换机（例如dlx_exchange）和死信队列（例如dlx_queue），并将其绑定到目标消费队列。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]