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

《PHP实战：浅析Laravel5中队列的配置及使用》要点：
本文介绍了PHP实战：浅析Laravel5中队列的配置及使用，希望对您有用。如果有疑问，可以联系我们。

PHP实战前言

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

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

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

PHP实战1.队列服务配置

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

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

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

PHP实战
QUEUE_DRIVER=redis

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

PHP实战
php artisan config:cache

PHP实战2.新建Queueable Jobs

PHP实战使用命令：

PHP实战
php artisan make:job MyJob

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

PHP实战

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

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

PHP实战
<?php
namespace AppJobs;
use AppJobsJob;
use IlluminateQueueSerializesModels;
use IlluminateQueueInteractsWithQueue;
use IlluminateContractsQueueShouldQueue;
use IlluminateSupportFacadesRedis;
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');
 }
}

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

PHP实战
$queueId = $this->dispatch(new MyJob('key_'.str_random(4),str_random(10)));
dd($queueId);

PHP实战配置并访问路由,可以多访问几次,然后到Redis中查看,会发现把队列存入了一个queue::queue:default的List结构中：

PHP实战

PHP实战其中value内容如下,这是转换成json格式的,而实际上是经过序列号的字符串：

PHP实战
{
 "job": "IlluminateQueueCallQueuedHandler@call","data": {
  "command": "O:14:"AppJobsMyJob":6:{s:19:"u0000AppJobsMyJobu0000key";i:1;s:21:"u0000AppJobsMyJobu0000value";i:2;s:10:"connection";N;s:5:"queue";N;s:5:"delay";N;s:6:"u0000*u0000job";N;}"
 },"id": "EV2bhqUlx0T8pRCVHw1qT0fkP8AQcyI8","attempts": 1
}

PHP实战这里data参数里包含了队列服务Job的名称,构造函数的参数等信息,消费者执行任务的依据.attempts表示重试的次数,往往执行队列任务失败了会重试,可以设置最多尝试次数.

PHP实战3.消费队列

PHP实战这个时候任务只是入了队列,但并没有消费,执行：

PHP实战
php artisan queue:listen

PHP实战这个命令,Laravel就开始消费队列.

PHP实战

PHP实战可以看到这几个任务以此被消费,再去Redis看看有没有实现预期要达到的效果,每个任务往一个List类型的结构写入数据.

PHP实战

PHP实战这证明队列任务消费成功.

PHP实战总结

PHP实战本文的内容到这就结束了,当然,还有更多Laravel队列的用法,可以请大家继续参考官方手册.希望本文的内容对大家学习Laravel有所帮助.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!