جعل منتجنا جاهزًا للتوسع مع قوائم انتظار Laravel

المقدمة

ما هي المهمة؟

<?php

use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Bus\Queueable;


class CallExternalAPI implements ShouldQueue
{
    use Dispatchable,
        InteractsWithQueue,
        Queueable;
        
    /**
     * @var string
     */
    protected $url;

    /**
     *    .
     *
     * @param array $Data
     */
    public function __construct($url)
    {
        $this->url = $url;
    }
    

    /**
     *  ,   .
     *
     * @return void
     * @throws \Throwable
     */
    public function handle()
    {
        file_get_contents($this->url);
    }
}

ماذا نعني بـ "المهام الشاقة"؟

<?php

class ProjectController 
{
    public function store(Request $request)
    {
        $project = Project::create($request->all());
        
        //  NotifyMembers, TagUserActive, NotifyToProveSource 
        //   ,     
        Notification::queue(new NotifyMembers($project->owners));
        $this->dispatch(new TagUserAsActive($project->owners));
        $this->dispatch(new NotifyToProveSource($project->owners));
        
        return $project;
    }
}

من يقوم بهذه المهام بعد إرسالها إلى قائمة الانتظار؟

php artisan queue:work

كما تقول الوثائق:
يشتمل Laravel على عامل في قائمة الانتظار يقوم بمعالجة المهام الجديدة عندما يتم وضعها في قائمة الانتظار.

دور المشرف

كيف يمكنني معرفة أن رمز المهمة لا يعمل؟

ليس لديك طلب http

<?php

//   

class TagUserJob implements ShouldQueue
{
    public $data;
    
    public function __construct(array $data)
    {
        $this->data = $data;
    }
}

//       

$this->dispatch(new TagUserJob($request->all()));

أنت لا تعرف من قام بتسجيل الدخول

<?php

//   
class TagUserJob implements ShouldQueue
{
    public $user;
    
    public function __construct(User $user)
    {
        $this->user= $user;
    }
}

//       
$this->dispatch(new TagUserJob($request->user()));

افهم كيفية القياس

الأفق

<?php

'production' => [
    'supervisor-1' => [
        'connection' => "redis",
        'queue' => ['adveritisement', 'logs', 'phones'],
        'processes' => 9,
        'tries' => 3,
        'balance' => 'simple', //   simple, auto  null

    ]
]

التكوين الخاص بي

<?php

'production' => [
    'supervisor-1' => [
        'connection' => 'redis',
        'queue' => ['default', 'ingest', 'notifications'],
        'balance' => 'auto',
        'processes' => 15,
        'tries' => 3,
    ],
]

• استيعاب عمليات تحليل البيانات من التطبيقات الخارجية ؛
• تُستخدم الإشعارات لجدولة الإشعارات على الفور إذا تم اكتشاف خطأ أثناء تلقي البيانات ؛
• يستخدم الافتراضي للمهام الأخرى التي لا تريد خلط مع استيعاب و إخطارات العمليات.

الملاحظات الختامية