thinkphp中使用queue

1、安装 thinkphp-queue

推荐使用Composer进行安装，切换到项目的根目录，执行： composer require topthink/think-queue

2、配置消息队列的存储环境

配置文件位于 application\extra\queue.php，如图：

使用Redis驱动，如果Redis环境还没有安装，请自行安装哦，很简单的，或者也可以使用其他类型驱动

3、任务的创建

4、任务消息的消费以及删除处理

我们在 index模块下创建一个 job 文件，该文件用来处理消费模式；

在 Demo 这个类下，创建一个 fire 方法，该方法是消息队列默认调用的方法。

5、监听任务并执行

php think queue:listen

php think queue:work –daemon（不加–daemon为执行单个任务）

可配合supervisor使用，保证进程常驻

supervisor使用链接：Supervisor使用详解 - 简书