位置: 编程技术 - 正文

PHP使用php-resque库配合Redis实现MQ消息队列的教程(php使用什么开发工具)

编辑:rootadmin

推荐整理分享PHP使用php-resque库配合Redis实现MQ消息队列的教程(php使用什么开发工具),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:php使用for循环计算1到100的和,php使用for循环实现乘法口诀表,php使用自定义函数编程求半径r为10的圆的周长和面积,php使用oci8扩展连接oracle,php使用for循环计算1到100的和,php使用pdo连接数据库,php使用for循环计算1到100的和,php使用for循环计算1到100的和,内容如对您有帮助,希望把文章链接给更多的朋友!

消息队列处理后台任务带来的问题项目中经常会有后台运行任务的需求,比如发送邮件时,因为要连接邮件服务器,往往需要5-秒甚至更长时间,如果能先给用户一个成功的提示信息,然后在后台慢慢处理发送邮件的操作,显然会有更好的用户体验。

为了实现类似的需求,Web项目中一般的实现方法是使用消息队列(Message Queue),比如MemcacheQ,RabbitMQ等等,都是很著名的产品。

消息队列说白了就是一个最简单的先进先出队列,队列的一个成员就是一段文本。正是因为消息队列实在太简单了,当拿着消息队列时,反而有点无从下手的感觉,因为这仅仅一个发送邮件的任务,就会引申出很多问题:

消息队列只能存储字符串类型的数据,如何将一个发送邮件这样的“任务”,转换为消息队列中的一个“消息”&#; 消息队列只负责数据的存放与进出,本身不能执行任何程序,那么我们要如何从消息队列中一个一个取出数据,再将这些数据转化回任务并执行。 我们无法预知消息队列何时会有数据产生,所以我们的任务执行程序还需要具备监控消息队列的能力,也就是一个常驻后台的守护进程。 一般的Web应用PHP都以cgi方式运行,无法常驻内存。我们知道php还有cli模式,那么守护进程是否能以php cli来实现,效率如何? 当守护进程运行时,Web应用能否与后台守护进程交互,实现开启/杀死进程的功能以及获得进程的运行状态?

Resque对后台任务的设计与角色划分

对以上这些问题,目前为止我能找到的最好答案,并不是来自php,而是来自Ruby的项目Resque,正是由于Resque清晰简单的解决了后台任务带来的一系列问题,Resque的设计也被Clone到Python、php、NodeJs等语言:比如Python下的pyres以及PHP下的php-resque等等,这里有各种语言版本的Resque实现,而在本篇日志里,我们当然要以PHP版本为例来说明如何用php-resque运行一个后台任务,可能一些细节方面会与Ruby版有出入,但是本文中以php版为准。

Resque是这样解决这些问题的:

后台任务的角色划分其实从上面的问题已经可以看出,只靠一个消息队列是无法解决所有问题的,需要新的角色介入。在Resque中,一个后台任务被抽象为由三种角色共同完成:

Job | 任务 : 一个Job就是一个需要在后台完成的任务,比如本文举例的发送邮件,就可以抽象为一个Job。在Resque中一个Job就是一个Class。 Queue | 队列 : 也就是上文的消息队列,在Resque中,队列则是由Redis实现的。Resque还提供了一个简单的队列管理器,可以实现将Job插入/取出队列等功能。 Worker | 执行者 : 负责从队列中取出Job并执行,可以以守护进程的方式运行在后台。

那么基于这个划分,一个后台任务在Resque下的基本流程是这样的:

将一个后台任务编写为一个独立的Class,这个Class就是一个Job。 在需要使用后台程序的地方,系统将Job Class的名称以及所需参数放入队列。 以命令行方式开启一个Worker,并通过参数指定Worker所需要处理的队列。 Worker作为守护进程运行,并且定时检查队列。 当队列中有Job时,Worker取出Job并运行,即实例化Job Class并执行Class中的方法。

至此就可以完整的运行完一个后台任务。

在Resque中,还有一个很重要的设计:一个Worker,可以处理一个队列,也可以处理很多个队列,并且可以通过增加Worker的进程/线程数来加快队列的执行速度。

php-resque的安装需要提前说明的是,由于涉及到进程的开辟与管理,php-resque使用了php的PCNTL函数,所以只能在Linux下运行,并且需要php编译PCNTL函数。如果希望用Windows做同样的工作,那么可以去找找Resque的其他语言版本,php在Windows下非常不适合做后台任务。

以Ubuntu.LTS为例,Ubuntu用apt安装的php已经默认编译了PCNTL函数,无需任何配置,以下指令均为root帐号

安装Redis

安装Composer

使用Composer安装php-resque假设web目录在/opt/htdocs

php-resque的使用1.编写一个Worker其实php-resque已经给出了简单的例子, demo/job.php文件就是一个最简单的Job:

这个Job就是在秒后向STDOUT输出字符Hello!

在Resque的设计中,一个Job必须存在一个perform方法,Worker则会自动运行这个方法。

PHP使用php-resque库配合Redis实现MQ消息队列的教程(php使用什么开发工具)

2.将Job插入队列php-resque也给出了最简单的插入队列实现 demo/queue.php:

在这个例子中,queue.php需要以cli方式运行,将cli接收到的第一个参数作为Job名称,插入名为'default'的队列,同时向屏幕输出刚才插入队列的Job Id。在终端输入:

结果可以看到屏幕上输出:

即Job已经添加成功。注意这里的Job名称与我们编写的Job Class名称保持一致:PHP_Job

