Docker 下 RabbitMQ 延时队列实战两部曲之一：极速体验
欢迎访问我的 GitHub
这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos
关于延时队列
有的应用场景中，向 RabbitMQ 发出消息后，我们希望消费方不要立即消费，可以通过延时队列来实现，思路是将消息发送到 A 队列，此队列没有消费者，等消息过期后会进入 A 队列的 Dead Letter Exchange 中，B 队列绑定了这个 Dead Letter Exchange，消费方只要消费 B 队列的消息，就能实现延时消费了，如下图所示：
延时的时长
从上面的描述可以看出，延时时长就是消息的过期时间 TTL（Time To Live），这个参数可以通过以下两种方式设置：
生产消息时，设置该消息的 TTL；
设置整个队列的 TTL，队列中每个消息的 TTL 都是一样的；
接下来的实战，我们将上述两种方式都体验一次；
环境信息
操作系统：Ubuntu 16.04.3 LTS
Docker：1.12.6
RabbitMQ：3.7.5-rc.1
极速体验
本章是《Docker 下 RabbitMQ 延时队列实战两部曲》系列的第一篇，重点是极速体验，先看一下即将体验的整体结构图：
简单说一下上图中应用的身份：
delayrabbitmqconsumer：SpringBoot 框架的应用，连接 RabbitMQ 的两个队列，消费消息；
messagettlproducer：SpringBoot 框架的应用，收到 web 请求后向 RabbitMQ 发送消息，消息中带有过期时间（TTL）；
queuettlproducer：SpringBoot 框架的应用，收到 web 请求后向 RabbitMQ 发送消息，消息中不带过期时间（TTL），但是对应的消息队列已经设置了过期时间；
开始实战：
确保当前电脑上 Docker 可用，创建 docker-compose.yml 文件，内容如下：
在 docker-compose.yml 文件所在目录执行命令 docker-compose up -d，docker 会先去下载镜像，然后创建多个容器，请静候启动完成，如下：
一共启动了 5 个容器，将他们的名称和作用列举到下面表格中：
我的电脑 IP 地址是 192.168.31.102，因此在浏览器输入：http://:192.168.31.102:15672 ，可以进入 RabbitMQ 的登录页面，如下图：
登录用户名：admin，密码：888888，登录后页面如下图，可以见到 RabbitMQ 集群已经就绪：
如果您的页面中的三个 RabbitMQ 还没有完全就绪（绿色状态），建议稍等几分钟后再刷新页面；
我的电脑 IP 地址是 192.168.31.102，因此在浏览器输入：http://192.168.31.102:18080/messagettl/aaa/bbb/3 ，即可向 delaymq_messagettlproducer_1 容器发起一次请求，容器会发送一条带有 TTL 的消息，然后页面提示发送成功，如下图：
在浏览器输入：http://192.168.31.102:18081/queuettl/ccc/ddd ，即可向 delaymq_queuettlproducer_1 容器发起一次请求，容器会向一个已经设置了 TTL 的队列发送一条消息，然后页面提示发送成功，如下图：
再次进入 RabbitMQ 管理页面 http://:192.168.31.102:15672 ，查看队列情况如下图，已经有四个队列了：
用下列表格对上述四个队列简单说明：
容器 delaymq_delayrabbitmqconsumer_1 中的 tomcat 在启动时候，由于此时队列还没创建，因此无法连接队列，会导致 tomcat 启动失败，进而导致容器退出(因为 tomcat 进程占据了控制台，它退出容器就会退出)，此时请执行 docker restart delaymq_delayrabbitmqconsumer_1 重启容器；
重启后，执行命令 docker logs -f delaymq_delayrabbitmqconsumer_1，开始实时打印消费者容器的日志，可以看到 SpringBoot 刚刚启动就把之前的两条消息给消费了，如下图红框所示：
在浏览器输入：http://192.168.31.102:18080/messagettl/aaa01/bbb01/10 ，url 中的 10 表示延时十秒，去看 delaymq_delayrabbitmqconsumer_1 的日志，果然，10 秒钟后日志才会打印出来，如下所示，消息中的时间和日志的时间戳相差 10 秒：
在浏览器输入：http://192.168.31.102:18081/queuettl/ccc01/ddd01 ，会发送消息到队列 queue.ttl.queue.source，这个队列的 TTL 是 5 秒，在 delaymq_delayrabbitmqconsumer_1 的日志中可以看见发起和收到时间正好差 5 秒，如下：
至此，咱们的极速体验延时队列实战就结束了，接下来的章节，我们一起实战详细的开发过程《Docker 下 RabbitMQ 延时队列实战两部曲之二：细说开发》
欢迎关注 InfoQ：程序员欣宸
版权声明: 本文为 InfoQ 作者【程序员欣宸】的原创文章。
原文链接:【http://xie.infoq.cn/article/1140b48cb9a1e7dbfcf855698】。文章转载请联系作者。
搜索"程序员欣宸"，一起畅游Java宇宙 2018.04.19 加入
前腾讯、前阿里员工，从事Java后台工作，对Docker和Kubernetes充满热爱，所有文章均为作者原创，个人Github：https://github.com/zq2599/blog_demos
评论