Laravel异步队列上传文件-laravel guzzle 异步请求

在Web开发中，文件上传是一个常见的需求。然而，当文件较大或网络条件不佳时，同步上传可能会导致用户等待时间过长，影响用户体验。为了解决这一问题，我们可以使用Laravel的异步队列和Guzzle库来实现文件的异步上传。

解决方案概述

本文将介绍如何使用Laravel的队列系统和Guzzle库来实现文件的异步上传。通过将文件上传任务放入队列中，我们可以在后台异步处理文件上传，从而提高用户体验。我们将详细介绍如何配置队列、创建队列任务以及使用Guzzle发送异步请求。

配置Laravel队列

安装依赖

首先，确保你的Laravel项目已经安装了队列相关的依赖。如果你还没有安装，可以使用以下命令进行安装：

bash
composer require predis/predis


接下来，配置队列驱动。打开 config/queue.php 文件，选择一个合适的队列驱动，例如 Redis：

php
'default' => env('QUEUE_CONNECTION', 'redis'),


然后，在 .env 文件中配置 Redis 连接：

env
QUEUE_CONNECTION=redis
REDIS_HOST=127.0.0.1
REDIS_PASSWORD=null
REDIS_PORT=6379


创建队列任务

使用 Artisan 命令创建一个新的队列任务：

bash
php artisan make:job UploadFileJob


这将生成一个位于 app/Jobs 目录下的 UploadFileJob.php 文件。编辑该文件，实现文件上传逻辑：

php
namespace AppJobs;</p>

<p>use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;
use GuzzleHttpClient;</p>

<p>class UploadFileJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;</p>

<pre><code>protected $file;
protected $url;

public function __construct($file, $url)
{
    $this->file = $file;
    $this->url = $url;
}

public function handle()
{
    $client = new Client();
    $response = $client->request('POST', $this->url, [
        'multipart' => [
            [
                'name'     => 'file',
                'contents' => fopen($this->file, 'r')
            ]
        ]
    ]);

    if ($response->getStatusCode() == 200) {
        // 处理成功的情况
    } else {
        // 处理失败的情况
    }
}

}

使用Guzzle发送异步请求

安装Guzzle

确保你的项目已经安装了Guzzle库。如果没有安装，可以使用以下命令进行安装：

bash
composer require guzzlehttp/guzzle


触发队列任务

在控制器中，我们可以接收文件并将其放入队列中进行异步处理。例如，创建一个文件上传控制器：

php
namespace AppHttpControllers;</p>

<p>use IlluminateHttpRequest;
use AppJobsUploadFileJob;</p>

<p>class FileUploadController extends Controller
{
    public function upload(Request $request)
    {
        $request->validate([
            'file' => 'required|file',
        ]);</p>

<pre><code>    $file = $request->file('file')->store('uploads');

    UploadFileJob::dispatch($file, 'https://example.com/api/upload');

    return response()->json(['message' => 'File upload started']);
}

}

多种思路

使用Supervisor管理队列

为了确保队列任务能够持续运行，可以使用Supervisor来管理队列工作进程。安装Supervisor并创建一个配置文件：

bash
sudo apt-get install supervisor


创建一个配置文件 /etc/supervisor/conf.d/laravel-worker.conf：

ini
[program:laravel-worker]
process_name=%(program_name)s_%(process_num)02d
command=php /path/to/your/project/artisan queue:work --sleep=3 --tries=3
autostart=true
autorestart=true
user=www-data
numprocs=8
redirect_stderr=true
stdout_logfile=/path/to/your/project/worker.log


更新Supervisor配置并启动队列工作进程：

bash
sudo supervisorctl reread
sudo supervisorctl update
sudo supervisorctl start laravel-worker:*


使用AWS S3存储文件

如果需要将文件存储到AWS S3，可以在队列任务中使用Laravel的S3适配器。首先，安装AWS SDK：

bash
composer require league/flysystem-aws-s3-v3


配置 config/filesystems.php 文件：

php
'disks' => [
'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'),
],
],


在队列任务中使用S3适配器：

php
use IlluminateSupportFacadesStorage;</p>

<p>public function handle()
{
    Storage::disk('s3')->put('uploads/' . basename($this->file), file<em>get</em>contents($this->file));</p>

<pre><code>// 继续处理其他逻辑

}

通过以上步骤，我们可以实现文件的异步上传，并提高用户体验。希望本文对你有所帮助！