Laravel队列实现(概念讲解与Supervisor配置)

为什么要使用队列？

学个框架如果只会写普通业务也太low了，我们要尝试一些高级的玩法(??????)??！

laravel框架里的队列介绍

.

最好的讲解方法当然是举例子啦

• 首先，我们要搞明白几个概念，从小到大依次有：队列任务，队列，连接。他们属于依次被包含的关系，一个队列里有许多的队列任务，一个连接中可以有许多队列

1. 队列任务:对每个用户都会进行的操作，理解为队列任务，比方说用户注册时的，我们发送验证邮件的操作，每个用户注册，我们都会进行，这样的任务我们可以把它抽象成一个队列任务

2. 队列:许多队列挤在一起等着被处理，形成了一个队列

3. 连接:队列的储存形式

4. 队列处理器处理队列任务的进程

• 举例：队列任务：某个操作，例如发邮件这个操作，之后我们会用更简单的操作举例代替

  队列：队列的存在是为了方便之后的队列处理器处理对应的队列任务，我们不做讲解

  连接：database（也就是指mysql），redis等，我们以database为主

实战

1. 通过这个命令生成任务类：

   php artisan make:job SendEmail

.

会在这里生成一个Jobs文件夹以及我们的任务类

顺便建立一个Controller来负责分发任务

php artisan make:controller QueueTest

2.具体的代码实现：

如何在控制器里新建一个job，并传递参数呢？请看：

SendEmail.php:

.

QueueController.php:

.

路由--web.php:

.

建立job数据表:

php artisan queue:tablephp artisan migrate

一个超简易的添加队列流程就完成了，起服务之后，我们用postman或者浏览器等工具发送请求

.

然后你就会发现，即使我们没有添加任务处理器，我们的任务还是嗖的一下被完成了，job表里什么都没有，这是为什么呢？？？

打开.env文件

.

把它改成database，重复刚才的请求，再查看job表

.

3.开启队列任务处理器:

一行命令：php artisan queue:work

这句话能加很多参数，这里不做过多陈述，可以自己查看文档的说明，很容易理解

.

• 我们会发现，任务直接被执行了，这是因为我们刚刚添加任务的时候，是以当时的时间为准并延迟一分钟执行，当我们开启处理器的时候早就到时间啦，所以那个队列任务才会一下子被消费掉

• 用进程管理器supervisor来让我们刚刚的任务管理器永久后台运行，否则我们只能总开着终端窗口才能使任务处理器运行

1. 安装

   pip install supervisor

2. 配置

supervisor的启动非常人性化，在命令行输入echo_supervisord_conf会直接给我们一份默认的配置文件内容，我们将其复制下来，在任意一个当前用户有权限的地方新建一个.ini或者.conf后缀结尾的文件（我创建的路径:/usr/local/etc/supervisord.ini），将内容复制进去，保存即可，但其中有一些内容需要我们略做修改

为了更直观的查看我们的进程运行情况，进行如下修改，去除httpserver和port的注释:

.

这样可以让我们在浏览器里查看进程运行情况

然后最后一行做如下修改:

.

这里面放我们的laravel-worker 配置文件，在这里创建并编辑我们的laravel-worker.ini文件

.

比较重要的几个参数:

command: 这里按我的理解是指 supervisor会对这个command命令所产生的进程进行管理，但是由于我们不在项目文件夹下，不能直接php artisan queue:work,所以我们在artisan前面加上我们的项目路径，被马赛克遮住的部分就是我们laravel项目的文件目录

user: 当前的系统用户名称，root等你当前使用的用户名即可

最后一行的logfile:这里要选择我们拥有权限的目录才可以，而且文件夹和文件需要我们手动帮其创建

如此一来，supervisor的配制就大工告成了

然后 surpervisord -c 配置文件目录启动，而我的命令就是:supervisord -c /usr/local/etc/supervisord.ini

在浏览器里输入http://localhost:9001,就可以看到我们的任务处理器跑起来啦

.

我们的队列任务也顺利执行成功

.

作者：不洗碗工作室