1.安装队列依赖

由于框架版本原因可以选择适合的版本

composer require topthink/think-queue

由于我是tp框架5.1的，所以选择了think-queue 1.1.6

composer require topthink/think-queue 1.1.6

判断安装成功

php think queue:work -h

image.png

2.配置文件

看了网上其他的一些帖子说配置文件在统一目录下/config/queue.php

但是，我这边没有生成，但是根据Queue.php源码可以看出，配置是在config.php文件中的一个键值对

Queue.png

//  文件路径 App/config.php//  队列设置'queue' => ['connector' => 'Redis', // 驱动方式'expire' => 60,         // 缓存有效期'default' => "queue",   // 如果未设置队列名称,默认队列名称'host' => '127.0.0.1',  // 主机地址'port' => 6379,         // 端口'password' => '',       // 密码'select' => 0,          // 默认选择第一个库'timeout' => 0,         // 超时'persistent' => false, // 是否长连接],

3.在项目下新建一个Job目录，用来存放处理消息的类

image.png

4.控制器编写测试代码

5.编写对应的消费者类

checkMsg($data);if ($is_exit){try {//  这里是处理消息的逻辑$res = Db::name('test')->where('id', $data['user_id'])->update(['age' => 10]);if (!$res)  return false;$job->delete();} catch (\Exception $exception) {if ($job->attempts() > 3){//  如果消息处理失败次数大于 3 次//  1.可以把失败的消息放入队列重新消费//  2.延迟消息执行//  3.删除消息}}}$job->delete();return false;}/*** 是否需要消费* @param $data* @return bool*/public function checkMsg($data): bool{//  判断消息到达这里的时候，是否还需要继续处理if ($data['user_id'] == 1) return true;return false;}
}

6.测试消息投递

数据表默认数据

image.png

启动队列监听，对应的参数可以查阅相关文档

php think queue:listen --queue test

image.png

访问控制器接口的时候回来窗口下打印出对应消息者的地址

image.png

image.png

消息投递成功后，会在redis中生成一条数据(list数据类型)，可以在redis中查看

image.png

成功消费后数据库的数据

image.png