在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
项目中经常会有后台运行任务的需求,比如发送邮件时,因为要连接邮件服务器,往往需要5-10秒甚至更长时间,如果能先给用户一个成功的提示信息,然后在后台慢慢处理发送邮件的操作,显然会有更好的用户体验。 为了实现类似的需求,Web项目中一般的实现方法是使用消息队列(Message Queue),比如MemcacheQ,RabbitMQ等等,都是很著名的产品。 消息队列说白了就是一个最简单的先进先出队列,队列的一个成员就是一段文本。正是因为消息队列实在太简单了,当拿着消息队列时,反而有点无从下手的感觉,因为这仅仅一个发送邮件的任务,就会引申出很多问题:
Resque对后台任务的设计与角色划分对以上这些问题,目前为止我能找到的最好答案,并不是来自php,而是来自Ruby的项目Resque,正是由于Resque清晰简单的解决了后台任务带来的一系列问题,Resque的设计也被Clone到Python、php、NodeJs等语言:比如Python下的pyres以及PHP下的php-resque等等,这里有各种语言版本的Resque实现,而在本篇日志里,我们当然要以PHP版本为例来说明如何用php-resque运行一个后台任务,可能一些细节方面会与Ruby版有出入,但是本文中以php版为准。 Resque是这样解决这些问题的: 后台任务的角色划分其实从上面的问题已经可以看出,只靠一个消息队列是无法解决所有问题的,需要新的角色介入。在Resque中,一个后台任务被抽象为由三种角色共同完成:
那么基于这个划分,一个后台任务在Resque下的基本流程是这样的:
至此就可以完整的运行完一个后台任务。 在Resque中,还有一个很重要的设计:一个Worker,可以处理一个队列,也可以处理很多个队列,并且可以通过增加Worker的进程/线程数来加快队列的执行速度。 php-resque的安装需要提前说明的是,由于涉及到进程的开辟与管理,php-resque使用了php的PCNTL函数,所以只能在Linux下运行,并且需要php编译PCNTL函数。如果希望用Windows做同样的工作,那么可以去找找Resque的其他语言版本,php在Windows下非常不适合做后台任务。 以Ubuntu12.04LTS为例,Ubuntu用apt安装的php已经默认编译了PCNTL函数,无需任何配置,以下指令均为root帐号 安装Redis
安装Composer
使用Composer安装php-resque假设web目录在/opt/htdocs
php-resque的使用编写一个Worker其实php-resque已经给出了简单的例子, demo/job.php文件就是一个最简单的Job:
这个Job就是在120秒后向STDOUT输出字符Hello! 在Resque的设计中,一个Job必须存在一个perform方法,Worker则会自动运行这个方法。 将Job插入队列php-resque也给出了最简单的插入队列实现 demo/queue.php:
在这个例子中,queue.php需要以cli方式运行,将cli接收到的第一个参数作为Job名称,插入名为'default'的队列,同时向屏幕输出刚才插入队列的Job Id。在终端输入:
结果可以看到屏幕上输出:
即Job已经添加成功。注意这里的Job名称与我们编写的Job Class名称保持一致:PHP_Job 查看Job运行情况php-resque同样提供了查看Job运行状态的例子,直接运行:
可以看到输出为:
我们刚才创建的Job状态为1。在Resque中,一个Job有以下4种状态:
因为没有Worker运行,所以刚才创建的Job还是等待状态。 运行Worker这次我们直接编写demo/resque.php:
可以看到一个Worker至少需要两部分:
在终端中运行:
前面的QUEUE部分是设置环境变量,我们指定当前的Worker只负责处理default队列。也可以使用
来处理所有队列。 运行后输出为
用ps指令检查一下:
可以看到有一个php的守护进程已经在运行了
再使用之前的检查Job指令
2分钟后可以看到
任务已经运行完毕,同时屏幕上应该可以看到输出的Hello! 至此我们已经成功的完成了一个最简单的Resque实例的全部演示,更复杂的情况以及遗留的问题会在下一次的日志中说明。 |
2022-08-15
2022-08-17
2022-11-06
2022-08-18
2022-07-18
请发表评论