Maison >développement back-end >tutoriel php >Chaînes de file d'attente plus propres avec l'intégration de l'énumération de Laravel

Chaînes de file d'attente plus propres avec l'intégration de l'énumération de Laravel

Johnathan Smith
Johnathan Smithoriginal
2025-03-10 11:53:11831parcourir

Cleaner Queue Chains with Laravel's Enum Integration

Laravel prend désormais en charge l'utilisation des énumérations avec des valeurs de secours directement dans la méthode onQueue de la façade de bus, sans accéder manuellement à l'attribut value de l'énumération. Cette amélioration crée un code plus propre et plus expressif lors de la gestion des chaînes de travail et des files d'attente.

Cette amélioration est particulièrement utile lors de la création de pipelines de travail complexes qui doivent être dirigés vers différentes files d'attente en fonction de la priorité, des exigences de ressources ou de la logique métier.

use App\Enums\QueueType;

// 直接使用枚举,无需 ->value
Bus::chain($jobs)
    ->onQueue(QueueType::Background)
    ->dispatch();

Ce qui suit est un exemple réel de l'implémentation d'un système de traitement de documents:

<?php namespace App\Enums;

enum ProcessingQueue: string
{
    case Immediate = 'realtime';
    case Standard = 'default';
    case Batch = 'batch-process';
    case LowPriority = 'low-priority';
}

namespace App\Services;

use App\Enums\ProcessingQueue;
use App\Jobs\ProcessDocument;
use App\Jobs\GenerateThumbnail;
use App\Jobs\ExtractMetadata;
use App\Jobs\NotifyUser;
use App\Models\Document;
use Illuminate\Support\Facades\Bus;

class DocumentProcessor
{
    public function process(Document $document, bool $isPriority = false)
    {
        $queue = $isPriority
            ? ProcessingQueue::Immediate
            : ProcessingQueue::Standard;

        Bus::chain([
            new ProcessDocument($document),
            new ExtractMetadata($document),
            new GenerateThumbnail($document),
            new NotifyUser($document->user, 'Document processing complete')
        ])
        ->onQueue($queue)
        ->dispatch();

        return $document;
    }

    public function batchProcess(array $documentIds)
    {
        foreach ($documentIds as $id) {
            $document = Document::find($id);

            Bus::chain([
                new ProcessDocument($document),
                new GenerateThumbnail($document)
            ])
            ->onQueue(ProcessingQueue::Batch)
            ->dispatch();
        }
    }
}

Cette amélioration simplifie la mise en œuvre des files d'attente tout en maintenant la sécurité du type et améliorer la lisibilité du code.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn