TP5的消息队列

2022-02-25 15:01:51 阅读：215 来源： 互联网

标签：get 队列 redis queue TP5 消息 Env think

1.首先查看项目中是否已经有think-queue目录：/vendor/topthink/

如果没有，则用composer安装（安装composer参考：http://www.runoob.com/w3cnote/composer-install-and-usage.html
），安装think-queue先进入到项目根目录，运行

composer require topthink/think-queue

安装完成后，有think-queue文件夹，再运行

php think queue:work -h

查看是否安装成功，出现如下，则安装成功

2.配置队列，queue内置了四种驱动，推荐使用redis驱动。配置文件在application/extra/queue.php，如下

<?php
use think\Env;
return [
    'connector'  => 'Redis',        // Redis 驱动
    'expire'     => Env::get('queue.expire',60),        // 任务的过期时间，默认为60秒; 若要禁用，则设置为 null
    'default'    => 'default',      // 默认的队列名称
    'host'       => Env::get('queue.host','127.0.0.1'), // redis 主机ip
    'port'       => Env::get('queue.port',6379),        // redis 端口
    'password'   => Env::get('queue.password',''),      // redis 密码
    'select'     => Env::get('queue.select',0),     // 使用哪一个 db，默认为 db0
    'timeout'    => 0,      // redis连接的超时时间
    'persistent' => false,      // 是否是长连接
];

3.消息的创建和推送，首先要添加队列

<?php
namespace app\common\controller;
use think\Queue;
class OrderQueue
{
    static $className = 'app\common\job';
    public static function createOrderQueue($jobData)
    {
        // 1.当前任务将由哪个类来负责处理。
        //   当轮到该任务时，系统将生成一个该类的实例，并调用其 fire 方法
        $jobHandlerClassName  = self::$className.'\Order';
        // 2.当前任务归属的队列名称，如果为新队列，会自动创建
        $jobQueueName     = "createOrderJob";
        // 3.当前任务所需的业务数据 . 不能为 resource 类型，其他类型最终将转化为json形式的字符串
        //   ( jobData 为对象时，需要在此处手动序列化，否则只存储其public属性的键值对 )
        // 4.将该任务推送到消息队列，等待对应的消费者去执行
        $isPushed = Queue::push( $jobHandlerClassName , $jobData , $jobQueueName );
        // database 驱动时，返回值为 1|false  ;   redis 驱动时，返回值为 随机字符串|false
        if( $isPushed !== false ){
            return true;
        }else{
            return false;
        }
    }
}

4.消息队列的执行

<?php
namespace app\common\job;

use app\common\model\ErrorLog;
use think\queue\Job;

class Order
{
    /**
     * fire方法是消息队列默认调用的方法
     * @param Job            $job      当前的任务对象
     * @param array|mixed    $data     发布任务时自定义的数据
     */
    public function fire(Job $job,$data)
    {
        //业务处理代码，具体不贴出来了
        $isJobDone = $this->create($data);

        if ($isJobDone) {
            // 如果任务执行成功， 记得删除任务
            $job->delete();
        }else{
            if ($job->attempts() > 3) {
                //通过这个方法可以检查这个任务已经重试了几次了

                $job->delete();

                // 也可以重新发布这个任务
                //print("<info>Hello Job will be availabe again after 2s."."</info>\n");
                //$job->release(2); //$delay为延迟时间，表示该任务延迟2秒后再执行
            }
        }
    }

    private function create($data)
    {
        ErrorLog::insertLog('执行队列',__METHOD__,json_encode($data));

        return true;
    }
}

到此，所有代码准备完毕，经历了一个消息的创建 -> 推送 -> 消费 -> 删除的基本流程，
上面添加队列的代码只要放在任意一个控制器内就行，部分目录机构如下

5.启用队列的监听模式，队列的监听模式有两种，配置参数如下

只需要到项目根目录执行

php think queue:listen --queue createOrderJob

即可，具体根据项目实际情况加上不同的参数。而且我们具体是不能要让命令以守护进程执行。所以我们可以换成下面这条命令

nohup php think queue:listen --queue createOrderJob &

到此，整个消息队列就完成了

6.测试：

public function createOrder()
{
   $data = [
         'order_id' => 1,
    ];

   OrderQueue::createOrderQueue($data);
}

转载：https://www.jianshu.com/p/e68e23f01490

标签：get,队列,redis,queue,TP5,消息,Env,think
来源： https://www.cnblogs.com/Ares0023/p/15936066.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

TP5的消息队列