thinkphp消息队列think-queue的使用方法

PHP 精帖 收藏 0 145
FREE VIP 2019-09-06 16:17:59

注:此方法简单实现学习,生产环境还需进程守护等等,加油啦

************************************************************************

版本要求 PHP > 7,否则不支持返回类型声明

如:function f() :array{}

1安装 thinkphp-queue

thinkphp-queue地址:https://packagist.org/packages/topthink/think-queue

 

第一种:composer install topthink/think-queue(安装失败使用下方命令)

 

第二种:composer require topthink/think-queue

 

第三种:在composer.json种添加符合版本的think-queue,然后执行composer update

undefined

2. 搭建消息队列Redis存储环境

配置queue文件

undefined

启动redisredis-server.exe redis.windows.conf


3. 创建任务处理类(消费者类)

fire方法是消息队列默认调用的方法

@param Job            $job      当前的任务对象

@param array|mixed    $data     发布任务时自定义的数据

添加业务处理的方法doJob(自定义方法)

undefined


4.创建控制器(创建消息与推送)

undefined


5. 执行命令

php think queue:work --queue testJob --daemon


6. 请求控制器页面

undefined

7. 查看任务监听页面

undefined


OK啦

undefined


评论
  • 消灭零回复