Laravel中使用Redis作为队列系统的工作流程-mysql教程-PHP中文网

Laravel中使用Redis作为队列系统的工作流程

php中文网

发布： 2016-06-07 16:34:39

原创

1283人浏览过

利用Redis可以很方便的实现一个任务队列，但是在Laravel中，Redis的队列总会出现一个任务多次执行的问题。究其原因是它写死了reserved的时长，也就是如果1分钟后任务没有执行完成，那么这个任务就会被重新放回队列。下面是队列的简单使用和执行原理。设置

利用Redis可以很方便的实现一个任务队列，但是在Laravel中，Redis的队列总会出现一个任务多次执行的问题。究其原因是它写死了reserved的时长，也就是如果1分钟后任务没有执行完成，那么这个任务就会被重新放回队列。下面是队列的简单使用和执行原理。

设置

设置队列使用redis非常容易，在app/config/queue.php中配置

<code>...
'default' => 'redis',
...
'connections' => array(
    ...
    'redis' => array(
        'driver' => 'redis',
        'queue'  => 'waa',
    ),
),
</code>

登录后复制

即可。

使用

使用时不需要多配置，只要写好Queue类和其fire方法，在需要的位置出队即可。具体方法可以看这里。

<code>class SendEmail {
    public function fire($job, $data)
    {
        //
        $job->delete();
    }
}
Queue::push('SendEmail@send', array('message' => $message));
</code>

登录后复制

流程

Laravel利用artisan命令来执行出队操作，然后进行任务的执行。方法调用如下：

artisan queue:work
WorkerCommand:fire()
Worker:pop()
Worker:getNextJob()
RedisQueue:pop()
Worker:process()

我遇到的问题就在这里，在RedisQueue:pop()方法中，有这样一句：

启科网络PHP商城系统

启科网络商城系统由启科网络技术开发团队完全自主开发，使用国内最流行高效的PHP程序语言，并用小巧的MySql作为数据库服务器，并且使用Smarty引擎来分离网站程序与前端设计代码，让建立的网站可以自由制作个性化的页面。系统使用标签作为数据调用格式，网站前台开发人员只要简单学习系统标签功能和使用方法，将标签设置在制作的HTML模板中进行对网站数据、内容、信息等的调用，即可建设出美观、个性的网站。

查看详情

<code>$this->redis->zadd($queue.':reserved', $this->getTime() + 60, $job);
</code>

登录后复制

这里将当前执行的任务放到另外一个reserved队列中，超时时间是60s。也就是说，如果60s后这个任务没有被删除掉，则任务会重新被放入队列中来。因此，在实际的使用过程中，任务很可能被多次执行。解决的办法是

<code>class SendEmail {
    public function fire($job, $data)
    {
        $job->delete();
        // job 
    }
}
</code>

登录后复制

即先删除这个任务，再开始执行任务。

原文地址：Laravel中使用Redis作为队列系统的工作流程, 感谢原作者分享。

大家都在看：

如何使用 EasyWeChat 在 Laravel 框架中轻松封装微信支付和支付宝支付？如何在 Laravel 中整合微信支付和支付宝支付？ Laravel 5.4 中使用 AliSQL 的 SQL 洞察功能时，为什么有些 SQL 语句的参数是问号，而有些则是实际的值？ Laravel 5.4 中 SQL 洞察显示的问号与实际参数值：究竟是何原因？在数据库中更新插入不使用主键或唯一约束的行