Membuat produk kami siap untuk disesuaikan dengan antrian Laravel

pengantar

Apa itu tugas?

<?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);
    }
}

Apa yang kita maksudkan dengan “tugas yang melelahkan”?

<?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;
    }
}

Siapa yang melakukan tugas ini setelah mengirimnya ke antrian?

php artisan queue:work

Seperti yang dikatakan dalam dokumentasi:
Laravel menyertakan pekerja antrian yang memproses tugas baru ketika mereka sedang antri.

Peran Pengawas

Bagaimana saya mengetahui bahwa kode tugas tidak berfungsi?

Anda tidak memiliki permintaan http

<?php

//   

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

//       

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

Anda tidak tahu siapa yang masuk

<?php

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

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

Memahami bagaimana skala

Cakrawala

<?php

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

    ]
]

Konfigurasi saya sendiri

<?php

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

• menelan proses untuk menganalisis data dari aplikasi eksternal;
• pemberitahuan digunakan untuk segera menjadwalkan pemberitahuan jika kesalahan terdeteksi saat menerima data;
• default digunakan untuk tugas-tugas lain yang saya tidak ingin campur dengan proses menelan dan pemberitahuan .

Pengamatan penutup