Обработката на видео е една от най-тежките задачи, с които може да се справи уеб приложение. В рамките на контролер, най-вероятно блокирате PHP-FPM нишките си, разочаровайки потребителите си и рискувайки времетраене. shell_exec(‘ffmpeg …’) През 2026 г. ние не правим това, ние третираме видео обработката като , . asynchronous distributed pipeline С освобождаването на Symfony 7.4 имаме нови инструменти, които правят това стабилно и родно. , и на Изграждане на паралелни тръбопроводи. edicated #[Video] validation constraint native support for shared directories, mature Messenger component В тази статия ще изградим архитектура за обработка на видео от производствен клас, която: 
 
 
 
 Validates незабавно качва с помощта на новите ограничения на Symfony 7.4. Изхвърля тежки повдигания на работниците на заден план. Паралелизира задачи (транскодиране, миниатюри, анализ) едновременно. Предпоставки 
 
 
 
 
 PHP 8.2+ (препоръчва се PHP 8.4) Симфония 7.4 (симфония / скелет и симфония / уеб-пакет) FFmpeg инсталиран на вашия сървър/контейнер (sudo apt install ffmpeg). Композиторски пакети:php-ffmpeg/php-ffmpeg(v1.3+)symfony/messenger\symfony/validator Архитектура: Стратегия за споделени директории Когато потребител качи видео към вашия уеб контейнер, вашият работен контейнер (който може да се намира на друг сървър) трябва да има достъп до него. В Симфония 7.4 ние се покланяме на “ " pattern - стандартизирано местоположение за състоятелни данни, споделени между възли (като NFS монти или Docker Volumes). Shared Directory Infrastructure setup (Conceptual): 
 
 
 Уеб възел: Настройва /mnt/shared_storage на ./var/storage. Работещ възел: Монтира същия обем на ./var/хранилище. Ние ще изградим този път в да гарантираме, че нашият код е агностичен за физическото местоположение. services.yaml # config/services.yaml
parameters:
    # The absolute path to the shared storage (mapped volume)
    app.storage_dir: '%kernel.project_dir%/var/storage'

services:
    _defaults:
        autowire: true
        autoconfigure: true
        bind:
            $storageDir: '%app.storage_dir%'
 Валидиране: The New #[Video] Constraint В предишните версии трябваше да разчитаме на генериката. ограничаване и гадание на MIME типове, или напишете сложни потребителски валидатори, за да проверите продължителността и кодеците. File Симфония 7.4 въвежда родния език Използва се, използва се Вътрешно (via за валидиране на метаданни, преди дори да приемете бизнес логиката. #[Video] FFmpeg ffprobe Нека да създадем DTO за нашия upload. // src/Dto/VideoUploadDto.php
namespace App\Dto;

use Symfony\Component\HttpFoundation\File\UploadedFile;
use Symfony\Component\Validator\Constraints as Assert;

final readonly class VideoUploadDto
{
    public function __construct(
        #[Assert\NotBlank]
        #[Assert\Video(
            maxSize: '500M',
            mimeTypes: ['video/mp4', 'video/quicktime', 'video/webm'],
            minWidth: 1280,
            maxWidth: 3840, // 4K limit
            minDuration: 5, // Seconds
            maxDuration: 3600,
            allowPortrait: false, // Enforce landscape
            suggestedExtensions: ['mp4', 'mov']
        )]
        public UploadedFile $file,

        #[Assert\NotBlank]
        #[Assert\Length(min: 5, max: 255)]
        public string $title
    ) {}
}
 Това ограничение изисква ffprobe двоичен да бъде изпълним от уеб потребителя. Съвпадение за: messenger pipelines За да обработваме видео ефективно, не трябва да изпълняваме само един гигантски скрипт. Трябва да разделим работата на тръбопроводи. Когато се качи видео, ще изпратим "Мениджърско съобщение", което след това изпраща подзадачи, които да се изпълняват паралелно. Съобщенията на хората (DTO) Ние използваме readonly класове за непроменливи съобщения обекти. // src/Message/ProcessVideoUpload.php
namespace App\Message;

/**
 * The Trigger: Dispatched immediately after upload.
 */
final readonly class ProcessVideoUpload
{
    public function __construct(
        public string $videoId,
        public string $filename
    ) {}
}
 // src/Message/TranscodeVideo.php
namespace App\Message;

/**
 * Sub-Task: Heavy encoding work.
 */
