【笔记】Laravel 使用队列

1、设置队列驱动

可在config/queue.php文件下设置队列的驱动，本文使用database作为驱动

'default' => 'database',

2、创建一个数据表来记住任务

php artisan queue:table
php artisan migrate

执行命令后，数据库会自动创建一个jobs的数据表

3、生成任务类

php artisan make:job SendMessage --queue

这个命令将会在 app/Jobs 下生成一个新的名为SendMessage类

4、将任务推送到队列上

在控制器里可以直接使用$this->dispatch()来推送需要执行的任务到队列里

$this->dispatch(new SendMessage($param));

5、启动队列侦听器

可以通过 queue:listen 命令来运行侦听器

php artisan queue:listen

执行命令后，终端会侦听队列的任务，但一旦关闭了终端，就无法侦听了

6、使侦听器后台运行（不建议使用，建议使用第7点）

linux下可以使用nohup &来后台运行

nohup php artisan queue:listen &

7、使用Supervisor监听进程

centos7安装supervisor

yum install supervisor

安装后，默认在/etc下自动创建一个supervisor的配置文件，vim进入一下

vim /etc/supervisor.conf

拉到最底

files = supervisord.d/*.ini 这句代码说明它会加载supervisord.d文件夹中的所有.ini配置文件

然后在/etc/supervisord.d/目录下创建一个*.ini的文件，使之启动和监控一个 queue:work 进程

cd /etc/supervisord.d
vim send-message.ini

输入以下配置

[program:send-message]
process_name=%(program_name)s_%(process_num)02d
command=php /usr/site/system/artisan queue:work database --sleep=3 --tries=3
autostart=true
autorestart=true
user=root
numprocs=1
redirect_stderr=true
stdout_logfile=/var/log/supervisord/send-message.log

第三行的database为队列所用的驱动，如果为其他驱动，请指定其他驱动的名称

第七行的numprocs为可以通知执行队列的数量，如果需要一个一个的进行执行，请就指定1

第九行为指定的日志文件位置

配置完成后，更行配置并启动监听

sudo supervisorctl reread

sudo supervisorctl update

sudo supervisorctl start send-message:*