PHP Laravel 异步任务与队列实现详解

异步执行的核心目标

Laravel 队列的主要目的是将耗时的任务从即时处理的请求中分离出来。通过将任务推入消息队列并稍后由独立的进程处理，可以大幅度缩短 HTTP 请求和响应的等待时间，确保用户界面的流畅性。

实施步骤与环境准备

第1步：生成异步任务类 (Job)

首先，需要创建一个专门处理该任务的类。使用 Artisan 命令行工具生成一个名为 UploadTask 的任务类：

php artisan make:job UploadTask

生成的文件位于 app/Jobs/UploadTask.php。该类需要继承或实现 ShouldQueue 接口，以告知 Laravel 这是一个需要放入队列而非同步执行的任务。

第2步：配置队列驱动

为了支持异步处理，必须更改项目的环境变量配置文件。打开根目录下的 .env 文件，找到并修改以下参数：

QUEUE_CONNECTION=redis

将默认的 sync（同步）模式改为 redis（或 database、beanstalkd 等）。若使用 Redis，需确保服务器已安装且正常运行 Redis 服务。

第3步：编写任务逻辑

在 app/Jobs/UploadTask.php 文件中实现具体的业务逻辑。通常核心代码写在 handle() 方法中：

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\Log;

class UploadTask implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * Create a new job instance.
     */
    public function __construct()
    {
        // 可以在这里定义需要传入任务的参数，例如 $this->data = $data;
    }

    /**
     * Execute the job.
     */
    public function handle()
    {
        // 记录日志开始执行
        Log::info('Start processing UploadTask');

        // 此处编写耗时操作，例如调用外部脚本处理 Excel 文件
        $command = 'cd ' . base_path() . ' && php artisan ExcelFile';
        $ret = shell_exec($command);

        Log::info('UploadTask completed with output: ' . print_r($ret, true));
    }
}

第4步：触发异步任务

在任意控制器或模型事件中使用 dispatch() 函数启动任务。这会将任务存入队列并立即返回，不会等待任务完成：

$form->saved(function (Form $form) {
    // 触发异步任务
    dispatch(new UploadTask());
    
    return $form->redirect('yyImport', '保存成功');
});

第5步：启动队列监听进程

队列任务必须有一个活跃的进程来处理它们。在项目根目录下运行以下命令启动监听器：

php artisan queue:work

只要该命令行窗口保持打开，Laravel 就会持续检查队列并执行积压的任务。

Windows 环境下的队列持久化

如果在个人电脑上进行开发，命令行窗口随时可能关闭导致队列停止工作。为了实现队列服务的“永动”，可以利用 Windows 的开机自启功能配合批处理和 VB 脚本隐藏运行命令行窗口。

1. 创建启动脚本 runReadExecelVbs.vbs：

set ws = CreateObject("Wscript.Shell")
ws.run "cmd /c I:\yinyue\runReadExecel.bat",vbhide

注：此脚本用于在后台静默执行 bat 文件。

2. 创建批处理文件 runReadExecel.bat：

cd I:\yinyue
php artisan queue:work

将上述两个文件放置在合适的位置，并将 VBS 文件的快捷方式添加到 Windows 的“启动”文件夹中，即可实现系统重启后自动后台拉起队列监听。

排错与验证

• 确认驱动配置：如果任务未进入队列，请再次检查 .env 中的 QUEUE_CONNECTION 是否已生效，尝试运行 composer install 或清除配置缓存。php artisan config:clear
• 查看报错信息：若队列无反应但服务开启，检查 Redis 连接状态或使用 php artisan tinker 尝试手动投递任务观察报错。

以上就是 Laravel 框架实现异步任务与队列配置的详细内容，更多关于 Laravel 高性能优化与队列深入原理的资料请关注本站其它相关文章！