后台任务和PHP-Resque的使用

╰半橙微兮° 2022-07-15 23:55 108阅读 0赞

# 后台任务和PHP-Resque的使用（四） 使用Worker #

发表于 2015-04-05    |   分类于 [PHP ][PHP]   |      |   阅读次数 1134

注意，这篇教程仅适用于Linux和OS X的系统，Windows并不适用。

### 理解Worker的本质 ###

技术上讲一个Worker就是一个不断运行的PHP进程，并且不断监视新的任务并运行。

一个简单的Worker的代码如下：

<table style="margin: 0px; width: auto; border-collapse: collapse; border-spacing: 0px; border: none; font-size: 14px; table-layout: fixed;"> 
 <tbody> 
  <tr style="background-color: rgb(249, 249, 249);"> 
   <td style="padding: 0px; vertical-align: middle; border: none;"><pre style="font-family: consolas, Menlo, 'PingFang SC', 'Microsoft YaHei', monospace; font-size: 13px; overflow: auto; margin-top: 0px; margin-bottom: 0px; padding: 1px 20px 1px 1px; color: rgb(102, 102, 102); background-color: rgb(247, 247, 247); line-height: 1.6; border: none; text-align: right;">
       
        
     <div style="height: 20px;">
      
         
        1
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        2
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        3
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        4
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        5
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        6
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        7
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        8
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        9
       
        
     </div></pre></td> 
   <td style="padding: 0px; vertical-align: middle; border: none;"><pre style="font-family: consolas, Menlo, 'PingFang SC', 'Microsoft YaHei', monospace; font-size: 13px; overflow: auto; margin-top: 0px; margin-bottom: 0px; padding: 1px; color: rgb(77, 77, 76); background-color: rgb(247, 247, 247); line-height: 1.6; border: none;">
       
        
     <div style="height: 20px;">
        
         
      <span style="color: rgb(137, 89, 168);">while</span> (
        
         
      <span style="color: rgb(137, 89, 168);">true</span>) {
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
            $jobs = pullData(); 
        
         
      <span style="color: rgb(142, 144, 140);">// 从队列中拉取任务</span>
       
        
     </div>
       
        
     <div style="height: 20px;"></div>
       
        
     <div style="height: 20px;">    
        
         
      <span style="color: rgb(137, 89, 168);">foreach</span> ($jobs 
        
         
      <span style="color: rgb(137, 89, 168);">as</span> $class =&gt; $args) { 
        
         
      <span style="color: rgb(142, 144, 140);">// 循环每个找到的任务</span>
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
                $job = 
        
         
      <span style="color: rgb(137, 89, 168);">new</span> $class();
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
                $job-&gt;perform($args); 
        
         
      <span style="color: rgb(142, 144, 140);">// 执行任务</span>
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
            }
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
            sleep(
        
         
      <span style="color: rgb(113, 140, 0);">300</span>); 
        
         
      <span style="color: rgb(142, 144, 140);">// 等待5分钟后再次尝试拉取任务</span>
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        }
       
        
     </div></pre></td> 
  </tr> 
 </tbody> 
</table>

以上这些代码的具体实现都可以交给php-resque。创建一个Worker，php-resque需要以下参数：

*  `QUEUE`: 需要执行的队列的名字
 *  `INTERVAL`：在队列中循环的间隔时间，即完成一个任务后的等待时间，默认是5秒
 *  `APP_INCLUDE`：需要自动载入PHP文件路径，Worker需要知道你的Job的位置并载入Job
 *  `COUNT`：需要创建的Worker的数量。所有的Worker都具有相同的属性。默认是创建1个Worker
 *  `REDIS_BACKEND`：Redis服务器的地址，使用 hostname:port 的格式，如127.0.0.1:6379，或localhost:6379。默认是localhost:6379
 *  `REDIS_BACKEND_DB`：使用的Redis数据库的名称，默认是0
 *  `VERBOSE`：啰嗦模式，设置“1”为启用，会输出基本的调试信息
 *  `VVERBOSE`：设置“1”启用更啰嗦模式，会输出详细的调试信息
 *  `PREFIX`：前缀。在Redis数据库中为队列的KEY添加前缀，以方便多个Worker运行在同一个Redis数据库中方便区分。默认为空
 *  `PIDFILE`：手动指定PID文件的位置，适用于单Worker运行方式

