rabbitmq实现延时消息主要有两种方式：
死信消息（队列ttl+死信exchange）延时插件 (rabbitmq-delayed-message-exchange) rabbitmq 实现方式一：队列ttl+死信exchange简述：使用两个队列，一个队列接收消息不消费，等待指定时间后消息死亡，再由该队列绑定的死信exchange再次将其路由到另一个队列提供业务消费。
ttl 和 死信exchange 相关知识 ttl先贴两个个rabbitmq官方文档：
Time-To-Live and Expiration：https://·/ttl.htmlDead Letter Exchangeshttps：https://·/dlx.html我这里也简单介绍下： rabbitmq 可以给 消息 和 队列 设置 ttl（生存时间）
队列设置：x-message-ttl=60000 （队列中所有消息都只有60s存活时间）指定消息设置：expire=60000 指定消息只有60s存活时间如果队列和消息同时设置了ttl，则取较小的那个作为ttl。消息死亡后不会被消费者消费。
死信exchange死信（死亡的消息）：
消费者使用 basic.reject 或 basic.nack 并将requeue参数设置为 false 来否定的消息ttl到期的消息队列超过长度限制被丢弃的消息当一个队列设置了死信exchange 后，这个队列的死信都会被投递到死信exchange中，然后可以再次路由到其他队列中（如果指定了死信routing key 则死信消息routing key 变为设置的routing key，未设置则为原始 routing key）。
使用介绍 先声明一个消费队列 queue_dlx，用来接收死信消息，并提供消费；然后声明一个死信exchange_dlx, 绑定 queue_dlx，接收消息后路由至queue_dlx；声明一个延迟队列，queue_delay, 用来接收业务消息，但不提供消费，等待消息死亡后转至死信exchange。（即延迟）声明一个exchange，由业务发送消息到exchange，然后转至queue_delay.一个消息的流程大概是：
具体使用推荐另一篇文章： RabbitMQ 实现固定延时等级的延时消息， 直接实现一套不同延时等级的消息，就不用每次都配置各种exchange和queue绑定关系了。
简单分析缺点：
只能支持固定延迟等级的消息使用较复杂，得声明一堆队列&exchange优点：
支持镜像队列复制，实现高可用支持大量消息（成千上万）适用场景： 使用固定延迟时间的场景。
备注：对于高版本（3.6及以上）的rabbitmq建议使用lazy-mode作为延迟队列，防止大量延时消息堆积而占用大量内存，从而触发rabbitmq换页阻塞队列。 （如果使用spring的话，即使低版本rabbitmq也不用太担心：spring-amqp默认发送持久化消息，即使触发换页，也只是把消息从内存中逐出而已。）
rabbitmq 实现方式二：rabbitmq延时插件简述：延时消息不直接投递到队列中，而是先转储到本地Mnesia数据库中，然后定时器在消息到期后再将其投递到队列中。
延时插件使用关于用法可以直接看这个文档或者网上搜一搜，这里就不介绍了。 github地址：https://github.com/rabbitmq/rabbitmq-delayed-message-exchange
其大概原理就是：指定了延时的消息，会被先保存在 Mnesia （erlang编写的数据库管理系统）中，然后有一个定时器去查询最近需要被投递的消息，将其投递到目标队列中。
简单分析优点：
基本支持任意延迟时间（不能超过1个月）缺点：
延时不可靠，存在消息数量较大或使用很久后延迟不准确（会推迟）， 见 issues#72无备份机制，延时消息存在单个节点磁盘中不支持ram类型的节点 （数据得存磁盘里面）增加大量内存的占用 （经测试发现，发送大量延时消息后，rabbitmq内存占用明显增高，比普通消息还要高很多那种。）安装插件需要重启适用场景：：如果不是无关紧要的小业务，不建议使用。
 1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，会注明原创字样,如未注明都非原创，如有侵权请联系删除！；3.作者投稿可能会经我们编辑修改或补充；4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |
