本文环境 PHP7.3,Laravel6.0 不懂的可以评论 著作权归OwenZhang所有。商业转载请联系OwenZhang获得授权,非商业转载请注明出处。
'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
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。