3.查看Job运行情况php-resque同样提供了查看Job运行状态的例子,直接运行:

可以看到输出为:

我们刚才创建的Job状态为1。在Resque中,一个Job有以下4种状态:

Resque_Job_Status::STATUS_WAITING = 1; (等待) Resque_Job_Status::STATUS_RUNNING = 2; (正在执行) Resque_Job_Status::STATUS_FAILED = 3; (失败) Resque_Job_Status::STATUS_COMPLETE = 4; (结束)

因为没有Worker运行,所以刚才创建的Job还是等待状态。

4.运行Worker这次我们直接编写demo/resque.php:

可以看到一个Worker至少需要两部分:

可以直接包含Job类文件,也可以使用php的自动加载机制,指定好Job Class所在路径并能实现自动加载包含Resque的默认Worker: bin/resque在终端中运行:

前面的QUEUE部分是设置环境变量,我们指定当前的Worker只负责处理default队列。也可以使用

来处理所有队列。

运行后输出为

用ps指令检查一下:

可以看到有一个php的守护进程已经在运行了

再使用之前的检查Job指令

2分钟后可以看到

任务已经运行完毕,同时屏幕上应该可以看到输出的Hello!

PHP上传图片类显示缩略图功能 有缩略图功能但是感觉不全面,而且有点问题,继续学习,将来以后修改下formaction="php$_SERVER['PHP_SELF'];"enctype="multipart/form-data"method="post"inputtype="text"name="

eclipse php wamp配置教程 eclipse+php+wamp配置入门教程,具体内容如下想要学习php,被各种配置虐了一遍。现在提供一个最为简单的php配置。希望给第一次学习PHP的朋友,一些帮助

Yii2 ActiveRecord多表关联及多表关联搜索的实现 Yii的ActiveRecord是与数据库打交道的类,也即MVC中的M(模型层),也是ORM的O(Object)。一个老生常谈的问题。最近通过群里的反馈,觉得很多人还是没有

标签: php使用什么开发工具

本文链接地址:https://www.jiuchutong.com/biancheng/296429.html 转载请保留说明!

上一篇:Thinkphp批量更新数据的方法汇总(thinkphp批量导入数据)

下一篇:PHP上传图片类显示缩略图功能(php上传图片并显示)

  • 利润表里面的所得税
  • 离职人员补发工资怎么做账
  • 增值税发票综合服务平台密码
  • 物业公司增值税加计扣除
  • 房地产企业销售现房是否预缴增值税
  • 期初存货中固定制造费用
  • 已执行新金融准则利润表如何填列
  • 残保金申报工资应该是实发数吗
  • 什么情况下纳税调减
  • 建筑业异地预缴增值税流程
  • 折扣销售指
  • 个人所得税允许扣除的费用
  • 当月冲销的作废发票怎么账务处理?
  • 仓库货物破损处理方法
  • 公司购买饮水机的申请
  • 律师要钱吗
  • 发票逾期未认证个人要承担责任吗
  • 税费种认定功能在哪里
  • 其他应付款余额在借方表示什么意思
  • 混合销售行为的含义及税务处理
  • 金税盘没有清卡可以开票吗
  • 零余额账户期末怎么结转?
  • 个税零申报工资填0吗
  • 太阳能真空管和普通管的区别
  • 设备销售和安装账务
  • 合并企业的增值税税率
  • 购买活动赠品会计分录
  • 单位收到项目前的钱
  • txt文档乱码怎么办
  • 怎么关闭win10搜索栏
  • PHP:curl_pause()的用法_cURL函数
  • 恶搞代码vbs教程
  • 公司搬家费用怎么入账
  • 契税计税依据及计算方式
  • 善意取得增值税专用发票 企业所得税
  • 解决的英文
  • PHP:imagecolormatch()的用法_GD库图像处理函数
  • sass转化为css
  • 存货损失的会计处理方法
  • [Vue warn]: Error in created hook: “TypeError: Cannot read properties of undefined (reading ‘$on‘)“
  • 销售多余材料的成本
  • 所得税减免要做账吗
  • 模型怎么部署
  • RedHat6.5/CentOS6.5安装Mysql5.7.20的教程详解
  • 债权投资产生的暂时性差异确认所得税吗
  • 委托加工物资验收时发生的成本怎么处理
  • 收到货款未开发票是否违法
  • 事业单位的财政拨款怎么做账
  • 疫情防控期间临时性工作补助申请
  • 模具成本核算汇总表
  • 互联网企业资产评估
  • 固定资产处置如何申报企业所得税
  • 滞留票不处理可以么
  • 营业收入增长率分析
  • 简易征收可以开具3专票吗
  • 财务费用怎么记账
  • sql server 数据库介绍
  • mysql修改允许远程连接
  • sqlserver临时表 效率
  • centos 任务计划
  • u盘ghost装机
  • win7界面比win10好看
  • iis安装失败找不到源文件
  • centos设置双网卡
  • Windows8怎么打开任务管理器
  • OpenGL ES2.0-iPhone开发-part1
  • androidsocket原理
  • js oncontextmenu事件使用详解
  • java获取两个日期间的所有月份
  • 浅谈一下新冠的好处
  • python基础教程 入门教程
  • unity3d android 插件
  • 基于JAVASCRIPT实现的可视化工具是
  • js操作对象的方法
  • jquery鼠标悬停显示内容
  • jquery datatable排序
  • 税务部门立足
  • 诺诺发票怎样上报汇总
  • 我国税制结构是怎样的
  • 国税网查发票真伪
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设