以上参数中只有`QUEUE`是必须的。如果让Worker监视执行多个队列，可以用逗号隔开多个队列的名称，如：”queue1,queue2,queue3”，队列执行是有顺序的，如上queue2和queue3总是会在queue1后面被执行。

也可以设置`QUEUE`为`*`让Worker以字母顺序执行所有的队列。

Worker 必须以CLI方式启动。你不可以从浏览器启动Worker，因为：

*  你无法从浏览器执行后台任务
 *  PCNTL扩展只能运行在CLI模式

### 启动Worker ###

可以从`resque.php`启动Worker，这个位置位于php-resque/bin目录下（也可能不带.php后缀）。

在终端中执行：

很显然Worker不会被启动，因为缺少必须的参数`QUEUE`，程序将会返回如下错误：

php-resque通过`getenv`获取参数，所以在启动Worker的时候应该传递环境变量过去。所以应该以下面的方式启动Worker：

如果启用`VVERBOSE`模式：

终端将会输出：

<table style="margin: 0px; width: auto; border-collapse: collapse; border-spacing: 0px; border: none; font-size: 14px; table-layout: fixed;"> 
 <tbody> 
  <tr style="background-color: rgb(249, 249, 249);"> 
   <td style="padding: 0px; vertical-align: middle; border: none;"><pre style="font-family: consolas, Menlo, 'PingFang SC', 'Microsoft YaHei', monospace; font-size: 13px; overflow: auto; margin-top: 0px; margin-bottom: 0px; padding: 1px 20px 1px 1px; color: rgb(102, 102, 102); background-color: rgb(247, 247, 247); line-height: 1.6; border: none; text-align: right;">
       
        
     <div style="height: 20px;">
      
         
        1
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        2
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        3
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        4
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        5
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        6
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        7
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        8
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        9
       
        
     </div></pre></td> 
   <td style="padding: 0px; vertical-align: middle; border: none;"><pre style="font-family: consolas, Menlo, 'PingFang SC', 'Microsoft YaHei', monospace; font-size: 13px; overflow: auto; margin-top: 0px; margin-bottom: 0px; padding: 1px; color: rgb(77, 77, 76); background-color: rgb(247, 247, 247); line-height: 1.6; border: none;">
       
        
     <div style="height: 20px;">
      
         
        *** Starting worker KAMISAMA-MAC.local:84499:notification
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:18 2012-10-11] Registered signals
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:18 2012-10-11] Checking achievement
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:18 2012-10-11] Checking notification
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:18 2012-10-11] Sleeping for 5
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:23 2012-10-11] Checking achievement
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:23 2012-10-11] Checking notification
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ** [23:48:23 2012-10-11] Sleeping for 5
       
        
     </div>
       
        
     <div style="height: 20px;">
      
         
        ... etc ...
       
        
     </div></pre></td> 
  </tr> 
 </tbody> 
</table>

Worker会自动被命名为`KAMISAMA-MAC.local:84499:notification`，命名的规则是`hostname:process-id:queue-names`。

如果觉得这种启动方式太麻烦且难记，可以自己手动写一个bash脚本来帮助你启动Resque，如：

### 后台运行Worker ###

通过上面的方法成功启动了Worker，但只有在终端开启的状态下，关闭终端或按下Ctrl+C时Worker就会停止运行。我们可以在命令后面添加一个`&`来使其后台运行。

这样就可以让resque在后台运行。但如果你开启了VERBOSE模式，所有的输出信息将会丢失。所以我们需要在resque后台运行时把输出的信息保存起来。

我们可以使用`nohup`来保持resque后台运行，即使是在用户登出后。

### 记录下Worker的输出 ###

可以使用管道操作的方式重定向输出到文件：

这样一来所有的标准及错误输出都会被写入到*logfile.log*文件中。如果需要监视这个文件的内容：

### Worker的执行权限 ###

无论何时你在终端中执行命令都是以当前登录用户的权限来执行。如果你登录的jerry的账户，php-resque将会运行于jerry的权限下。以root用户登录时也一样。

如果需要避开当前登录账户以其它用户的权限运行，如Apache通常运行在*www-data*用户下，让php-resque运行于www-data账户：