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'

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

    # 为 Flysystem 的 'first.storage' 创建公共别名
    # 建议使用清晰的命名约定，例如 'app.storage.<名称>_alias'
    app.storage.first_alias:
        alias: 'first.storage'
        public: true # 必须设置为 true，以便从容器外部访问

    # 为 Flysystem 的 'second.storage' 创建公共别名
    app.storage.second_alias:
        alias: 'second.storage'
        public: true # 必须设置为 true

<?php

namespace App\Service; // 假设你的服务在 App\Service 命名空间下

use League\Flysystem\FilesystemOperator;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Psr\Container\NotFoundExceptionInterface;
use Psr\Container\ContainerExceptionInterface;

/**
 * FileSystemFactory 负责根据名称动态获取 Flysystem 文件存储实例。
 */
class FileSystemFactory
{
    private ContainerInterface $container;

    /**
     * 构造函数，注入 Symfony 的服务容器。
     *
     * @param ContainerInterface $container
     */
    public function __construct(ContainerInterface $container)
    {
        $this->container = $container;
    }

    /**
     * 根据存储名称动态获取 Flysystem 文件系统操作器实例。
     *
     * @param string $storageName 存储的名称（例如 'first' 或 'second'），将用于构建服务别名。
     * @return FilesystemOperator 对应的 Flysystem 文件系统操作器实例。
     * @throws NotFoundExceptionInterface 如果找不到对应的服务别名。
     * @throws ContainerExceptionInterface 如果获取服务时发生其他容器相关的错误。
     * @throws \RuntimeException 如果获取到的服务不是 FilesystemOperator 实例。
     */
    public function getStorage(string $storageName): FilesystemOperator
    {
        // 根据传入的存储名称构建完整的服务别名 ID
        // 例如，如果 $storageName 是 'first'，则服务 ID 为 'app.storage.first_alias'
        $serviceId = sprintf('app.storage.%s_alias', $storageName);

        // 检查服务是否存在且可访问
        if (!$this->container->has($serviceId)) {
            throw new NotFoundExceptionInterface(
                sprintf('Flysystem storage service "%s" (alias for "%s.storage") not found or not public. ' .
                        'Please ensure it is defined as a public alias in your services.yaml.',
                    $serviceId, $storageName
                )
            );
        }

        // 从容器中获取服务实例
        $storageInstance = $this->container->get($serviceId);

        // 验证获取到的实例类型是否正确
        if (!$storageInstance instanceof FilesystemOperator) {
            throw new \RuntimeException(
                sprintf('Service "%s" is not a valid FlysystemOperator instance. ' .
                        'Expected type %s, got %s.',
                    $serviceId, FilesystemOperator::class, get_debug_type($storageInstance)
                )
            );
        }

        return $storageInstance;
    }
}

<?php

namespace App\Controller; // 或其他服务命名空间

use App\Service\FileSystemFactory;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route;
use Psr\Container\NotFoundExceptionInterface;
use Psr\Container\ContainerExceptionInterface;

class FileController extends AbstractController
{
    private FileSystemFactory $fileSystemFactory;

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

    /**
     * @Route("/process-file/{storageType}/{fileName}", name="process_file")
     */
    public function processFile(string $storageType, string $fileName): Response
    {
        try {
            // 根据 URL 参数动态获取存储实例
            $storage = $this->fileSystemFactory->getStorage($storageType);

            // 示例：读取文件内容
            if ($storage->fileExists($fileName)) {
                $content = $storage->read($fileName);
                $this->addFlash('success', sprintf('File "%s" from storage "%s" content: %s', $fileName, $storageType, $content));
            } else {
                $this->addFlash('warning', sprintf('File "%s" not found in storage "%s".', $fileName, $storageType));
            }

        } catch (NotFoundExceptionInterface $e) {
            $this->addFlash('error', 'Storage type not found: ' . $e->getMessage());
        } catch (ContainerExceptionInterface $e) {
            $this->addFlash('error', 'Container error: ' . $e->getMessage());
        } catch (\RuntimeException $e) {
            $this->addFlash('error', 'Runtime error: ' . $e->getMessage());
        }

        return $this->render('file/index.html.twig'); // 假设你有一个视图来显示消息
    }
}