ThinkPHP如何实现任务队列-ThinkPHP-PHP中文网

必须安装topthink/think-queue ^3.0扩展，配置config/queue.php中default为redis、connections.redis含正确host/port/select、failed设database并执行迁移；任务类继承think\queue\jobs\job，实现fire方法并调用$job->delete()；推送用queue::push或later；消费者用php think queue:work --daemon --max-jobs=100。

thinkphp如何实现任务队列

ThinkPHP 6.x 自带的 `think-queue` 怎么装和配

直接用官方维护的 think-queue 扩展，别自己手写队列驱动。它封装了 Redis、Database、Sync（同步）、Beanstalkd 等多种驱动，且与 TP6 的容器、事件、命令行机制深度集成。

安装命令：composer require topthink/think-queue。装完后无需手动注册服务提供者——TP6 会自动加载。

配置文件在 config/queue.php，关键项包括：

'default' => 'redis'：默认驱动，推荐设为 redis（Database 驱动仅适合低频调试，性能差、无重试保障）
'connections.redis' => [...]：确保 'host'、'port'、'database' 填对，Redis 连不上时任务会静默失败
'failed' => ['driver' => 'database']：失败任务存数据库，需先执行 php think queue:table 和 php think migrate:run

如何定义一个可被队列执行的任务类

任务类必须实现 think\queue\Job 接口，但更推荐继承 think\queue\job 提供的基类 think\queue\Jobs\Job（注意命名空间是 think\queue\Jobs\Job，不是 think\queue\Job）。

最简结构：

namespace app\job;

use think\queue\Jobs\Job;

class SendEmailJob
{
    public function fire(Job $job, $data)
    {
        // 实际业务逻辑，比如调用 Mail::send()
        \think\facade\Mail::raw('Hello', function ($message) use ($data) {
            $message->to($data['email']);
        });

        // 执行成功，手动删除该任务
        $job->delete();
    }
}

注意点：

不要在 fire() 里 throw 异常来“失败重试”——框架靠返回值或抛出特定异常控制行为
想让任务失败后重试，就抛出 \think\exception\RetryException；想彻底失败并进 failed_jobs 表，就抛其他异常或不捕获
$job->attempts() 可查当前重试次数，避免无限重试

怎么把任务推入队列、指定延迟、控制重试次数

推送靠 think\facade\Queue 门面，不是直接 new 类或调用静态方法。

btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理：站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

常见推送方式：

立即执行：Queue::push(new SendEmailJob(), ['email' => 'a@b.com'])
延迟 60 秒：Queue::later(60, new SendEmailJob(), ['email' => 'a@b.com'])
指定连接（如用 database 驱动做测试）：Queue::connection('database')->push(...)
限制最大重试次数（只对 Redis/Beanstalkd 有效）：Queue::push(new SendEmailJob(), [], ['maxTries' => 3])

注意：later() 在 Database 驱动下不可靠（依赖定时轮询），生产环境务必用 Redis。