如何通过消息队列异步删除VichUploaderBundle中的原始图片？

核心问题分析 #

你目前仅能获取文件名，但VichUploader的文件存储路径、Bucket等配置绑定在实体映射上，因此需要在消息中额外传递实体类名和映射名称，才能定位到正确的存储位置。

步骤1：修改消息类，携带必要信息 #

扩展消息类，加入实体类名和映射名称字段，让处理器能找到对应的Vich配置：

// src/Message/DeleteImageMessage.php
namespace App\Message;

class DeleteImageMessage
{
    public function __construct(
        private string $fileName,
        private string $entityClass,
        private string $mappingName
    ) {}

    // Getter方法
    public function getFileName(): string
    {
        return $this->fileName;
    }

    public function getEntityClass(): string
    {
        return $this->entityClass;
    }

    public function getMappingName(): string
    {
        return $this->mappingName;
    }
}

步骤2：触发消息时传递完整信息 #

在实体删除逻辑中（比如EventListener、Repository或Controller），构造消息时传入实体类、映射名和文件名：

// 示例：在实体删除事件中发送消息
use App\Message\DeleteImageMessage;
use Symfony\Component\Messenger\MessageBusInterface;

// ...

public function preRemove($entity, MessageBusInterface $messageBus): void
{
    // 假设你的实体有getImageName()方法返回文件名
    $message = new DeleteImageMessage(
        $entity->getImageName(),
        get_class($entity),
        'image' // 对应vich_uploader.yaml中配置的mapping名称
    );
    
    $messageBus->dispatch($message);
}

步骤3：编写消息处理器，执行删除操作 #

注入Vich的StorageMap服务获取对应映射的存储适配器，直接调用适配器的删除方法处理S3文件：

// src/MessageHandler/DeleteImageMessageHandler.php
namespace App\MessageHandler;

use App\Message\DeleteImageMessage;
use Vich\UploaderBundle\Mapping\StorageMap;
use Liip\ImagineBundle\Imagine\Cache\CacheManager;
use Symfony\Component\Messenger\Attribute\AsMessageHandler;

#[AsMessageHandler]
class DeleteImageMessageHandler
{
    public function __construct(
        private StorageMap $storageMap,
        private CacheManager $cacheManager
    ) {}

    public function __invoke(DeleteImageMessage $message): void
    {
        // 1. 清除LiipImagine缓存（你已实现，可保留）
        $this->cacheManager->remove($message->getFileName());

        // 2. 获取对应实体映射的配置与存储适配器
        $mapping = $this->storageMap->getMapping($message->getEntityClass(), $message->getMappingName());
        $adapter = $mapping->getStorage()->getAdapter();
        
        // 3. 删除S3上的原始文件
        $adapter->delete($message->getFileName(), $mapping->getUploadDir());
    }
}

关键注意事项 #

• 映射名称匹配：确保$mappingName与vich_uploader.yaml中配置的映射名完全一致（比如示例中的image）。
• S3权限：消息队列Worker的执行账号需要拥有S3对象的删除权限，检查IAM角色或Access Key的权限配置。
• 虚拟实体替代方案：如果不想直接调用适配器，也可以构造一个带文件名Getter的虚拟实体，调用StorageInterface::remove()方法：

  $dummyEntity = new class($message->getFileName()) {
      private string $imageName;
      public function __construct(string $imageName) { $this->imageName = $imageName; }
      public function getImageName(): string { return $this->imageName; }
  };
  $mapping->getStorage()->remove($dummyEntity, $message->getMappingName());
  

内容的提问来源于stack exchange，提问作者John McCaughan