1，场景
1.定时发布文章
2.秒杀之后，给30分钟时间进行支付，如果30分钟后，没有支付，订单取消。
3.预约餐厅，提前半个小时发短信通知用户。
A -> 13:00 17:00 16:30 延迟时间： 7*30 * 60 * 1000
B -> 11:00 18:00 17:30 延迟时间： 13*30 * 60 * 1000
C -> 8:00 14:00 13:30 延迟时间： 11*30 * 60 * 1000
2.第一种方式：创建具有超时功能且绑定死信交换机的消息队列
@Bean public Queue directQueueLong(){
return QueueBuilder.durable("业务队列名称")
.deadLetterExchange("死信交换机名称")
.deadLetterRoutingKey("死信队列 RoutingKey")
.ttl(20000) // 消息停留时间
//.maxLength(500)
.build(); }
6.延迟队列
6.1场景：
1.定时发布文章
2.秒杀之后，给30分钟时间进行支付，如果30分钟后，没有支付，订单取消。
3.预约餐厅，提前半个小时发短信通知用户。
A -> 13:00 17:00 16:30 延迟时间： 7*30 * 60 * 1000
B -> 11:00 18:00 17:30 延迟时间： 13*30 * 60 * 1000
C -> 8:00 14:00 13:30 延迟时间： 11*30 * 60 * 1000
6.2第一种方式：创建具有超时功能且绑定死信交换机的消息队列
@Bean
public Queue directQueueLong(){
return QueueBuilder.durable("业务队列名称")
.deadLetterExchange("死信交换机名称")
.deadLetterRoutingKey("死信队列 RoutingKey")
.ttl(20000) // 消息停留时间
//.maxLength(500)
.build();
}
监听死信队列，即可处理超时的消息队列
缺点：
上述实现方式中，ttl延时队列中所有的消息超时时间都是一样的，如果不同消息想设置不一样的超时时间，就需要建立多个不同超时时间的消息队列，比较麻烦，且不利于维护。
3，第二种方式：创建通用延时消息
rabbitTemplate.convertAndSend("交换机名称", "RoutingKey","对象", message => { message.getMessageProperties().setExpiration(String.valueOf(5000)) return message; } );
缺点：
该种方式可以创建一个承载不同超时时间消息的消息队列，但是这种方式有一个问题，如果消息队列中排在前面的消息没有到超时时间，即使后面的消息到了超时时间，先到超时时间的消息也不会进入死信队列，而是先检查排在最前面的消息队列是否到了超时时间，如果到了超时时间才会继续检查后面的消息。
4，第三种方式：使用rabbitmq的延时队列插件，实现同一个队列中有多个不同超时时间的消息，并按时间超时顺序出队
下载延迟插件
Releases · rabbitmq/rabbitmq-delayed-message-exchange · GitHub
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
安装插件并启用
我用的是 Docker 客户端，下载完成后直接把插件放在 /root 目录，然后拷贝到容器内plugins目录下（rabbitmq是容器的name，也可以使用容器id）
docker cp /home/208/rabbitmq_delayed_message_exchange-3.10.0.ez rabbitmq:/plugins
进入 Docker 容器
docker exec -it rabbitmq /bin/bash
在plugins内启用插件
#先执行，解除防火墙限制，增加文件权限 umask 0022rabbitmq-plugins enable rabbitmq_delayed_message_exchange
退出容器
exit
重启 RabbitMQ
docker restart rabbitmq
6.延迟队列
6.1场景：
1.定时发布文章
2.秒杀之后，给30分钟时间进行支付，如果30分钟后，没有支付，订单取消。
3.预约餐厅，提前半个小时发短信通知用户。
A -> 13:00 17:00 16:30 延迟时间： 7*30 * 60 * 1000
B -> 11:00 18:00 17:30 延迟时间： 13*30 * 60 * 1000
C -> 8:00 14:00 13:30 延迟时间： 11*30 * 60 * 1000
6.2第一种方式：创建具有超时功能且绑定死信交换机的消息队列
@Bean
public Queue directQueueLong(){
return QueueBuilder.durable("业务队列名称")
.deadLetterExchange("死信交换机名称")
.deadLetterRoutingKey("死信队列 RoutingKey")
.ttl(20000) // 消息停留时间
//.maxLength(500)
.build();
}
Java
监听死信队列，即可处理超时的消息队列
缺点：
上述实现方式中，ttl延时队列中所有的消息超时时间都是一样的，如果不同消息想设置不一样的超时时间，就需要建立多个不同超时时间的消息队列，比较麻烦，且不利于维护。
6.3第二种方式：创建通用延时消息
rabbitTemplate.convertAndSend("交换机名称", "RoutingKey","对象", message => {
message.getMessageProperties().setExpiration(String.valueOf(5000)) return message;
}
);
Java
缺点：
该种方式可以创建一个承载不同超时时间消息的消息队列，但是这种方式有一个问题，如果消息队列中排在前面的消息没有到超时时间，即使后面的消息到了超时时间，先到超时时间的消息也不会进入死信队列，而是先检查排在最前面的消息队列是否到了超时时间，如果到了超时时间才会继续检查后面的消息。
6.4 第三种方式：使用rabbitmq的延时队列插件，实现同一个队列中有多个不同超时时间的消息，并按时间超时顺序出队
6.4.1下载延迟插件
在 RabbitMQ 的 3.5.7 版本之后，提供了一个插件（rabbitmq-delayed-message-exchange）来实现延迟队列 ，同时需保证 Erlang/OPT 版本为 18.0 之后。
我这里 MQ 的版本是 3.10.0 现在去 GitHub 上根据版本号下载插件
Releases · rabbitmq/rabbitmq-delayed-message-exchange
Delayed Messaging for RabbitMQ. Contribute to rabbitmq/rabbitmq-delayed-message-exchange development by creating an account on GitHub.
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
rabbitmq_delayed_message_exchange-3.1
0.0.ez(34.4 KB)
6.4.2安装插件并启用
我用的是 Docker 客户端，下载完成后直接把插件放在 /root 目录，然后拷贝到容器内plugins目录下（rabbitmq是容器的name，也可以使用容器id）
docker cp /home/208/rabbitmq_delayed_message_exchange-3.10.0.ez rabbitmq:/pluginsBash
进入 Docker 容器
docker exec -it rabbitmq /bin/bashBash
在plugins内启用插件
#先执行，解除防火墙限制，增加文件权限
umask 0022rabbitmq-plugins enable rabbitmq_delayed_message_exchangeBash
退出容器
exit
Bash
重启 RabbitMQ
docker restart rabbitmq通过UI查看
原理
使用方法
1，消费者
生产者
