如何在Laravel Storage门面中实现AWS S3重试策略？

方法一：通过文件系统配置自定义AWS客户端 #

直接在config/filesystems.php的S3磁盘配置中，自定义创建带有重试逻辑的AWS S3客户端，这种方式直观且易于配置：

's3' => [
    'driver' => 's3',
    'key' => env('AWS_ACCESS_KEY_ID'),
    'secret' => env('AWS_SECRET_ACCESS_KEY'),
    'region' => env('AWS_DEFAULT_REGION'),
    'bucket' => env('AWS_BUCKET'),
    'url' => env('AWS_URL'),
    'endpoint' => env('AWS_ENDPOINT'),
    'use_path_style_endpoint' => env('AWS_USE_PATH_STYLE_ENDPOINT', false),
    // 自定义客户端，注入重试逻辑
    'client' => function () {
        // 基础AWS客户端配置
        $clientConfig = [
            'region' => env('AWS_DEFAULT_REGION'),
            'version' => 'latest',
            'credentials' => [
                'key' => env('AWS_ACCESS_KEY_ID'),
                'secret' => env('AWS_SECRET_ACCESS_KEY'),
            ],
        ];

        // 创建S3客户端实例
        $client = new \Aws\S3\S3Client($clientConfig);

        // 获取客户端的请求处理器栈，添加重试中间件
        $handlerStack = $client->getHandlerList();
        $handlerStack->append(
            \Aws\Middleware::retry(function ($retries, $request, $response, $exception) {
                // 重试规则：仅针对503错误，最多重试3次
                return $exception instanceof \Aws\S3\Exception\S3Exception 
                    && $exception->getStatusCode() === 503 
                    && $retries < 3;
            }),
            's3_503_retry'
        );

        return $client;
    },
],

你还可以加入指数退避策略，避免短时间重复请求加重服务压力：

$handlerStack->append(
    \Aws\Middleware::retry([
        'max_retries' => 3,
        'delay' => function ($attempt) {
            // 第1次重试等待100ms，第2次200ms，第3次400ms
            return 100 * (2 ** $attempt);
        },
        'retryable' => function ($exception) {
            return $exception instanceof \Aws\S3\Exception\S3Exception && $exception->getStatusCode() === 503;
        },
    ]),
    's3_503_retry'
);

方法二：通过服务提供者扩展已解析的S3客户端 #

如果不想修改文件系统配置，更贴合Laravel服务容器扩展机制，可以创建自定义服务提供者动态修改已解析的S3客户端：

1. 创建app/Providers/AwsS3RetryServiceProvider.php：

<?php

namespace App\Providers;

use Aws\Middleware;
use Illuminate\Support\ServiceProvider;
use Illuminate\Filesystem\FilesystemAdapter;
use League\Flysystem\AwsS3V3\AwsS3V3Adapter;

class AwsS3RetryServiceProvider extends ServiceProvider
{
    public function boot()
    {
        // 当S3磁盘实例被解析后，注入重试中间件
        $this->app->afterResolving('filesystem.disk.s3', function (FilesystemAdapter $adapter) {
            /** @var AwsS3V3Adapter $flysystemAdapter */
            $flysystemAdapter = $adapter->getDriver()->getAdapter();
            $s3Client = $flysystemAdapter->getClient();

            // 添加重试中间件到客户端处理器栈
            $handlerStack = $s3Client->getHandlerList();
            $handlerStack->append(
                Middleware::retry([
                    'max_retries' => 3,
                    'delay' => fn($attempt) => 100 * (2 ** $attempt),
                    'retryable' => fn($exception) => 
                        $exception instanceof \Aws\S3\Exception\S3Exception 
                        && $exception->getStatusCode() === 503,
                ]),
                's3_503_retry'
            );
        });
    }
}

2. 在config/app.php的providers数组中注册服务提供者：

App\Providers\AwsS3RetryServiceProvider::class,

核心原理说明 #

Laravel的S3存储驱动基于AWS SDK PHP实现，Storage门面的所有操作最终都会调用AWS S3客户端的方法。通过修改客户端的请求处理器栈，注入AWS官方重试中间件（或自定义逻辑），可拦截503错误并自动重试，完全贴合Laravel的扩展规范。

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