服务器之家

服务器之家 > 正文

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

时间:2021-02-21 15:41     来源/作者:小谈博客

前言

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

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

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

1.队列服务配置

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

?
1
2
3
4
5
6
'redis' => [
 'driver'  => 'redis',
 'connection' => 'default',
 'queue'  => 'default',
 'expire'  => 60,
],

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

?
1
queue_driver=redis

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

?
1
php artisan config:cache

2.新建queueable jobs

使用命令:

?
1
php artisan make:job myjob

新建一个名为myjob的队列处理类,在app/jobs目录下自动生成一个myjob.php文件。

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

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

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
<?php
 
namespace 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的构造函数传两个随机生成的字符串参数:

?
1
2
$queueid = $this->dispatch(new myjob('key_'.str_random(4), str_random(10)));
dd($queueid);

配置并访问路由,可以多访问几次,然后到redis中查看,会发现把队列存入了一个queue::queue:defaultlist结构中:

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

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

?
1
2
3
4
5
6
7
8
{
 "job": "illuminate\\queue\\callqueuedhandler@call",
 "data": {
  "command": "o:14:\"app\\jobs\\myjob\":6:{s:19:\"\u0000app\\jobs\\myjob\u0000key\";i:1;s:21:\"\u0000app\\jobs\\myjob\u0000value\";i:2;s:10:\"connection\";n;s:5:\"queue\";n;s:5:\"delay\";n;s:6:\"\u0000*\u0000job\";n;}"
 },
 "id": "ev2bhqulx0t8prcvhw1qt0fkp8aqcyi8",
 "attempts": 1
}

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

3.消费队列

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

?
1
php artisan queue:listen

这个命令,laravel就开始消费队列。

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

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

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

这证明队列任务消费成功。

总结

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

原文链接:http://blog.tanteng.me/2016/07/laravel-5-queue/

标签:

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
Intellij idea2020永久破解,亲测可用!!!
Intellij idea2020永久破解,亲测可用!!! 2020-07-29
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
返回顶部