《PHP实例：PHP使用php-resque库配合Redis实现MQ消息队列的教程》要点：
本文介绍了PHP实例：PHP使用php-resque库配合Redis实现MQ消息队列的教程，希望对您有用。如果有疑问，可以联系我们。
消息队列处理后台任务带来的问题
项目中经常会有后台运行任务的需求,比如发送邮件时,因为要连接邮件服务器,往往需要5-10秒甚至更长时间,如果能先给用户一个成功的提示信息,然后在后台慢慢处理发送邮件的操作,显然会有更好的用户体验.PHP应用
为了实现类似的需求,Web项目中一般的实现方法是使用消息队列(Message Queue),比如MemcacheQ,RabbitMQ等等,都是很著名的产品.PHP应用
消息队列说白了就是一个最简单的先进先出队列,队列的一个成员就是一段文本.正是因为消息队列实在太简单了,当拿着消息队列时,反而有点无从下手的感觉,因为这仅仅一个发送邮件的任务,就会引申出很多问题：PHP应用
Resque对后台任务的设计与角色划分PHP应用
对以上这些问题,目前为止我能找到的最好答案,并不是来自php,而是来自Ruby的项目Resque,正是由于Resque清晰简单的解决了后台任务带来的一系列问题,Resque的设计也被Clone到Python、php、NodeJs等语言：比如Python下的pyres以及PHP下的php-resque等等,这里有各种语言版本的Resque实现,而在本篇日志里,我们当然要以PHP版本为例来说明如何用php-resque运行一个后台任务,可能一些细节方面会与Ruby版有出入,但是本文中以php版为准.PHP应用
Resque是这样解决这些问题的：PHP应用
后台任务的角色划分
其实从上面的问题已经可以看出,只靠一个消息队列是无法解决所有问题的,需要新的角色介入.在Resque中,一个后台任务被抽象为由三种角色共同完成：PHP应用
那么基于这个划分,一个后台任务在Resque下的基本流程是这样的：PHP应用
至此就可以完整的运行完一个后台任务.PHP应用
在Resque中,还有一个很重要的设计：一个Worker,可以处理一个队列,也可以处理很多个队列,并且可以通过增加Worker的进程/线程数来加快队列的执行速度.PHP应用
php-resque的安装
需要提前说明的是,由于涉及到进程的开辟与管理,php-resque使用了php的PCNTL函数,所以只能在Linux下运行,并且需要php编译PCNTL函数.如果希望用Windows做同样的工作,那么可以去找找Resque的其他语言版本,php在Windows下非常不适合做后台任务.PHP应用
以Ubuntu12.04LTS为例,Ubuntu用apt安装的php已经默认编译了PCNTL函数,无需任何配置,以下指令均为root帐号PHP应用
安装Redis
PHP应用
apt-get install redis-server
安装Composer
PHP应用
apt-get install curl cd /usr/local/bin curl -s http://getcomposer.org/installer | php chmod a+x composer.phar alias composer='/usr/local/bin/composer.phar'
使用Composer安装php-resque
假设web目录在/opt/htdocsPHP应用
apt-get install git git-core cd /opt/htdocs git clone git://github.com/chrisboulton/php-resque.git cd php-resque composer install
php-resque的使用
1.编写一个Worker
其实php-resque已经给出了简单的例子, demo/job.php文件就是一个最简单的Job：PHP应用
class PHP_Job
{
public function perform()
{
sleep(120);
fwrite(STDOUT, 'Hello!');
}
}
这个Job就是在120秒后向STDOUT输出字符Hello!PHP应用
在Resque的设计中,一个Job必须存在一个perform方法,Worker则会自动运行这个方法.PHP应用
2.将Job插入队列
php-resque也给出了最简单的插入队列实现 demo/queue.php：PHP应用
if(empty($argv[1])) {
die('Specify the name of a job to add. e.g, php queue.php PHP_Job');
}
require __DIR__ . '/init.php';
date_default_timezone_set('GMT');
Resque::setBackend('127.0.0.1:6379');
$args = array(
'time' => time(),
'array' => array(
'test' => 'test',
),
);
$jobId = Resque::enqueue('default', $argv[1], $args, true);
echo "Queued job ".$jobId."\n\n";
在这个例子中,queue.php需要以cli方式运行,将cli接收到的第一个参数作为Job名称,插入名为'default'的队列,同时向屏幕输出刚才插入队列的Job Id.在终端输入：PHP应用
php demo/queue.php PHP_Job
结果可以看到屏幕上输出：PHP应用
Queued job b1f01038e5e833d24b46271a0e31f6d6
即Job已经添加成功.注意这里的Job名称与我们编写的Job Class名称保持一致：PHP_JobPHP应用
3.查看Job运行情况
php-resque同样提供了查看Job运行状态的例子,直接运行：PHP应用
php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6
可以看到输出为：PHP应用
Tracking status of b1f01038e5e833d24b46271a0e31f6d6. Press [break] to stop. Status of b1f01038e5e833d24b46271a0e31f6d6 is: 1
我们刚才创建的Job状态为1.在Resque中,一个Job有以下4种状态：PHP应用
因为没有Worker运行,所以刚才创建的Job还是等待状态.PHP应用
4.运行Worker
这次我们直接编写demo/resque.php：PHP应用
<?php
date_default_timezone_set('GMT');
require 'job.php';
require '../bin/resque';
可以看到一个Worker至少需要两部分：PHP应用
可以直接包含Job类文件,也可以使用php的自动加载机制,指定好Job Class所在路径并能实现自动加载
包含Resque的默认Worker： bin/resque
在终端中运行：PHP应用
QUEUE=default php demo/resque.php
前面的QUEUE部分是设置环境变量,我们指定当前的Worker只负责处理default队列.也可以使用PHP应用
QUEUE=* php demo/resque.php
来处理所有队列.PHP应用
运行后输出为PHP应用
#!/usr/bin/env php *** Starting worker
用ps指令检查一下：PHP应用
ps aux | grep resque
可以看到有一个php的守护进程已经在运行了PHP应用
1000 4607 0.0 0.1 74816 11612 pts/3 S+ 14:52 0:00 php demo/resque.php
再使用之前的检查Job指令PHP应用
php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6
2分钟后可以看到PHP应用
Status of b1f01038e5e833d24b46271a0e31f6d6 is: 4
任务已经运行完毕,同时屏幕上应该可以看到输出的Hello!PHP应用
转载请注明本页网址：
http://www.vephp.com/jiaocheng/6074.html
