视频处理是一个Web应用程序可以处理的最沉重的任务之一。 在控制器中,你可能会阻止你的PHP-FPM线程,使用户感到沮丧,并冒着时间漏洞的风险。 shell_exec(‘ffmpeg …’) 在2026年,我们不会这样做,我们将视频处理视为一种 , . asynchronous distributed pipeline 随着Symfony 7.4的发布,我们有新的工具,使这个强大和原生。 , 而且,该 对平行管道进行管制。 edicated #[Video] validation constraint native support for shared directories, mature Messenger component 在本文中,我们将构建一个生产级视频处理架构,该架构: 
 
 
 
 验证使用新的 Symfony 7.4 限制立即上传。 将重量提升到后台工人。 并行执行任务(转码、小图像、分析)同时进行。 前提条件 
 
 
 
 
 PHP 8.2+(建议使用 PHP 8.4) 交响乐 7.4 (交响乐/骨骼和交响乐/webapp-pack) FFmpeg安装在您的服务器/容器上( sudo apt install ffmpeg)。 作曲家包:php-ffmpeg/php-ffmpeg(v1.3+)symfony/messenger\symfony/validator 建筑:共享目录策略 在编写代码之前,我们必须解决物理存储问题. 当用户上传视频到您的 Web 容器时,您的 Worker 容器(可能位于不同的服务器上)需要访问它。 在 Symfony 7.4 中,我们倾向于“ ” 模式 – 用于在节点之间共享的状态数据的标准化位置(如 NFS 安装或 Docker 卷)。 Shared Directory Infrastructure setup (Conceptual): 
 
 
 Web 节点:将 /mnt/shared_storage 设置为 ./var/storage。 工作节点:将相同的音量设置为 ./var/storage。 我们将构建这个路径在 确保我们的代码对物理位置是无知的。 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%'
 验证:新 #[视频] 限制 在以前的版本中,我们不得不依靠通用 限制和猜测MIME类型,或编写复杂的自定义验证器来检查持续时间和编码器。 File Symfony 7.4 引入原生 制约,它使用 室内(通过) )在您甚至接受业务逻辑之前验证元数据。 #[Video] FFmpeg ffprobe 让我们为我们的上传创建一个 DTO。 // 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 二进制可由 Web 用户执行。 导演:Messenger Pipelines 为了有效地处理视频,我们不应该只运行一个巨大的脚本,我们应该将工作分成管道,当视频上传时,我们会发送一个“管理员消息”,然后发送子任务并行运行。 传达信息(DTOs) 我们使用 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.");
    }
}
 重型工人处理器 现在,我们正在运用实际的逻辑 . 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");
    }
}
 控制者:把它捆绑在一起 控制器的工作现在非常简单: 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
 验证 
 
 
 
 
 将 50MB MP4 文件发送到 /api/videos/upload。 观察终端1:它接收ProcessVideoUpload,然后几乎立即发送5条新消息(3小图,2个转码)。 观察终端2:它收集了TranscodeVideo. 当FFmpeg运行时,您将看到CPU使用量上升。 检查您的 . / var / 存储 / 处理 / 目录. 您将看到小图像快速出现,然后是转码的视频文件。 结论 通过利用Symfony 7.4,我们将一个复杂的问题转化为一个清洁、可管理的架构。 
 
 
 
 可靠性: #[视频]限制确保没有错误的文件进入我们的管道。 可扩展性:通过分离 async_priority 和 async_heavy,小图像生成从不被大型视频编码所阻止。 可维护:逻辑分开,您可以更改转码库或存储引擎(例如,使用 Flysystem 更改为 S3)而不需要触摸控制器或验证逻辑。 该架构是“生产准备”,但允许增长. 当您扩展时,您可能会更换本地 与一个 (使用联盟/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

加密货币增长：创建有效的用户角色

数字游民请注意：您需要了解泰国新推出的 DTV 签证

如何将您的工作流程提高 10 倍：17 个必备应用程序

看不见的层面：为什么用户访谈是不可替代的资产

加密货币增长：创建有效的用户角色

数字游民请注意：您需要了解泰国新推出的 DTV 签证

如何将您的工作流程提高 10 倍：17 个必备应用程序

看不见的层面：为什么用户访谈是不可替代的资产

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps