如何在Laravel中动态添加基于数据库FTP账号的存储磁盘？

当然可行！Laravel的文件系统设计本身就支持动态扩展磁盘，中间件确实是实现这个需求的好地方——毕竟它会在请求处理前运行，刚好能在业务逻辑执行前把磁盘配置好。下面一步步教你实现：

1. 准备FTP账号的数据库模型（如果还没有的话） #

首先你需要一个数据库表来存储FTP账号信息，先创建迁移文件：

php artisan make:migration create_ftp_accounts_table

在生成的迁移文件中添加必要的字段：

public function up()
{
    Schema::create('ftp_accounts', function (Blueprint $table) {
        $table->id();
        $table->string('name')->unique(); // 磁盘名称，必须唯一
        $table->string('host');
        $table->string('username');
        $table->string('password');
        $table->string('root')->nullable(); // FTP根目录，可选
        $table->integer('port')->default(21);
        $table->boolean('passive')->default(true);
        $table->boolean('ssl')->default(false);
        $table->integer('timeout')->default(30);
        $table->timestamps();
    });
}

然后运行迁移：

php artisan migrate

接着创建对应的模型：

php artisan make:model FtpAccount

2. 编写动态注册磁盘的中间件 #

创建一个中间件来读取数据库中的FTP账号，并注册为Laravel存储磁盘：

php artisan make:middleware DynamicFtpDisksMiddleware

打开生成的中间件文件，替换内容如下：

<?php

namespace App\Http\Middleware;

use Closure;
use Illuminate\Filesystem\FilesystemManager;
use App\Models\FtpAccount;
use Illuminate\Support\Facades\Cache;

class DynamicFtpDisksMiddleware
{
    protected $filesystem;

    public function __construct(FilesystemManager $filesystem)
    {
        $this->filesystem = $filesystem;
    }

    public function handle($request, Closure $next)
    {
        // 缓存FTP账号配置，避免每次请求都查数据库（可选，根据你的更新频率调整缓存时间）
        $ftpAccounts = Cache::remember('ftp_accounts', 3600, function () {
            return FtpAccount::all();
        });

        foreach ($ftpAccounts as $account) {
            // 为每个FTP账号注册一个独立的存储磁盘
            $this->filesystem->extend($account->name, function ($app) use ($account) {
                return $app->make('filesystem')->createFtpDriver([
                    'driver' => 'ftp',
                    'host' => $account->host,
                    'username' => $account->username,
                    'password' => $account->password,
                    'root' => $account->root ?? '',
                    'port' => $account->port,
                    'passive' => $account->passive,
                    'ssl' => $account->ssl,
                    'timeout' => $account->timeout,
                ]);
            });
        }

        return $next($request);
    }
}

3. 注册中间件 #

打开app/Http/Kernel.php，把中间件注册到路由中间件组里：

方式一：全局生效（所有请求都注册磁盘） #

把中间件添加到$middleware数组：

protected $middleware = [
    // ...其他默认中间件
    \App\Http\Middleware\DynamicFtpDisksMiddleware::class,
];

方式二：仅特定路由生效 #

把中间件添加到$routeMiddleware数组，给它起个别名：

protected $routeMiddleware = [
    // ...其他路由中间件
    'dynamic.ftp.disks' => \App\Http\Middleware\DynamicFtpDisksMiddleware::class,
];

然后在需要使用动态FTP磁盘的路由上应用这个中间件：

Route::group(['middleware' => 'dynamic.ftp.disks'], function () {
    // 这里放需要访问FTP磁盘的路由，比如文件上传、下载接口
    Route::post('/upload-to-ftp', [FtpController::class, 'upload']);
});

4. 使用动态注册的FTP磁盘 #

现在你就可以像使用默认磁盘一样，通过账号的name字段来访问对应的FTP磁盘了：

// 上传文件到名为"customer_ftp"的磁盘
Storage::disk('customer_ftp')->put('documents/invoice.pdf', file_get_contents($localFilePath));

// 读取FTP磁盘上的文件
$content = Storage::disk('customer_ftp')->get('documents/invoice.pdf');

注意事项 #

• 磁盘名称唯一性：确保数据库中ftp_accounts表的name字段是唯一的，否则后面的账号会覆盖前面的磁盘配置。
• 缓存优化：如果你的FTP账号不会频繁更新，建议保留代码中的缓存逻辑，减少数据库查询压力。
• 错误处理：可以在中间件中添加try-catch块，处理数据库查询失败或FTP配置无效的情况，避免影响正常请求：

try {
    $ftpAccounts = Cache::remember('ftp_accounts', 3600, function () {
        return FtpAccount::all();
    });

    // ...注册磁盘逻辑
} catch (\Exception $e) {
    // 可以记录日志，或者直接跳过注册，不影响其他业务
    \Log::error('动态注册FTP磁盘失败：'.$e->getMessage());
}

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