final readonly class TranscodeVideo
{
    public function __construct(
        public string $videoId,
        public string $filename,
        public string $targetFormat // e.g., 'hls', 'mp4-720p'
    ) {}
}
 // src/Message/GenerateThumbnail.php
namespace App\Message;

/**
 * Sub-Task: Image extraction.
 */
final readonly class GenerateThumbnail
{
    public function __construct(
        public string $videoId,
        public string $filename,
        public int $timestamp
    ) {}
}
 Конфигуриране на транспорта Необходими са поне два вида транспорт: 
 
 
 async_priority: За бързи задачи (малки изображения, актуализации на бази данни). async_heavy: За дълги задачи (транскодиране). Това предотвратява 10-минутно 4K кодиране да блокира генерирането на миниатюри. # config/packages/messenger.yaml
framework:
    messenger:
        failure_transport: failed

        transports:
            # Fast lane
            async_priority:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    queue_name: priority_queue

            # Slow lane (Heavy video processing)
            async_heavy:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    queue_name: video_encoding_queue
                    # Increase timeout for workers on this queue
                    auto_setup: true

            failed: 'doctrine://default?queue_name=failed'

        routing:
            'App\Message\ProcessVideoUpload': async_priority
            'App\Message\GenerateThumbnail': async_priority
            'App\Message\TranscodeVideo': async_heavy
 Логиката на обработката Ние ще използваме библиотека. Първо инсталирайте го: php-ffmpeg composer require php-ffmpeg/php-ffmpeg
 Мениджърът Handler Този манипулатор получава първоначалното събитие за качване и „излъчва“ работата. // src/MessageHandler/ProcessVideoUploadHandler.php
namespace App\MessageHandler;

use App\Message\GenerateThumbnail;
use App\Message\ProcessVideoUpload;
use App\Message\TranscodeVideo;
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;
use Symfony\Component\Messenger\MessageBusInterface;

#[AsMessageHandler]
final readonly class ProcessVideoUploadHandler
{
    public function __construct(
        private MessageBusInterface $bus,
        private LoggerInterface $logger
    ) {}

    public function __invoke(ProcessVideoUpload $message): void
    {
        $this->logger->info("Starting pipeline for video: {$message->videoId}");

        // 1. Dispatch Thumbnail Generation (Fast)
        // We generate 3 thumbnails in parallel by dispatching 3 messages
        $this->bus->dispatch(new GenerateThumbnail($message->videoId, $message->filename, 5));
        $this->bus->dispatch(new GenerateThumbnail($message->videoId, $message->filename, 30));
        $this->bus->dispatch(new GenerateThumbnail($message->videoId, $message->filename, 60));

        // 2. Dispatch Transcoding (Slow/Heavy)
        // These will go to the 'async_heavy' transport
        $this->bus->dispatch(new TranscodeVideo($message->videoId, $message->filename, 'mp4-720p'));
        $this->bus->dispatch(new TranscodeVideo($message->videoId, $message->filename, 'webm-720p'));

        $this->logger->info("Pipeline dispatched successfully.");
    }
}
 Тежкият работник Handler Сега ние прилагаме реалната логика, използвайки . FFmpeg // src/MessageHandler/TranscodeVideoHandler.php
namespace App\MessageHandler;

use App\Message\TranscodeVideo;
use FFMpeg\FFMpeg;
use FFMpeg\Format\Video\X264;
use Psr\Log\LoggerInterface;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
final readonly class TranscodeVideoHandler
{
    public function __construct(
        private string $storageDir,
        private LoggerInterface $logger,
    ) {}

    public function __invoke(TranscodeVideo $message): void
    {
        $inputFile = $this->storageDir . '/' . $message->filename;
        $outputFile = $this->storageDir . '/processed/' . $message->videoId . '-' . $message->targetFormat . '.mp4';

        // 1. Verify existence (Robustness)
        if (!file_exists($inputFile)) {
            // In a shared dir setup, there might be a slight sync delay or error.
            // Throwing exception triggers Messenger retry policy.
            throw new \RuntimeException("File not found: $inputFile");
        }

        $this->logger->info("Transcoding {$message->videoId} to {$message->targetFormat}...");

        // 2. Initialize FFMpeg
        $ffmpeg = FFMpeg::create();
        $video = $ffmpeg->open($inputFile);

        // 3. Configure Format (x264 codec, AAC audio)
        $format = new X264();
        $format->setKiloBitrate(1000)
               ->setAudioChannels(2)
               ->setAudioKiloBitrate(128);

        // 4. Save
        // This is a blocking process that can take minutes.
        // Because it's in a worker, the user is not waiting.
        $filesystem = new Filesystem();
        $filesystem->mkdir(dirname($outputFile));
        
        $video->save($format, $outputFile);

        $this->logger->info("Transcoding complete: $outputFile");
    }
}
 The Controller: Свързвайки го заедно Задачата на контролера сега е невероятно проста: Validate -> Move to Storage -> Dispatch -> Return 202 Accepted. // src/Controller/VideoController.php
