TP6.0 消息队列 topthink/think-queue

1. TP6.0 消息队列 topthink/think-queue

---

topthink/think-queue 是ThinkPHP官方提供的一个消息队列服务，是专门支持队列服务的扩展包

github : https://github.com/top-think/think-queue

packagist : https://packagist.org/packages/topthink/think-queue

2. think-queue 各主版本对应适用的TP版本

---

think-queue 版本号	适用的TP版本
1.x	ThinkPHP5.0
2.x	ThinkPHP5.1
3.x	ThinkPHP6.0

3. 安装 topthink/think-queue

---

在应用根目录执行命令, 下载 topthink/think-queue 扩展

安装扩展后会自动生成消息队列配置文件 config/queue.php

站长源码网

代码语言：javascript复制

composer require topthink/think-queue

4. topthink/think-queue 驱动类型

---

驱动类型	对应的类型值
sync	同步执行, 默认值
database	数据库驱动
redis	Redis驱动 【推荐】
其他自定义的完整的类名	…

如果驱动类型为 sync, 则以下两种发布任务的方式都会同步执行

当驱动类型修改为 redis 时, thinkfacadeQueue::later() 才会异步执行

代码语言：javascript复制

// 立即执行
thinkfacadeQueue::push($job, $data = '', $queue = null);
// 延迟执行
thinkfacadeQueue::later($delay, $job, $data = '', $queue = null);

代码语言：javascript复制

return [
    'default'     => 'sync',
    'connections' => [
        'sync'     => [
            'type' => 'sync',
        ],
        ...
    ],
    'failed'      => [
        'type'  => 'none',
        'table' => 'failed_jobs',
    ],
];

5. 发布任务

---

代码语言：javascript复制

// 立即执行
thinkfacadeQueue::push($job, $data = '', $queue = null);
// 延迟执行
// $delay 延迟时间,单位秒,几秒后执行
// $job   任务对象
// $data  自定义数据
// $queue 队列名称
thinkfacadeQueue::later($delay, $job, $data = '', $queue = null);

代码语言：javascript复制

/**
 * 获取任务对象
 * 发布任务时使用
 * @param string $class
 * @param string $action
 * @example getJob(appqueueTask::class, 'fire')
 * @return string appqueuetask@fire
 */
function getJob(string $class, string $action)
{
    // 使用示例
    // $delay = 10;
    // $job = getJob(appqueueTask::class, 'fire');
    // thinkfacadeQueue::later($delay, $job, $data);
    return implode('@', [strtolower($class), $action]);
}

6. 监听任务并执行

---

两种命令

代码语言：javascript复制

php think queue:work
php think queue:listen

两种命令的具体的可选参数可以输入命令加 —help 查看

代码语言：javascript复制

php think queue:work --help
php think queue:listen --help

常用参数

代码语言：javascript复制

// 任务执行五次还未成功, 第六次进入failed方法
php think queue:listen --tries 5

thinkphp github http https 云数据库Redis

0 人点赞