前言
队列常常用于两种场景,一种是高并发的情况,一种是耗时的操作,可以将任务放到队列中去,消费者从队列取任务执行,当然还有失败的情况如何处理,以及延迟,重试,更复杂的情况还有优先级的实现。
在Laravel 5中使用队列非常简单,并且失败处理,延迟,重试的方法都已经实现,下面简单尝试了一下Laravel的队列服务。
Laravel默认支持以下几种队列服务:sync
,database
,beanstalkd
,sqs
,redis
,本例使用redis
作为队列服务,需先配置好Redis
服务。
1.队列服务配置
在配置文件queue.PHP的connections
中已经默认定义了redis
的连接:
在
.env
环境配置文件中把默认的队列驱动改成redis
:
为了避免配置缓存的影响,执行以下命令清除并重建配置缓存:
2.新建Queueable Jobs
使用命令:
新建一个名为
MyJob
的队列处理类,在App/Jobs
目录下自动生成一个MyJob.PHP
文件。MyJob.PHP需要实现handle
方法,用来具体执行队列任务,构造函数可以用来传递需要的参数,handle
方法支持依赖注入。
这里handle
方法随便写了一个,就是往一个list
类型数据结构中存一个key-value
数据,测试消费队列的时候有没有起作用,构造函数传两个参数就是key
和value
.
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);
}
在控制器中使用dispatch
方法调用队列,将任务放入队列中,控制器中写个方法如public function test()
,new MyJob
的构造函数传两个随机生成的字符串参数:
配置并访问路由,可以多访问几次,然后到Redis
中查看,会发现把队列存入了一个queue::queue:default
的List
结构中:
其中value
内容如下,这是转换成json
格式的,而实际上是经过序列号的字符串:
这里data
参数里包含了队列服务Job
的名称,构造函数的参数等信息,消费者执行任务的依据。attempts
表示重试的次数,往往执行队列任务失败了会重试,可以设置最多尝试次数。
3.消费队列
这个时候任务只是入了队列,但并没有消费,执行:
这个命令,Laravel就开始消费队列。
可以看到这几个任务以此被消费,再去Redis
看看有没有实现预期要达到的效果,每个任务往一个List
类型的结构写入数据。
这证明队列任务消费成功。
总结
本文的内容到这就结束了,当然,还有更多Laravel队列的用法,可以请大家继续参考官方手册。希望本文的内容对大家学习Laravel有所帮助。