ThinkPHP框架中如何使用队列

话说，在PHP圈子里，但凡项目规模稍微上来一点，就会遇到这么个问题：有些任务实在太耗时了——比如发邮件、生成报表、处理图片——如果让用户在那儿干等着，体验就太糟糕了。这时候，队列就派上用场了。在ThinkPHP里，队列机制能帮我们把这类耗时任务从主流程中解放出来，让应用跑得更顺畅。下面，咱们就一步步看看怎么在ThinkPHP里把队列搭起来。

第一步：搞个队列驱动

选哪个驱动好呢？ThinkPHP支持Redis、RabbitMQ、Database等多种选择，灵活性不错。以最常见的Redis为例，你得先把Redis扩展和Predis库装上。这事儿Composer就能搞定：

composer require predis/predis

装完之后，就算把基础环境准备好了。

第二步：配好配置文件

光有驱动不够，还得让框架知道怎么用。在config目录下新建一个queue.php配置文件，把队列驱动和连接信息写进去：

 'redis', // 默认队列驱动
    'connections' => [
        'redis' => [
            'type' => 'redis',
            'host' => '127.0.0.1',
            'port' => 6379,
            'password' => '',
            'select' => 0,
            'timeout' => 0,
            'expire' => 0,
            'persistent_id' => '',
            'prefix' => 'queue',
        ],
    ],
];

这里的关键参数，像host和port，按你实际环境来配就行。配置到位了，队列系统就算是跟ThinkPHP“接上头”了。

第三步：创建队列任务

队列的核心在于任务本身。用php artisan make:job命令可以快速生成一个任务类：

php artisan make:job SendEmailJob

这会在app/job目录下生成一个SendEmailJob.php文件。打开它，把实际的业务逻辑塞进fire方法里：

delete();
    }

    public function failed(Exception $exception)
    {
        // 任务执行失败时的处理逻辑
    }
}

值得留意的是，fire方法里任务执行完后别忘了$job->delete()，否则任务会一直留在队列里反复执行。当然，failed方法也为异常情况留了后路，你可以在这里做日志或者重试策略。

第四步：把任务推送到队列

任务类写好了，怎么用呢？很简单，在需要执行耗时操作的地方，用dispatch函数把任务推送到队列：

use app\job\SendEmailJob;

// 将SendEmailJob任务推送到队列
dispatch(new SendEmailJob($emailData));

比如用户注册后发欢迎邮件，或者订单支付后发通知，都可以通过这一行代码丢到后台去处理。用户那边不用等，体验立马提升一个档次。

第五步：启动队列监听器

任务推过去了，谁来消费呢？这就是队列监听器的工作了。在命令行里运行：

php artisan queue:listen

这条命令一旦跑起来，就会持续监听队列，有新任务进来就自动执行。你可以把它挂在后台跑，或者用supervisor等工具来守护进程，确保队列消费不中断。

以上就是ThinkPHP里使用队列的基本流程。从驱动安装、配置，到任务创建、推送，再到监听执行，环环相扣。实际上，队列不仅能提升性能，还能让你的代码结构更清晰——耗时的脏活累活都丢到后台，主流程只做最核心的事。下一步，你可以根据自己的需求，在任务类里加入更复杂的业务逻辑，比如失败重试、延迟执行、任务优先级等，让队列真正为你的项目服务。