laravel 基于redis队列

'default' =>env('QUEUE_CONNECTION', 'redis'),

<?php

namespace App\Jobs;

use App\Lib\Output\Log;
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\DB;

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

    /**
     * 任务最大尝试次数。
     * @var int
     */
    public $tries = 5;

    /**
     * data 实例
     *
     */
    public $data;

    /**
     * 创建工作实例
     *
     * @param $data
     * @return void
     */
    public function __construct($data)
    {
        $this->data = $data;
    }

    //        //调用
//        $data = [
//            [
//                'title' => 'a1',
//                'sort'  => '11',
//            ],
//            [
//                'title' => 'a2',
//                'sort'  => '22',
//            ],
//        ];
//        $res  = EmailJob::dispatch($data)->onQueue('emailQueue');
//        var_dump($res);
//        die();
    /**
     * 执行任务
     *
     * @return void
     */
    public function handle()
    {
        //处理业务逻辑
        Log::info('jobowen', $this->data);
        foreach ($this->data as $datum) {
            DB::table('copywriting_config')->insert([
                'title' => $datum['title'],
                'sort'  => $datum['sort'],
            ]);
        }
    }

    /**
     * 任务失败的处理过程
     *
     * @param \Exception $exception
     * @return void
     */
    public function failed(\Exception $exception)
    {
        // 给用户发送任务失败的通知，等等……
        Log::info('jobowenException', $exception->getMessage());
    }

}

php artisan queue:work --queue=emailQueue