【Fastadmin/ThinkPHP5】使用Queue队列方法详细步骤

在现代应用开发中，合理利用队列系统能够有效提升系统的性能和响应速度，尤其是在处理耗时较长的任务时，如发送大量邮件、执行定时任务等。下面是如何在ThinkPHP框架中设置和使用队列功能的详细指南：

1.配置队列服务

在application/extra/queue.php文件中，我们设置了队列的连接器及其相关配置：

<?php use think\Env; return [ 'connector' => Env::get('queue.CONNECTOR', 'redis'),//驱动类型，可选择 sync(默认):同步执行，database:数据库驱动,redis:Redis驱动,topthink:Topthink驱动 //或其他自定义的完整的类名 'host' => Env::get('app.REDIS_HOST', '127.0.0.1'), 'port' => Env::get('app.REDIS_PORT', '6379'), 'password' => Env::get('app.REDIS_PASSWORD', ''), 'select' => Env::get('app.REDIS_DB', 1), ];

上述代码中，我们可以通过环境变量灵活地配置了队列连接器，支持同步执行、数据库驱动和Redis驱动等多种方式。

2.创建Job类

我们在application/common/library/job/MessageSendJob.php中创建了一个处理邮件发送任务的Job类：

<?php namespace app\common\library\job; use app\common\library\Ems; use think\queue\Job; class MessageSendJob { /** * 处理邮件发送任务 * * @param Job $job 当前任务对象 * @param array $data 邮件发送所需数据 */ public function handle(Job $job, array $data) { try { // 实现邮件发送逻辑 Ems::sendNotice($data['email'], $data['title'], $data['content']); echo $data['email'] . '邮件发送成功'. PHP_EOL; // 成功发送邮件后删除队列任务 $job->delete(); } catch (\Exception $e) { // 若邮件发送失败，可根据实际需求决定是否重新入队 if ($job->attempts() < 3) { // 例如最多重试3次 $job->release(60); // 在60秒后再次尝试执行 } else { $this->failed($job, $data); } } } /** * 任务执行失败后的回调 * * @param Job $job 当前任务对象 * @param array $data 邮件发送所需数据 */ public function failed(Job $job, array $data) { // 记录日志或采取其他补救措施 Log::record('邮件发送任务失败，邮箱：' . $data['email'], 'error'); // 可考虑在此处通知管理员，或采取其他失败后处理逻辑 } } 3.将任务加入队列 // 构建邮件发送任务数据 $queueData = [ 'email' => $email, 'title' => $title, 'content' => $content, ]; // 使用MessageSendJob类将任务推送到'message'队列 Queue::push(MessageSendJob::class, $queueData, 'message'); 4.启动队列监听

  在命令行环境下，我们可以通过以下命令监听特定队列或全局监听所有队列：

监听特定队列（如'message'）：php think queue:listen --queue message全局监听所有队列：php think queue:listen

通过以上步骤，我们成功地在ThinkPHP框架中实现了队列任务的创建、配置与监听，使得系统在处理耗时任务时更加高效流畅。