分享每一天-laravel5.8 基础教程

laravel5.8 基础教程 — 队列

PHP 1728 0 创建时间：2020-08-25 11:40:54

队列

#### laravel 5.8 基础教程 —— 队列

###### 生成任务类

默认的，所有的可队列执行的任务都被存储在 app/Jobs 目录下，你可以通过 Artisan 命令来生成一个新的队列任务：

```php
php artisan make:job ProcessPodcast
```

该命令将会在app/Jobs目录下生成一个新的类，并且该类实现了Illuminate\Contracts\Queue\ShouldQueue接口，告诉Laravel该任务应该被推送到队列而不是同步运行。

###### 任务类结构
任务类非常简单，通常只包含处理该任务的 handle 方法，让我们看一个任务类的例子。在这个例子中，我们模拟管理播客发布服务，并在发布以前上传相应的播客文件：
```php
<?php

namespace App\Jobs;

use App\Podcast;
use App\AudioProcessor;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;

class ProcessPodcast implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

protected $podcast;

/**
     * 创建任务实例
     *
     * @param  Podcast  $podcast
     * @return void
     */
    public function __construct(Podcast $podcast)
    {
        $this->podcast = $podcast;
    }

/**
     * 执行任务
     *
     * @param  AudioProcessor  $processor
     * @return void
     */
    public function handle(AudioProcessor $processor)
    {
        // 处理上传的播客…
    }
}
```
在本例中，注意我们能够直接将Eloquent模型传递到对列任务的构造函数中。由于该任务使用了SerializesModels trait，Eloquent模型将会在任务被执行是优雅地序列化和反序列化。如果你的队列任务在构造函数中接收Eloquent模型，只有模型的主键会被序列化到队列，当任务真正被执行的时候，队列系统会自动从数据库中获取整个模型实例。这对应用而言是完全透明的，从而避免序列化整个Eloquent模型实例引起的问题。

handle方法在任务被队列处理的时候被调用，注意我们可以在任务的handle方法中进行依赖注入。Laravel服务容器会自动注入这些依赖。

如果你想要完全控制容器如何将依赖注入到 handle 方法，可以使用容器的 bindMethod 方法。bindMethod 方法接收一个回调，该回调支持传入任务和容器实例，在这个回调中，你可以随意调用 handle 方法。通常，我们在某个服务提供者中调用这个方法：
```php
use App\Jobs\ProcessPodcast;

$this->app->bindMethod(ProcessPodcast::class.'@handle', function ($job, $app) {
    return $job->handle($app->make(AudioProcessor::class));
});
```
###### 分发任务
创建好任务类后，就可以通过任务自身的 dispatch 方法将其分发到队列。dispatch 方法需要的唯一参数就是该任务的实例:
```php
<?php

namespace App\Http\Controllers;

use App\Jobs\ProcessPodcast;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;

class PodcastController extends Controller
{
    /**
     * Store a new podcast.
     *
     * @param  Request  $request
     * @return Response
     */
    public function store(Request $request)
    {
        // Create podcast...

ProcessPodcast::dispatch($podcast);
    }
}
```
###### 延时分发
有时候你可能想要延迟队列任务的执行，这可以通过在分发任务时使用 delay 方法实现。例如你希望将某个任务在创建 10 分钟以后才执行：
```php
<?php

namespace App\Http\Controllers;

use App\Jobs\ProcessPodcast;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;

ProcessPodcast::dispatch($podcast)
                ->delay(now()->addMinutes(10));
    }
}
```
###### 同步分发
如果你立即想要分发任务（同步），可以使用 dispatchNow 方法。使用这个方法时，对应任务不会被推送到队列，而是立即在当前进程中运行：
```php
<?php

namespace App\Http\Controllers;

use Illuminate\Http\Request;
use App\Jobs\ProcessPodcast;
use App\Http\Controllers\Controller;

ProcessPodcast::dispatchNow($podcast);
    }
}
```

文档地址：https://xueyuanjun.com/post/19516.html#bkmrk-%E5%88%86%E5%8F%91%E4%BB%BB%E5%8A%A1

laravel5.8 基础教程 — 队列

商品推荐

广告推荐

推荐文章