Laravel Horizon

composer require laravel/horizon

php artisan horizon:install

'environments' => [
    'production' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => ['default', 'notifications'],
            'balance' => 'auto',
            'autoScalingStrategy' => 'time',
            'minProcesses' => 1,
            'maxProcesses' => 10,
            'balanceMaxShift' => 1,
            'balanceCooldown' => 3,
            'tries' => 3,
            'timeout' => 60,
        ],
    ],

    'local' => [
        'supervisor-1' => [
            // De overige waarden worden overgenomen uit de sectie defaults
            'maxProcesses' => 3,
        ],
    ],
],

use Closure;
use Illuminate\Http\Request;
use Laravel\Horizon\Horizon;
use Symfony\Component\HttpFoundation\Response;

public function handle(Request $request, Closure $next): Response
{
    Horizon::cspNonce('csp-nonce');

    return $next($request);
}

'middleware' => [
    'web',
    App\Http\Middleware\AddHorizonCspNonce::class,
],

'defaults' => [
    'supervisor-1' => [
        'connection' => 'redis',
        'queue' => ['default'],
        'balance' => 'auto',
        'tries' => 1,
        'timeout' => 60,
        'maxProcesses' => 1,
    ],
],

'environments' => [
    'production' => [
        'supervisor-1' => [
            'force' => true,
        ],
    ],
],

'environments' => [
    'production' => [
        'supervisor-1' => [
            'tries' => 10,
        ],
    ],
],

'environments' => [
    'production' => [
        'supervisor-1' => [
            'timeout' => 60,
        ],
    ],
],

// Vaste waarde
'backoff' => 10,

// Stapsgewijs (exponentiële backoff)
'backoff' => [1, 5, 10],

'environments' => [
    'production' => [
        'supervisor-1' => [
            // ...
            'memory' => 128,
            'maxJobs' => 1000,
            'maxTime' => 3600,
            'sleep' => 3,
            'rest' => 0,
            'nice' => 0,
        ],
    ],
],

use App\Models\User;
use Illuminate\Support\Facades\Gate;

protected function gate(): void
{
    Gate::define('viewHorizon', function (User $user) {
        return in_array($user->email, [
            '[email protected]',
        ]);
    });
}

Gate::define('viewHorizon', function (User $user = null) {
    // Wanneer je de toegang beperkt via IP-adressen e.d.
    return true;
});

# Starten
php artisan horizon

# Pauzeren / hervatten
php artisan horizon:pause
php artisan horizon:continue

# Een specifieke supervisor pauzeren / hervatten
php artisan horizon:pause-supervisor supervisor-1
php artisan horizon:continue-supervisor supervisor-1

# Status controleren
php artisan horizon:status
php artisan horizon:supervisor-status supervisor-1

# Netjes afsluiten
php artisan horizon:terminate

npm install --save-dev chokidar
php artisan horizon:listen

# In Docker- / Vagrant-omgevingen
php artisan horizon:listen --poll

sudo apt-get install supervisor

[program:horizon]
process_name=%(program_name)s
command=php /home/forge/example.com/artisan horizon
autostart=true
autorestart=true
user=forge
redirect_stderr=true
stdout_logfile=/home/forge/example.com/horizon.log
stopwaitsecs=3600

sudo supervisorctl reread
sudo supervisorctl update
sudo supervisorctl start horizon

php artisan horizon:terminate

// Een job die een Video-model (id=1) ontvangt → krijgt automatisch de tag "App\Models\Video:1"
RenderVideo::dispatch(Video::find(1));

class RenderVideo implements ShouldQueue
{
    /**
     * @return array<int, string>
     */
    public function tags(): array
    {
        return ['render', 'video:'.$this->video->id];
    }
}

class SendRenderNotifications implements ShouldQueue
{
    public function tags(VideoRendered $event): array
    {
        return ['video:'.$event->video->id];
    }
}

'silenced' => [
    App\Jobs\ProcessPodcast::class,
],

// Silencen per tag
'silenced_tags' => [
    'notifications',
],

use Laravel\Horizon\Contracts\Silenced;

class ProcessPodcast implements ShouldQueue, Silenced
{
    use Queueable;
    // ...
}

// routes/console.php
use Illuminate\Support\Facades\Schedule;

Schedule::command('horizon:snapshot')->everyFiveMinutes();

'metrics' => [
    'trim_snapshots' => [
        'job' => 24,
        'queue' => 24,
    ],
],

php artisan horizon:clear-metrics

use Laravel\Horizon\Horizon;

public function boot(): void
{
    parent::boot();

    Horizon::routeMailNotificationsTo('[email protected]');
    Horizon::routeSlackNotificationsTo('slack-webhook-url', '#ops');
    Horizon::routeSmsNotificationsTo('15556667777');
}

'waits' => [
    'redis:critical' => 30,  // Notificatie bij 30 seconden of meer wachttijd
    'redis:default' => 60,
    'redis:batch' => 120,
],

# Een specifieke mislukte job verwijderen
php artisan horizon:forget 5

# Alle mislukte jobs verwijderen
php artisan horizon:forget --all

# De standaardqueue wissen
php artisan horizon:clear

# Een specifieke queue wissen
php artisan horizon:clear --queue=emails