在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'

use League\Flysystem\FilesystemOperator;

class MyService
{
    private FilesystemOperator $firstStorage;

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

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

    # 为 'first.storage' Flysystem 服务创建公共别名
    first.storage.alias:
        alias: 'first.storage'
        public: true

    # 为 'second.storage' Flysystem 服务创建公共别名
    second.storage.alias:
        alias: 'second.storage'
        public: true

<?php

namespace App\Factory;

use League\Flysystem\FilesystemOperator;
use Psr\Container\ContainerInterface; // 使用 Psr\Container\ContainerInterface 更通用

class FileSystemFactory
{
    private ContainerInterface $container;

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

    /**
     * 根据存储名称获取对应的FilesystemOperator实例。
     *
     * @param string $storageName 存储的名称（例如 'first.storage.alias', 'second.storage.alias'）
     * @return FilesystemOperator
     * @throws \Psr\Container\NotFoundExceptionInterface 如果指定的存储服务不存在
     * @throws \Psr\Container\ContainerExceptionInterface 如果获取服务时发生错误
     */
    public function getStorage(string $storageName): FilesystemOperator
    {
        // 检查服务是否存在，避免直接调用get()导致错误
        if (!$this->container->has($storageName)) {
            throw new \InvalidArgumentException(sprintf('The storage service "%s" does not exist or is not public.', $storageName));
        }

        $fileSystemOperator = $this->container->get($storageName);

        // 确保获取到的是FilesystemOperator实例
        if (!$fileSystemOperator instanceof FilesystemOperator) {
            throw new \UnexpectedValueException(sprintf('The service "%s" is not an instance of FilesystemOperator.', $storageName));
        }

        return $fileSystemOperator;
    }
}

<?php

namespace App\Service;

use App\Factory\FileSystemFactory;
use League\Flysystem\FilesystemOperator;

class FileProcessor
{
    private FileSystemFactory $fileSystemFactory;

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

    public function processFile(string $fileName, string $storageKey): void
    {
        // 根据传入的 storageKey 动态获取 Flysystem 存储实例
        $storage = $this->fileSystemFactory->getStorage($storageKey . '.alias');

        // 现在可以使用获取到的存储实例进行文件操作
        if ($storage->fileExists($fileName)) {
            $contents = $storage->read($fileName);
            // ... 处理文件内容
            echo "文件 '{$fileName}' 的内容: " . $contents . PHP_EOL;
        } else {
            echo "文件 '{$fileName}' 在存储 '{$storageKey}' 中不存在." . PHP_EOL;
        }
    }
}

// 假设在控制器或其他服务中调用
// $fileProcessor->processFile('my_document.txt', 'first.storage');
// $fileProcessor->processFile('another_image.jpg', 'second.storage');