tp5.0 think-queue 消息队列
- 安装 think-queue
composer require topthink/think-queue 1.1.4
不加版本号 默认安装的最新的queue ,适用于tp6.0。 使用tp5.0 只需要1.1.4 即可,不加版本号会报错,提示版本不匹配
2.配置文件
内容编辑修改
return ['connector' => 'Redis', // Redis 驱动'expire' => null, // 任务的过期时间,默认为60秒; 若要禁用,则设置为 null'default' => 'default', // 默认的队列名称'host' => '127.0.0.1', // redis 主机ip'port' => 6379, // redis 端口'password' => '', // redis 密码'select' => 0, // 使用哪一个 db,默认为 db0'timeout' => 0, // redis连接的超时时间'persistent' => false, // 是否是长连接
];
3.生产者(入队)
把你需要处理的信息,加入到队列当中;
4.消费者(出队)
$isJobDone = this−>doHelloJob(this->doHelloJob(this−>doHelloJob(data); 是你执行的逻辑方法;
- 操作命令
启动
php think queue:work --daemon --queue helloJobQueue
helloJobQueue 是你的队列名称 ,在生产者里面有设置;
加 --daemon 为循环执行,只有队列里面有你添加的数据有会一直执行
不加 单次执行,执行一次消费就会退出
停止
php think queue:restart
重启
php think queue:restart
php think queue:work
6.守护进程
使用 supervisor
tp5.0 think-queue 消息队列相关推荐
- tp5 mysql实现消息队列_TP5系列 | Queue消息队列
消费信息如下ThinkPHP5 Queue消息队列 优点 1.Queue内置了 Redis,Database,Topthink ,Sync这四种驱动,本文使用Redis驱动 2.Queue消息队列适用 ...
- ThinkPHP5.0+Queue消息队列
Queue消息队列: Thinkphp官方团队开发的一个专门支持队列服务的扩展包,使用composer管理,使用起来非常方便 优点: 1. Queue内置了 Redis,Database,Topthi ...
- think queue 消息队列初体验
使用的是tp5 自带的消息队列 thinkphp top里的 消息队列框架 think-queue 这是thinkphp官方团队开发的一个专门支持队列服务的扩展包 消息队列应用场景: 消息队列适用于 ...
- 进程间通信-Queue 消息队列 先进先出
Process之间有时需要通信,操作系统提供了很多机制来实现进程间的通信. multiprocessing模块的Queue实现多进程之间的数据传递,Queue本身是一个消息列队程序 初始化Queue( ...
- think\queue 消息队列
简介 TP 中使用 think-queue 可以实现普通队列和延迟队列. think-queue 是thinkphp 官方提供的一个消息队列服务,它支持消息队列的一些基本特性: 消息的发布,获取,执行 ...
- tp5 mysql实现消息队列_thinkphp5 tp5 queue消息队列使用方法
安装 composer require topthink/think-queue 配置 配置文件位于 config/queue.php 公共配置 [ 'default'=>'sync' //驱动 ...
- python队列线程池_实例详解:python高级编程之消息队列(Queue)与进程池(Pool)
今天为大家带来的内容是:python高级编程之消息队列(Queue)与进程池(Pool),结合了实例的形式详细分析了Python消息队列与进程池的相关原理.使用技巧与操作注意事项!!! Queue消息 ...
- 进程间通信——消息队列(Message queue)
在Linux中,IPC消息队列是一个双向通信的全内存设计,即内核保证了读写顺序和数据同步,并且是性能比较好的先进先出的数据结构.消息队列的应用场景:比如异步任务处理,抢占式的数据分发,顺序缓存区等. ...
- PHP使用topthink/think-queue消息队列实例
常住队列消费命令 sudo nohup php7.2 think queue:work --daemon --queue createAdminLogQueue --tries 2 > ou ...
- 消息队列之 RabbitMQ
消息队列之 RabbitMQ 关于消息队列,从前年开始断断续续看了些资料,想写很久了,但一直没腾出空,近来分别碰到几个朋友聊这块的技术选型,是时候把这块的知识整理记录一下了. 市面上的消息队列产品有很 ...
最新文章
- python处理多个excel表-使用python把Excel表格由一个分隔成多个
- NYOJ 623 A*B ProblemII
- 人生致命的8个经典问题,你也常常犯傻
- E-MapReduce结合DataV进行数据展现
- 【转】企业开发的困境与变局
- 献给支持51CTO博客的博友们-----做自己喜欢的事情
- java合并后求和_用分支/合并框架执行并行求和
- 智能优化算法:绯鲵鲣优化算法-附代码
- ffmpeg filter过滤器 基础实例及全面解析
- WampServer 给电脑搭建apache服务器和php环境
- 除了php云和骑士还有什么_骑士CMS是什么开源程序
- 解决鼠标不能移出视频框,切换网页不能播视频的小窍门
- jtest准考证打印
- 世界杯决赛倒计时,你最看好谁
- 4/2 三元表达式/函数递归/匿名函数/内置函数
- Python和JavaScript间代码转换4个工具
- python图书馆管理系统实验报告_基于python图书馆管理系统设计实例详解
- 2022年软件评测师真题
- 第一场web3的游戏直播带领我走向直播的另一高点
- PTA 07-图6 旅游规划
热门文章
- Ubuntu系统电池管理软件TLP(Thinkpad设置电池充电阈值)
- 新浪体育——篮球足球的直播和战报爬取
- OSChina 周六乱弹 —— 三口气印度史(3.5)
- 阿里云免费SSL证书申请与安装使用-附Nginx,Apache,IIS 6,IIS 8配置SSL教程
- 三、C语言的数据类型—浮点型数据
- android socket上传视频教程,android socket视频流方案
- SEM测试优点与特点
- 升级 MDK 5.37 后的问题处理: AC6编译选项, printf, 重启失效等
- 【C++】Web服务器项目所用到的函数详解
- (转)如何快速学习Tableau Desktop