## **简介**
传统的程序执行流程一般是 即时|同步|串行的，在某些场景下，会存在并发低，吞吐量低，响应时间长等问题。在大型系统中，一般会引入消息队列的组件，将流程中部分任务抽离出来放入消息队列，并由专门的消费者作针对性的处理，从而降低系统耦合度，提高系统性能和可用性。
一般来说，可以抽离的任务具有以下的特点：
* **允许延后|异步|并行处理**（相对于传统的**即时|同步|串行**的执行方式）
* **允许延后**：
抢购活动时，先快速缓冲有限的参与人数到消息队列，后续再排队处理实际的抢购业务；
* **允许异步**：
业务处理过程中的邮件，短信等通知
* **允许并行**：
用户支付成功之后，邮件通知，微信通知，短信通知可以由多个不同的消费者并行执行，通知到达的时间不要求先后顺序。
* **允许失败和重试**
* 强一致性的业务放入核心流程处理
* 无一致性要求或最终一致即可的业务放入队列处理
thinkphp-queue是thinkphp 官方提供的一个消息队列服务，它支持消息队列的一些基本特性：
* 消息的**发布**，**获取**，**执行**，**删除**，**重发**，**失败处理**，**延迟执行**，**超时控制**等
* 队列的**多队列**，**内存限制**，**启动**，**停止**，**守护**等
* 消息队列可**降级为同步执行**
thinkphp-queue 内置了**Redis**，**Database**，**Topthink**，**Sync**这四种驱动。本文主要介绍 thinkphp-queue 结合其内置的 redis 驱动的使用方式和基本原理。
## **安装**
> composer require topthink/think-queue
## **配置**
> 配置文件位于`config/queue.php`
### 公共配置
~~~
[
'default'=>'sync' //驱动类型，可选择 sync(默认):同步执行，database:数据库驱动,redis:Redis驱动//或其他自定义的完整的类名
]
~~~
## **创建任务类**
> 单模块项目推荐使用`app\job`作为任务类的命名空间 多模块项目可用使用`app\module\job`作为任务类的命名空间 也可以放在任意可以自动加载到的地方
任务类不需继承任何类，如果这个类只有一个任务，那么就只需要提供一个`fire`方法就可以了，如果有多个小任务，就写多个方法，下面发布任务的时候会有区别
每个方法会传入两个参数`think\queue\Job $job`（当前的任务对象） 和`$data`（发布任务时自定义的数据）
还有个可选的任务失败执行的方法`failed`传入的参数为`$data`（发布任务时自定义的数据）
### 下面写两个例子
```
namespace app\job;
use think\queue\Job;
class Job1{
public function fire(Job $job, $data){
//....这里执行具体的任务
if ($job->attempts() > 3) {
//通过这个方法可以检查这个任务已经重试了几次了
}
//如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
$job->delete();
// 也可以重新发布这个任务
$job->release($delay); //$delay为延迟时间
}
public function failed($data){
// ...任务达到最大重试次数后，失败了
}
}
```
```
namespace app\lib\job;
use think\queue\Job;
class Job2{
public function task1(Job $job, $data)
{
}
public function task2(Job $job, $data)
{
}
public function failed($data)
{
}
}
```
## **发布任务**
```
// 立即执行
think\facade\Queue::push($job, $data = '', $queue = null)
// 在`$delay`秒后执行
think\facade\Queue::later($delay, $job, $data = '', $queue = null)
```
`$job`是任务名
单模块的，且命名空间是`app\job`的，比如上面的例子一,写`Job1`类名即可
多模块的，且命名空间是`app\module\job`的，写`model/Job1`即可
其他的需要些完整的类名，比如上面的例子二，需要写完整的类名`app\lib\job\Job2`
如果一个任务类里有多个小任务的话，如上面的例子二，需要用@+方法名`app\lib\job\Job2@task1`、`app\lib\job\Job2@task2`
`$data`是你要传到任务里的参数
`$queue`队列名，指定这个任务是在哪个队列上执行，同下面监控队列的时候指定的队列名,可不填
## **监听任务并执行**
```
php think queue:listen
php think queue:work
```
两种，具体的可选参数可以输入命令加`--help`查看
> 可配合supervisor使用，保证进程常驻
