前言
队列常常用于两种场景，一种是高并发的情况，一种是耗时的操作，可以将任务放到队列中去，消费者从队列取任务执行，当然还有失败的情况如何处理，以及延迟，重试，更复杂的情况还有优先级的实现。
在laravel 5中使用队列非常简单，并且失败处理，延迟，重试的方法都已经实现，下面简单尝试了一下laravel的队列服务。
laravel默认支持以下几种队列服务：sync, database, beanstalkd, sqs, redis，本例使用redis作为队列服务，需先配置好redis服务。
在配置文件queue.php的connections中已经默认定义了redis的连接：
|
1
2
3
4
5
6
|
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => 'default',
'expire' => 60,
],
|
|
1
|
queue_driver=redis
|
|
1
|
php artisan config:cache
|
2.新建queueable jobs
使用命令：
|
1
|
php artisan make:job myjob
|
新建一个名为myjob的队列处理类，在app/jobs目录下自动生成一个myjob.php文件。
myjob.php需要实现handle方法，用来具体执行队列任务，构造函数可以用来传递需要的参数，handle方法支持依赖注入。
这里handle方法随便写了一个，就是往一个list类型数据结构中存一个key-value数据，测试消费队列的时候有没有起作用，构造函数传两个参数就是key和value.
|
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:default的list结构中：
其中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就开始消费队列。
可以看到这几个任务以此被消费，再去redis看看有没有实现预期要达到的效果，每个任务往一个list类型的结构写入数据。
这证明队列任务消费成功。
总结
本文的内容到这就结束了，当然，还有更多laravel队列的用法，可以请大家继续参考官方手册。希望本文的内容对大家学习laravel有所帮助。
原文链接：http://blog.tanteng.me/2016/07/laravel-5-queue/
相关文章
- 个人网站搭建：如何挑选具有弹性扩展能力的服务器？ 2025-06-10
- 个人服务器网站搭建：如何选择适合自己的建站程序或框架？ 2025-06-10
- 64M VPS建站：能否支持高流量网站运行？ 2025-06-10
- 64M VPS建站：怎样选择合适的域名和SSL证书？ 2025-06-10
- 64M VPS建站：怎样优化以提高网站加载速度？ 2025-06-10
