浅析Laravel5中队列的配置及使用

前言

队列常常用于两种场景，一种是高并发的情况，一种是耗时的操作，可以将任务放到队列中去，消费者从队列取任务执行，当然还有失败的情况如何处理，以及延迟，重试，更复杂的情况还有优先级的实现。

在Laravel 5中使用队列非常简单，并且失败处理，延迟，重试的方法都已经实现，下面简单尝试了一下Laravel的队列服务。

Laravel默认支持以下几种队列服务：sync, database, beanstalkd, sqs, redis，本例使用redis作为队列服务，需先配置好Redis服务。

1.队列服务配置

在配置文件queue.php的connections中已经默认定义了redis的连接：

'redis' => [ 'driver'  => 'redis', 'connection' => 'default', 'queue'  => 'default', 'expire'  => 60,],

在.env环境配置文件中把默认的队列驱动改成redis：

QUEUE_DRIVER=redis

为了避免配置缓存的影响，执行以下命令清除并重建配置缓存：

php artisan config:cache

2.新建Queueable Jobs

使用命令：

php artisan make:job MyJob

新建一个名为MyJob的队列处理类，在App/Jobs目录下自动生成一个MyJob.php文件。

MyJob.php需要实现handle方法，用来具体执行队列任务，构造函数可以用来传递需要的参数，handle方法支持依赖注入。

这里handle方法随便写了一个，就是往一个list类型数据结构中存一个key-value数据，测试消费队列的时候有没有起作用，构造函数传两个参数就是key和value.

<?phpnamespace App/Jobs;use App/Jobs/Job;use Illuminate/Queue/SerializesModels;use Illuminate/Queue/InteractsWithQueue;use Illuminate/Contracts/Queue/ShouldQueue;use Illuminate/Support/Facades/Redis;class MyJob extends Job implements ShouldQueue{ use InteractsWithQueue, SerializesModels; private $key; private $value; /**  * Create a new job instance.  *  * @return void  */ public function __construct($key, $value) {  $this->key = $key;  $this->value = $value; } /**  * Execute the job.  *  * @return void  */ public function handle() {  Redis::hset('queue.test', $this->key, $this->value); } public function failed() {  dump('failed'); }}

在控制器中使用dispatch方法调用队列，将任务放入队列中，控制器中写个方法如public function test()，new MyJob的构造函数传两个随机生成的字符串参数：