Laravel 队列服务

Caizhenhao 发布于2019-06-27 14:49 / 2091人阅读

摘要：按照配置文件注册一个默认连接方式在此使用注册队列各种命令队列连接重启等。上面任务进入队列的整个流程就明白了。

看完文档后总想知道是怎么样一个开始，又是怎样的一个结束！图片来源

QueueServiceProvider

Laravel 各种服务的注册大多都是通过各种 ServiceProvider 进行绑定的，队列服务也不例外，打开 namespace IlluminateQueueQueueServiceProvider 文件定位到 register 方法，

public function register()
{
   // 注册队列管理器 一旦实例化，为队列连接器注册各种解析器，这些连接器负责创建接受队列配置和实例化各种不同队列处理的类。
   // 按照配置文件注册一个默认连接方式 在此使用 redis
    $this->registerManager();
   // 注册队列各种命令 队列连接 重启等。
    $this->registerWorker();
   // 注册队列监听命令
    $this->registerListener();
   // 5.1后弃用
    $this->registerSubscriber();
   // 注册队列失败处理
    $this->registerFailedJobServices();
   // Register the Illuminate queued closure job. 什么用，后面再看。
    $this->registerQueueClosure();
}

任务创建与分配

php artisan make:job SendReminderEmail

按照文档的方式生成了一个队列任务类，该类继承了 namespaceAppJobsJob, 实现了接口 SelfHandling 和 ShouldQueue , 或许你会问这两个接口啥规范都没规定啥用啊(先略过)，重点在两个 trait 内，对队列任务实现了各种操作，删除，重试，延迟等。
在分配任务的时候我们使用了辅助函数 dispatch ，其实是 IlluminateBus 下 Dispatcher 类的 dispatch方法

public function dispatch($command, Closure $afterResolving = null)
{    

    if ($this->queueResolver && $this->commandShouldBeQueued($command)) {
        // 队列执行
        return $this->dispatchToQueue($command);
    } else {
        // 立即执行
        return $this->dispatchNow($command, $afterResolving);
    }
}
protected function commandShouldBeQueued($command)
{
    if ($command instanceof ShouldQueue) {  // 就这用。。
        return true;
    }

    return (new ReflectionClass($this->getHandlerClass($command)))->implementsInterface(
        "IlluminateContractsQueueShouldQueue"
    );
}

在此，我们先看下 namespace IlluminateBusBusServiceProvider 下的

public function register()
{
    $this->app->singleton("IlluminateBusDispatcher", function ($app) {
        return new Dispatcher($app, function () use ($app) {

        // "queue.connection" => "IlluminateContractsQueueQueue", 再回看 QueueServiceProvider 的 registerManager 方法，就很清晰了。

            return $app["IlluminateContractsQueueQueue"]; // 默认队列连接
        });
    });
}

下面看 dispatchToQueue

public function dispatchToQueue($command)
{
    $queue = call_user_func($this->queueResolver); // 在此为设置的默认值 将实例化 RedisQueue
    
    // 异常则抛出！
    if (! $queue instanceof Queue) {
        throw new RuntimeException("Queue resolver did not return a Queue implementation.");
    }
    if (method_exists($command, "queue")) {
        // 可以自定义
        return $command->queue($queue, $command);
    } else {
        // 在此使用的是进入队列方式  最终结果类似 $queue->push(); 看 RedisQueue 下的 push 方法。
        return $this->pushCommandToQueue($queue, $command);
    }
}

上面任务进入队列的整个流程就明白了。那任务出队列呢？在文档中我们可以看到，我们通过执行 php artisan queue:work 这条语句进行队列的监听，那在此就看下 namespace IlluminateQueueConsoleWorkCommand::fire()，夜很深了，下面自己看吧！

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/22045.html

laravel 队列

摘要：如果任务没有在规定时间内完成，那么该有序集合的任务将会被重新放入队列中。这两个进程操纵了三个队列，其中一个，负责即时任务，两个，负责延时任务与待处理任务。如果任务执行成功，就会删除中的任务，否则会被重新放入队列中。在实际的项目开发中，我们经常会遇到需要轻量级队列的情形，例如发短信、发邮件等，这些任务不足以使用 kafka、RabbitMQ 等重量级的消息队列，但是又的确需要异步、重试...

BDEEFE 2019-07-01 10:35 评论0 收藏0
Laravel5.2队列驱动expire参数设置带来的重复执行问题数据库驱动

摘要：已经取消了参数，都用来执行。取数据的过程事物处理已经打开。取得符合条件的队列后程序会更新该条数据，并且更新完后即。 connections => [ .... database => [ driver => database, table => jobs, queue => defaul...

ysl_unh 2019-06-27 16:26 评论0 收藏0
centos 7 使用supervisor 管理laravel 队列

摘要：使用开发的一个服务，是系统下的一个进程管理工具。一切就绪后，我们使用如下命令就可以启动队列进程的监听了这里值得注意的是，如果处理队列的代码更改了，需要重启的队列管理才能生效。 supervisor使用python开发的一个client/server服务，是linux/unix系统下的一个进程管理工具。它可以很方便的监听、停止、重启一个或多个进程。用supervisor管理的进程,打你...

only_do 2019-06-28 13:22 评论0 收藏0
分析Laravel队列实现原理解决问题记录

摘要：在使用中的队列时，产生冲突干扰。文件中的配置部分至此，两个项目的队列冲突原因就找到了。队列监听最后遇到问题，莫要病急乱投医。从代码入手，分析理解实现原理，找对点，解决方法也许很简单，。问题公司项目使用Laravel的开发的两个项目在同一个测试服务器部署，公用同一个redis。在使用laravel中的队列时，产生冲突干扰。查找问题原因在laravel 队列的操作类 Illumin...

Corwien 2019-06-28 13:31 评论0 收藏0