前言
前段时间写过一篇：
#RabbitMQ：消息丢失
消息重复
消息积压的原因+解决方案+网上学不到的使用心得
很多人加了我好友，说很喜欢这篇文章，也问了我一些问题。
因为最近工作比较忙，隔了一段时间没写，忙完后专门花时间把RabbitMQ剩下的一个重要技术点通过案例的方式整理出来，就是延迟消息的用法。
延迟消息含义不解释了，就是字面意思。
用法一共两种方式，死信队列和延迟插件，两种各有利弊，我会一一陈述并给出最佳用法。
死信队列方式
死信队列不要理解成很玄乎的东西，它就是普通队列绑定了死信交换机，而且配置参数还是固定的，无需动脑，作用的话你想象成回收站就好了，被拒绝或超时的消息就往这里边丢，然后还能继续被消费，就这么简单。
1、原理图解
2、引入MQ
3、声明交换机和队列
声明普通交换机、队列、路由，这里我们声明两个预备延迟的队列，名称分别包含5s和15min，用来区分延迟消息是否达到预期效果。
我们接下来所有交换机和队列都是以Direct模式来创建的，也就是点对点方式，具体原因后面会讲。
另外，注意这里注释的延迟交换机、队列，都是为了特别说明，其实还是普通队列，参考上面的原理图解。
创建交换机、队列、绑定关系。
聪明的小伙伴应该能发现，上面这段代码只有交换机和绑定队列的关系，却没有创建队列。
没错，接下来就是重点部分，创建队列时，要绑定死信交换机，这样就变成了一个死信队列。
可以看到，5s和15min的队列绑定的都是同一个死信交换机，只是路由规则、消息过期时间TTL不同。
这样，在项目启动后，RabbitMQ就会创建出两个具备不同过期时间的死信队列，后面会有截图专门给大家看。
绑定后的效果，在项目启动后RabbitMQ会把交换机和队列都创建出来，在控制台就能看到。
普通队列绑定死信交换机和对应的路由规则后，我们接下来就把死信交换机、路由规则、队列创建出来即可，其实和创建普通队列没区别。
4、yml配置
为了演示方便，我们的生产者和消费者是写在同一个项目中的，所以配置文件没有区别。但是在线上环境中，为了解耦生产者和消费者往往是分开的。
这里可以发现，我们给RabbitMQ开启了消息确认机制，读过开头提过那篇文章的小伙伴应该知道，线上环境我们为了提高性能一般是不打开确认机制的，这里之所以打开，是为了演示消息的投递情况，同时也为了特别讲后面延迟插件会出现的一个问题。
5、创建生产者
这里加了诸如消息唯一ID、消息确认机制的写法，单纯为了展示给大家看，实际上你可以不加。
6、创建消费者
这里注意，监听的队列也就是我们前面声明的死信队列，因为过期的消息都通过绑定的死信交换机转发到了里面，如果对过程有疑惑，可以回到开头的图解那里对着图片来看。
7、测试接口
分别创建了5s延迟和15min延迟的测试接口
8、效果
延迟插件方式
插件方式，要比死信队列方式简单得多，只需要安装插件，启动插件功能，然后创建延迟队列即可。
1、安装插件
这里给出源码安装方式和docker安装方式，大家根据各自情况自己选。
1）、源码安装
下载插件：
转载请注明地址:http://www.1xbbk.net/jwbys/4240.html
