Laravel 5.2 队列的配置和使用方法

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

在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:

PHP

QUEUE_DRIVER=redis

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

php artisan config:cache

2.新建Queueable Jobs

使用命令:

PHP

php artisan make:job MyJob

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

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

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

<?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的构造函数传两个随机生成的字符串参数:

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

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

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

{
    "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.消费队列

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

php artisan queue:listen

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

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

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

时间: 2024-07-30 07:14:17

Laravel 5.2 队列的配置和使用方法的相关文章

Laravel Memcached缓存驱动的配置与应用方法分析_php实例

本文实例讲述了Laravel Memcached缓存驱动的配置与应用方法.分享给大家供大家参考,具体如下: Memcached缓存配置在任何php环境下我们都可以配置使用来提升WEB的性能.对于大型网站(数据多,访问量大)而言,缓存系统是必备组件,其为减轻数据库负载.提高页面访问速度.提升系统性能立下汗马功劳.Laravel作为一个功能完善且强大的PHP框架,自然为缓存系统提供了支持.目前Laravle支持的缓存驱动包括文件.数组.数据库.APC.Memcached和Redis,并且为这些驱动提

Laravel Memcached缓存驱动的配置与应用方法分析

本文实例讲述了Laravel Memcached缓存驱动的配置与应用方法.分享给大家供大家参考,具体如下: Memcached缓存配置在任何php环境下我们都可以配置使用来提升WEB的性能.对于大型网站(数据多,访问量大)而言,缓存系统是必备组件,其为减轻数据库负载.提高页面访问速度.提升系统性能立下汗马功劳.Laravel作为一个功能完善且强大的PHP框架,自然为缓存系统提供了支持.目前Laravle支持的缓存驱动包括文件.数组.数据库.APC.Memcached和Redis,并且为这些驱动提

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

前言 队列常常用于两种场景,一种是高并发的情况,一种是耗时的操作,可以将任务放到队列中去,消费者从队列取任务执行,当然还有失败的情况如何处理,以及延迟,重试,更复杂的情况还有优先级的实现. 在Laravel 5中使用队列非常简单,并且失败处理,延迟,重试的方法都已经实现,下面简单尝试了一下Laravel的队列服务. Laravel默认支持以下几种队列服务:sync, database, beanstalkd, sqs, redis,本例使用redis作为队列服务,需先配置好Redis服务. 1.

phpMyAdmin“无法载入mysql扩展,请检查PHP配置”的解决方法

phpMyAdmin"无法载入mysql扩展,请检查PHP配置"的解决方法 在配置了PHP的运行环境,并且安装了MySQl数据库之后,下面就可以学习下PHP如何与MySQL进行交互了. 既然MySQL是数据库,则必不可少的需要建立数据库.表.字段等操作(假象下我们使用ASP+ACCESS的情形),然而对于MySQL数据库而言,在我们默认安装时是没有可视化界面操作MySQl的,所以我们很多时候是借助phpMyAdmin来操作MySQL数据库的. 然而通过"PHP 5.2.3 i

log4net配置和使用方法分享

 这篇文章主要介绍了log4net配置和使用方法,大家参考使用吧 1.Global.asax文件 代码如下: void Application_Start(object sender, EventArgs e)  { //在应用程序启动时运行的代码 log4net.Config.XmlConfigurator.ConfigureAndWatch(new System.IO.FileInfo(Sxmobi.FileHelper.GetMapPath("~log4net.config"))

Win8设置自动配置脚本的方法

Win8设置自动配置脚本的方法: 1.点击桌面右侧"设置",选择"控制面板",点击"网络和共享中心"; 2.点击"Internet 选项"; 3.点击"连接"中的"局域网设置"; 4.勾选"使用自动配置脚本信息".

cpu-z查看电脑配置数据的方法

  在之前的教程中,我们给大家介绍了CPU-Z的5大功能,使用CPU-Z可以查询电脑的处理器.缓存.主板.内存.显卡以及SPD的信息.不过,很多网友都不知道具体看哪一个项目,因此,在今天的教程中,我们就跟大家分享一下cpu-z 查看电脑配置数据的方法! CPU-Z cpu-z 怎么看电脑配置? 处理器选项卡下面的意的全部都是关于CPU的一些信息[名字]处的名字就是电脑城市常说的一型号.插槽就是这个CPU的能安装在什么样接口的用主板上,如首图. 内存当然就是内存大小的信息比较重要了.还有SPD选项

每次打开office2007都提示安装配置的解决方法

  最近,一些office2007用户反映说,打开office2007都会被提示需要安装配置,然而配置安装完毕,第二次打开office2007还是会提示.一些用户怀疑是不是office2007的注册码过期了,其实不然,出现office2007提示安装配置的罪魁祸首就是一个名叫:Oiffce Setup Cotroller的文件,所以,只要找到这个文件,然后删除掉就可以解决了. office2007打开时提示安装配置的解决方法: 打开电脑中的C盘,然后在C盘地址栏,输入:C:Program Fil

CodeIgniter针对数据库的连接、配置及使用方法_php实例

本文实例讲述了CodeIgniter针对数据库的连接.配置及使用方法.分享给大家供大家参考,具体如下: 1. 数据库: create database test; create table users( id int not null, name varchar(10), pwd varchar(10), email varchar(20) ) insert into users values(1,'shunping','shunping','aa@163.com'); insert into