PHP 如何通过 rabbitMQ 死信队列实现业务的延时 / 定时操作

前言

之前也通过文章介绍过 rabbitMQ 的搭建以及在 PHP 开发场景下的一些使用。这个主要从 rabbitMQ 的 web 控制台介绍死信队列的操作，以及代码层面的小应用等。关于死信的原理，rabbitMQ 的特性等可以在其他文章中找到，这里就不详细介绍了。

场景

死信的场景主要是用于来实现延迟队列，比如之前介绍的 redis 订阅的过期事件。都是用于在未来某个时间段需要对某些数据进行操作 (删除 / 更新)，就比如某些订单创建成功后添加到一个队列中。程序消费掉一部分已经支付过的订单，而那些未支付状态并且超过 30 分钟 (举例的超时时间) 就将其放入到延迟队列进行批量处理。

死信队列概述

可以把死信队列理解为过滤后的水池，前面的队列就像负责接水的大水池，只有当大水池满了或者过滤筛选过的水才会流入小水池。最后小水池的水再进行饮用或者使用。

流程

1. 创建 1 个死信交换机 (正常创建即可) 和一个死信队列 (正常创建)，二者通过路由键绑定。

2. 创建 1 个业务交换机， 创建一个业务队列，队列关联一个死信交换机及与交换机绑定的一个死信队列路由键。

3. 最后将业务交换机与业务队列绑定。

4. 代码只需要对生产消息到业务队列，消费死信队列的消息就可以。

步骤

1. 通过搭建的地址 xxx.xxx.xxx.xxx:15672 进入 rabbitMQ 的 web 控制台，新建虚拟机并进入。

2. 新建死信交换机和死信队列，如下的 ex_dlx，queue_dlx。

3. 新建业务交换机，和业务队列，队列关联死信交换机。

4. 用代码生产一条消息，然后查看业务队列是否有新消息。

5. 两分钟后 (创建队列时设置) 查看死信队列是否有消息进来，以下表示死信队列已经有新消息。

6. 最后对死信队列的消息用代码进行消费了，表示已经过期的数据。

本作品采用《CC 协议》，转载必须注明作者和本文链接