在 Symfony 中通过依赖注入和别名动态访问 Flysystem 存储服务

# config/packages/flysystem.yaml
flysystem:
    storages:
        first.storage:
            adapter: 'local'
            options:
                directory: '%kernel.project_dir%/var/storage/first'
        second.storage:
            adapter: 'local'
            options:
                directory: '%kernel.project_dir%/var/storage/second'

// src/Service/SomeService.php
namespace App\Service;

use League\Flysystem\FilesystemOperator;

class SomeService
{
    private FilesystemOperator $firstStorage;

    public function __construct(FilesystemOperator $firstStorage)
    {
        $this->firstStorage = $firstStorage;
    }

    public function doSomethingWithFirstStorage(): void
    {
        // 使用 $this->firstStorage
    }
}

# config/services.yaml
services:
    # ... 其他服务配置

    # 为 Flysystem 存储服务创建公共别名
    # 'first.storage' 和 'second.storage' 是 flysystem.yaml 中定义的存储名称
    first.storage.alias:
        alias: 'first.storage'
        public: true

    second.storage.alias:
        alias: 'second.storage'
        public: true

// src/Factory/FileSystemFactory.php
namespace App\Factory;

use League\Flysystem\FilesystemOperator;
use Symfony\Component\DependencyInjection\ContainerInterface;
use InvalidArgumentException;

class FileSystemFactory
{
    private ContainerInterface $container;

    public function __construct(ContainerInterface $container)
    {
        $this->container = $container;
    }

    /**
     * 根据名称获取指定的 Flysystem 存储实例。
     *
     * @param string $storageName 存储的名称（例如 'first' 或 'second'）
     * @return FilesystemOperator
     * @throws InvalidArgumentException 如果指定的存储不存在
     */
    public function getStorage(string $storageName): FilesystemOperator
    {
        // 根据传入的名称构建服务别名
        $serviceId = sprintf('%s.storage.alias', $storageName);

        // 检查服务是否存在，以提供更友好的错误信息
        if (!$this->container->has($serviceId)) {
            throw new InvalidArgumentException(sprintf('Flysystem storage "%s" (service ID: "%s") not found or not publicly aliased.', $storageName, $serviceId));
        }

        // 从容器中获取 Flysystem 存储实例
        $fileSystemStorage = $this->container->get($serviceId);

        // 确保获取到的实例是 FilesystemOperator 类型
        if (!$fileSystemStorage instanceof FilesystemOperator) {
            throw new \RuntimeException(sprintf('Service "%s" is not an instance of FilesystemOperator.', $serviceId));
        }

        return $fileSystemStorage;
    }
}

// src/Service/FileProcessor.php
namespace App\Service;

use App\Factory\FileSystemFactory;

class FileProcessor
{
    private FileSystemFactory $fileSystemFactory;

    public function __construct(FileSystemFactory $fileSystemFactory)
    {
        $this->fileSystemFactory = $fileSystemFactory;
    }

    public function processFile(string $storageType, string $filePath): void
    {
        $storage = $this->fileSystemFactory->getStorage($storageType);

        // 使用获取到的 $storage 进行文件操作
        $content = $storage->read($filePath);
        // ...
    }
}