Laravel事务失败时如何阻止AWS S3文件上传？

除了你提到的先将文件存入数组、事务提交后再循环上传的方法，还有以下几种可行方案：

1. 利用Laravel事务的提交回调 #

Laravel的数据库事务支持通过afterCommit方法注册回调，只有当事务成功提交后，回调里的代码才会执行。这样可以把文件上传逻辑完全放在回调中，从根源避免事务失败时上传文件。

示例代码：

DB::beginTransaction();
try {
    $pendingUploads = [];
    foreach ($uploaded as $image) {
        // 执行所有数据库操作
        DB::table('images')->insert([
           'product_id' => $product_id,
        ]);
        DB::table('images')
             ->where('product_id', 1)
             ->update([
                 'product_id' => $product_id,
             ]);
        // 暂存文件信息，后续在回调中使用
        $pendingUploads[] = [
            'image' => $image,
            'path' => 'path' // 根据实际逻辑生成目标路径
        ];
    }

    DB::commit();

    // 注册提交成功后的回调（Laravel 8+支持）
    DB::afterCommit(function () use ($pendingUploads) {
        foreach ($pendingUploads as $item) {
            Storage::disk('s3')->putFileAs('products', $item['image']->url, $item['path']);
        }
    });
} catch (Exception $e) {
    DB::rollback();
}

注：afterCommit在嵌套事务中也能正常工作，只有最外层事务提交时才会触发回调。

2. 先临时存储到本地，事务提交后再迁移到S3 #

先把上传的文件保存到本地临时目录，等事务确认提交成功后，再将本地文件上传到S3，最后删除本地临时文件；如果事务回滚，直接删除本地临时文件即可。

示例代码：

use Illuminate\Support\Facades\File;

$tempDir = storage_path('temp/uploads');
// 确保临时目录存在
if (!File::exists($tempDir)) {
    File::makeDirectory($tempDir, 0755, true);
}

$localFiles = [];

DB::beginTransaction();
try {
    foreach ($uploaded as $image) {
        // 执行数据库操作
        DB::table('images')->insert([
           'product_id' => $product_id,
        ]);
        DB::table('images')
             ->where('product_id', 1)
             ->update([
                 'product_id' => $product_id,
             ]);

        // 保存到本地临时目录
        $tempFileName = uniqid() . '.' . $image->getClientOriginalExtension();
        $tempPath = $tempDir . '/' . $tempFileName;
        $image->move($tempDir, $tempFileName);
        $localFiles[] = [
            'tempPath' => $tempPath,
            's3Path' => 'products/' . $tempFileName // 目标S3路径
        ];
    }

    DB::commit();

    // 事务提交成功，上传到S3并清理本地文件
    foreach ($localFiles as $file) {
        Storage::disk('s3')->putFileAs('products', new File($file['tempPath']), basename($file['s3Path']));
        File::delete($file['tempPath']);
    }
} catch (Exception $e) {
    DB::rollback();
    // 事务失败，清理本地临时文件
    foreach ($localFiles as $file) {
        if (File::exists($file['tempPath'])) {
            File::delete($file['tempPath']);
        }
    }
}

3. 使用异步队列延迟上传（适合大文件场景） #

如果上传的是大文件，同步上传可能影响响应速度，可以把文件上传任务放到队列中，只有当事务提交成功后才将任务推送到队列。这样即使事务失败，队列任务也不会被触发。

示例代码：

DB::beginTransaction();
try {
    $uploadTasks = [];
    foreach ($uploaded as $image) {
        // 执行数据库操作
        DB::table('images')->insert([
           'product_id' => $product_id,
        ]);
        DB::table('images')
             ->where('product_id', 1)
             ->update([
                 'product_id' => $product_id,
             ]);

        // 准备队列任务参数（不能直接传UploadedFile对象，需传临时路径或文件信息）
        $uploadTasks[] = [
            'tempFilePath' => $image->getRealPath(),
            'clientName' => $image->getClientOriginalName(),
            's3Path' => 'products/' . uniqid() . '.' . $image->getClientOriginalExtension()
        ];
    }

    DB::commit();

    // 事务提交成功，推送队列任务
    foreach ($uploadTasks as $task) {
        UploadToS3::dispatch($task['tempFilePath'], $task['clientName'], $task['s3Path']);
    }
} catch (Exception $e) {
    DB::rollback();
    // 事务失败，无需处理队列（任务未推送）
}

注：队列任务UploadToS3中需实现文件上传到S3的逻辑，并完成临时文件的清理。

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