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使用详解 - 简书