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

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

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

• 消息队列只能存储字符串类型的数据，如何将一个发送邮件这样的“任务”，转换为消息队列中的一个“消息”"htmlcode">

  apt-get install redis-server
  

  安装Composer
  

  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/htdocs

  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：

  class PHP_Job
  {
    public function perform()
    {
      sleep(120);
      fwrite(STDOUT, 'Hello!');
    }
  }
  

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

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

  2.将Job插入队列
  php-resque也给出了最简单的插入队列实现 demo/queue.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 demo/queue.php PHP_Job
  

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

  Queued job b1f01038e5e833d24b46271a0e31f6d6
  

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

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

  php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6
  

  可以看到输出为：

  Tracking status of b1f01038e5e833d24b46271a0e31f6d6. Press [break] to stop. 
  Status of b1f01038e5e833d24b46271a0e31f6d6 is: 1
  

  我们刚才创建的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：

  <"htmlcode">
  
  QUEUE=default php demo/resque.php
  
  
  
  前面的QUEUE部分是设置环境变量，我们指定当前的Worker只负责处理default队列。也可以使用
  
  
  QUEUE=* php demo/resque.php
  
  
  
  来处理所有队列。
  运行后输出为
  
  
  #!/usr/bin/env php
  *** Starting worker
  
  
  
  用ps指令检查一下：
  
  
  ps aux | grep resque
  
  
  
  可以看到有一个php的守护进程已经在运行了
  
  
  1000   4607 0.0 0.1 74816 11612 pts/3  S+  14:52  0:00 php demo/resque.php
  
  
  
  再使用之前的检查Job指令
  
  
  php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6
  
  
  
  2分钟后可以看到
  
  
  Status of b1f01038e5e833d24b46271a0e31f6d6 is: 4
  
  
  
  任务已经运行完毕，同时屏幕上应该可以看到输出的Hello!