namespace App\Controller;

use App\Dto\VideoUploadDto;
use App\Message\ProcessVideoUpload;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpKernel\Attribute\MapUploadedFile;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Routing\Attribute\Route;
use Symfony\Component\Uid\Uuid;

#[Route('/api/videos')]
class VideoController extends AbstractController
{
    public function __construct(
        private string $storageDir,
        private MessageBusInterface $bus
    ) {}

    #[Route('/upload', methods: ['POST'])]
    public function upload(
        // Validates automatically using our DTO constraints
        #[MapUploadedFile] VideoUploadDto $uploadDto
    ): JsonResponse {
        
        $file = $uploadDto->file;
        $videoId = Uuid::v7()->toRfc4122();
        
        // 1. Move file to Shared Directory
        // We use the ID as the filename to avoid collisions
        $filename = $videoId . '.' . $file->guessExtension();
        $file->move($this->storageDir, $filename);

        // 2. Dispatch the Manager Message
        $this->bus->dispatch(new ProcessVideoUpload($videoId, $filename));

        // 3. Immediate Response
        return $this->json([
            'status' => 'processing',
            'id' => $videoId,
            'message' => 'Video accepted. Processing pipelines initiated.'
        ], 202);
    }
}
 Извършване на тръбопроводи За да видите тази паралелност в действие, трябва да управлявате работниците си.В производствена среда (като Kubernetes или Docker Swarm) бихте скалирали тези внедрения самостоятелно. Извършва диспечиране и миниатюри. Terminal 1 (The Priority Worker): php bin/console messenger:consume async_priority -vv
 Можете да изпълнявате 4 или 5 от тези контейнери. Terminal 2 (The Heavy Worker): php bin/console messenger:consume async_heavy -vv
 Проверка 
 
 
 
 
 POST 50MB MP4 файл в /api/videos/upload. Наблюдавайте Терминал 1: Той получава ProcessVideoUpload, след което почти мигновено изпраща 5 нови съобщения (3 миниатюри, 2 транскода). Обърнете внимание на терминал 2: Той взема TranscodeVideo. Ще видите увеличаване на използването на CPU, докато FFmpeg работи. Проверете ./var/storage/processed/ директория. Ще видите миниатюри се появяват бързо, последвани по-късно от транскодирани видео файлове. Заключението Използвайки Symfony 7.4, ние трансформираме сложен проблем в чиста, управляема архитектура. 
 
 
 
 Надеждност: ограничението #[Видео] гарантира, че никакви невалидни файлове никога не влизат в нашия тръбопровод. Скалируемост: Чрез разделяне на async_priority и async_heavy, генерирането на миниатюри никога не се блокира от голямо видео кодиране. Можете да промените библиотеката за транскодиране или двигателя за съхранение (например на S3 с помощта на Flysystem) без да докосвате контролера или логиката за валидиране. Тази архитектура е "готова за производство", но позволява растеж. С един (използвайки league/flysystem-aws-s3-v3), но концепциите за тръбопровода Messenger остават точно същите. Shared Directory Object Storage abstraction С правилните ограничения и архитектурата на опашката, тя става предсказуема и наблюдаема. Имате въпроси за мащабирането на тръбопроводи на Symfony? нека се свържем. споделям ежедневни съвети за съвременната PHP архитектура. LinkedIn: Свържете се с мен [ ] https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/

This story contains AI-generated text. The author has used AI either for research, to generate outlines, or write the text itself. 

Read My Stories

Това аудио е създадено на оригиналния език на историята!

Как да мащабирате видеоклипове: паралелна обработка, Messenger и др.

About Author

КОМЕНТАРИ

ЗАКАЧВАЙТЕ ЕТИКЕТИ

ТАЗИ СТАТИЯ Е ПРЕДСТАВЕНА В

Related Stories

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps