laravel队列（一）

laravel队列（一）
-------------
## 数据库驱动
* 修改 .env 中的配置项 QUEUE_DRIVER 为 database
ps:默认是sync

* 首先要创建数据表来存储任务，
> php artisan queue:table
> php artisan migrate

* 创建执行队列的文件
> php artisan make:job SendReminderEmail

```php
<?php

namespace App\Jobs;

use App\User;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\Log;

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

protected $user;

/**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(User $user)
    {
        $this->user=$user;
        //
    }

/**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        //
        Log::info('我是来自队列,发送了一个邮件',['id' => $this->user->id, 'name' => $this->user->name]);
    }
}
```

* 使用
a. 在 Controller 层 $this->dispatch(new SendRemindEmail()) 生产队列，于是 database jobs 中记录了最新添加的队列任务

```php
<?php

namespace App\Http\Controllers\User;

use App\Jobs\SendReminderEmail;
use App\User;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
use Illuminate\Support\Facades\DB;

class JobsController extends Controller
{
    //
    public function jobs()
    {
        $user = User::find(1);
        $this->dispatch(new SendReminderEmail($user));
		
		$this->dispatch((new SendReminderEmail($user))->delay(50)); //delay表示延迟队列执行
    }
}
```

b. 其他地方使用
```php
use DispatchesJobs;
......
$this->dispatch()
```

* 单一消费队列
> php artisan queue:work

默认只执行一次队列请求, 当请求执行完成后就终止；

* 依次消费所有队列
> php artisan queue:listen

监听队列请求，只要运行着，就能一直接受请求，除非手动终止

* 队列重启
> php artisan queue:restart

## 处理失败任务
* 创建一个 failed_jobs 表的迁移
> php artisan queue:failed-table

* 生成表
> php artisan migrate

* 加重试次数限制
> php artisan queue:listen connection-name --tries=3

超过3次的任务将被移到failed_jobs表

* 添加失败任务事件
a. AppServiceProvider中添加

```php
/**
* 启动应用服务
*
* @return void
*/
public function boot()
{
    Queue::failing(function ($connection, $job, $data) {
    // Notify team of failing job...
    });
}
```

b .任务类中添加
```php

/**
* 执行任务
*
* @param Mailer $mailer
* @return void
*/
public function handle(Mailer $mailer)
{
    //
}
 
/**
* 处理失败任务
*
* @return void
*/
public function failed()
{
    // Called when the job is failing...
}
```

* 重试失败任务

a.查看失败的任务
> php artisan queue:failed
 
b.重新执行失败任务
> php artisan queue:retry 5 //重新执行id为5的失败任务
 
c.删除失败任务
> php artisan queue:forget 5 //删除id为5的失败任务
 
d.删除所有失败任务
> php artisan queue:flush

参考：
https://www.cnblogs.com/itfenqing/p/6934184.html

添加新评论

最新文章

最新回复

标签

归档

友情链接