Belajar Laravel - Queues & Jobs

#Pendahuluan

Bayangkan sebuah request yang harus: menyimpan order, mengirim email, menghasilkan PDF, memanggil API pembayaran, dan notifikasi. Jika semuanya dijalankan sinkron di dalam request, user menunggu berdetik-detikk. Lebih buruk lagi: satu langkah gagal, seluruh request gagal. Queues memecahkan ini dengan memindahkan pekerjaan yang tidak harus segera selesai ke background worker.

Di episode ini kita pelajari pola dasarnya — dari mengirim job sampai menjalankan worker — dan mengenal Horizon, dashboard production-grade untuk queue berbasis Redis.

#Konsep Dasar Queue

Alurnya: aplikasi menyimpan "pekerjaan" ke dalam queue dan segera mengembalikan response. Worker yang berjalan terus-menerus mengambil pekerjaan dan menjalankannya. User tidak menunggu — email/PDF/API call dikerjakan belakangan.

#Konfigurasi Queue Driver

Queue driver diatur di .env lewat QUEUE_CONNECTION:

QUEUE_CONNECTION=database

Untuk driver database, buat tabel job-nya:

php artisan queue:table
php artisan migrate

#Membuat Job

php artisan make:job SendWelcomeEmail

<?php
 
namespace App\Jobs;
 
use App\Models\User;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
 
class SendWelcomeEmail implements ShouldQueue
{
    use Queueable;
 
    public function __construct(
        public User $user,
    ) {
    }
 
    public function handle(): void
    {
        // kirim email - dijalankan worker, bukan di request
    }
}

Implementasi ShouldQueue memberi tahu Laravel: job ini harus masuk antrian, bukan dieksekusi sinkron.

#Mengirim Job: dispatch()

use App\Jobs\SendWelcomeEmail;
 
SendWelcomeEmail::dispatch($user);

Response langsung kembali ke user; handle() berjalan di worker. Untuk job yang hampir selalu ingin di-queue, bisa juga dispatchAfterResponse() — dieksekusi setelah response dikirim, tanpa perlu worker terpisah:

SendWelcomeEmail::dispatchAfterResponse($user);

#Delayed dan Job Chaining

ProcessPayment::dispatch($order)->delay(now()->addMinutes(5));
 
SendInvoice::dispatch($order)
    ->chain([
        new UpdateLedger($order),
        new NotifyAccountant($order),
    ]);

Job chaining menjalankan job berurutan; jika salah satu gagal, sisa chain tidak dijalankan — sempurna untuk pipeline yang saling bergantung.

#Retry, Backoff, dan Timeout

Job bisa gagal — karena API down, network hiccup, dan sebagainya. Atur retry dan backoff di job:

class ProcessPayment implements ShouldQueue
{
    public $tries = 3;
 
    public $backoff = [5, 15, 60];  // tunggu 5s, lalu 15s, lalu 60s
 
    public $timeout = 120;          // batasi durasi eksekusi
 
    public function failed(Throwable $e): void
    {
        // dipanggil setelah semua percobaan gagal
    }
}

failed() adalah tempat terakhir untuk mencatat atau mengirim alert. Job yang gagal permanen masuk tabel failed_jobs — audit dengan:

php artisan queue:failed
php artisan queue:retry all
php artisan queue:forget 1
php artisan queue:flush

#Menjalankan Worker

php artisan queue:work

php artisan queue:work --queue=emails,default --tries=3 --sleep=2

• --queue memilih urutan antrian yang diproses.
• --tries membatasi percobaan; --sleep jeda saat queue kosong.
• Di production, worker dijalankan sebagai daemon (supervisor/systemd) agar selalu hidup — bukan sekali jalan.

#Horizon: Dashboard Redis Queues

Horizon adalah dashboard resmi Laravel untuk queue berbasis Redis — menampilkan job yang diproses, failed, throughput, dan queue balancing antar worker:

composer require laravel/horizon
php artisan horizon:install
php artisan migrate

php artisan horizon

php artisan horizon menggantikan queue:work — ia mengelola worker pool secara otomatis sesuai beban, dengan dashboard di /horizon yang bisa dilindungi middleware auth. Horizon adalah jawaban Laravel untuk "bagaimana memantau dan menyeimbangkan queue di production".

#Penutup

Inti yang harus dibawa pulang:

• Pindahkan kerja berat ke queue agar response cepat dan tahan gagal.
• Job mengimplementasikan ShouldQueue; kirim dengan dispatch().
• Manfaatkan delay, chaining, retry/backoff, dan failed() untuk ketahanan.
• Jalankan worker dengan queue:work (daemon di production).
• Horizon untuk memantau dan mengelola Redis queues di production.

Di episode 15 selanjutnya kita akan membahas events, listeners & notifications — make:event/make:listener, Event::dispatch, listeners, serta Notifications via mail/SMS/database dan broadcasting events real-time. Sampai jumpa di episode 15!