Laravelキューサービス

QueueServiceProvider

Laravel さまざまなサービスのほとんどの登録はさまざまな ServiceProvider を通じてバインドされており、キュー サービスも例外ではありません。名前空間 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 を実装するキュー タスク クラス。おそらく、何も指定せずにこれら 2 つのインターフェイスを使用するのは何なのかと疑問に思われるかもしれません (最初はスキップしてください)。焦点はさまざまな操作、削除です。キュータスクにはリトライや遅延などが実装されています。
タスクを割り当てるとき、補助関数dispatchを使用します。これは、実際にはIlluminateBusの下のDispatcherクラスのディスパッチメソッドです

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(
        'Illuminate\Contracts\Queue\ShouldQueue'
    );
}

ここでは、まず名前空間IlluminateBusBusServiceProviderの下の

public function register()
{
    $this->app->singleton('Illuminate\Bus\Dispatcher', function ($app) {
        return new Dispatcher($app, function () use ($app) {

        // 'queue.connection' => 'Illuminate\Contracts\Queue\Queue', 再回看 QueueServiceProvider 的 registerManager 方法，就很清晰了。

            return $app['Illuminate\Contracts\Queue\Queue']; // 默认队列连接
        });
    });
}

を見てみましょう

次に、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 職人 queue:work を実行してキューを監視していることがわかります。 名前空間 IlluminateQueueConsoleWorkCommand::fire() を見てみましょう。