乱爱性全过程免费视频/午夜毛片视频/中文字幕av三区/一级视频网址

當(dāng)前位置： 維易PHP培訓(xùn)學(xué)院 > PHP學(xué)習(xí) > 內(nèi)容正文

PHP實(shí)例：PHP使用php-resque庫(kù)配合Redis實(shí)現(xiàn)MQ消息隊(duì)列的教程

作者：VEPHP   時(shí)間 2017-10-02

《PHP實(shí)例：PHP使用php-resque庫(kù)配合Redis實(shí)現(xiàn)MQ消息隊(duì)列的教程》要點(diǎn)：
本文介紹了PHP實(shí)例：PHP使用php-resque庫(kù)配合Redis實(shí)現(xiàn)MQ消息隊(duì)列的教程，希望對(duì)您有用。如果有疑問(wèn)，可以聯(lián)系我們。

消息隊(duì)列處理后臺(tái)任務(wù)帶來(lái)的問(wèn)題
項(xiàng)目中經(jīng)常會(huì)有后臺(tái)運(yùn)行任務(wù)的需求,比如發(fā)送郵件時(shí),因?yàn)橐B接郵件服務(wù)器,往往需要5-10秒甚至更長(zhǎng)時(shí)間,如果能先給用戶(hù)一個(gè)成功的提示信息,然后在后臺(tái)慢慢處理發(fā)送郵件的操作,顯然會(huì)有更好的用戶(hù)體驗(yàn).PHP應(yīng)用

為了實(shí)現(xiàn)類(lèi)似的需求,Web項(xiàng)目中一般的實(shí)現(xiàn)方法是使用消息隊(duì)列(Message Queue),比如MemcacheQ,RabbitMQ等等,都是很著名的產(chǎn)品.PHP應(yīng)用

消息隊(duì)列說(shuō)白了就是一個(gè)最簡(jiǎn)單的先進(jìn)先出隊(duì)列,隊(duì)列的一個(gè)成員就是一段文本.正是因?yàn)橄㈥?duì)列實(shí)在太簡(jiǎn)單了,當(dāng)拿著消息隊(duì)列時(shí),反而有點(diǎn)無(wú)從下手的感覺(jué),因?yàn)檫@僅僅一個(gè)發(fā)送郵件的任務(wù),就會(huì)引申出很多問(wèn)題：PHP應(yīng)用

  • 消息隊(duì)列只能存儲(chǔ)字符串類(lèi)型的數(shù)據(jù),如何將一個(gè)發(fā)送郵件這樣的“任務(wù)”,轉(zhuǎn)換為消息隊(duì)列中的一個(gè)“消息”?
  • 消息隊(duì)列只負(fù)責(zé)數(shù)據(jù)的存放與進(jìn)出,本身不能執(zhí)行任何程序,那么我們要如何從消息隊(duì)列中一個(gè)一個(gè)取出數(shù)據(jù),再將這些數(shù)據(jù)轉(zhuǎn)化回任務(wù)并執(zhí)行.
  • 我們無(wú)法預(yù)知消息隊(duì)列何時(shí)會(huì)有數(shù)據(jù)產(chǎn)生,所以我們的任務(wù)執(zhí)行程序還需要具備監(jiān)控消息隊(duì)列的能力,也就是一個(gè)常駐后臺(tái)的守護(hù)進(jìn)程.
  • 一般的Web應(yīng)用PHP都以cgi方式運(yùn)行,無(wú)法常駐內(nèi)存.我們知道php還有cli模式,那么守護(hù)進(jìn)程是否能以php cli來(lái)實(shí)現(xiàn),效率如何?
  • 當(dāng)守護(hù)進(jìn)程運(yùn)行時(shí),Web應(yīng)用能否與后臺(tái)守護(hù)進(jìn)程交互,實(shí)現(xiàn)開(kāi)啟/殺死進(jìn)程的功能以及獲得進(jìn)程的運(yùn)行狀態(tài)?

Resque對(duì)后臺(tái)任務(wù)的設(shè)計(jì)與角色劃分PHP應(yīng)用

對(duì)以上這些問(wèn)題,目前為止我能找到的最好答案,并不是來(lái)自php,而是來(lái)自Ruby的項(xiàng)目Resque,正是由于Resque清晰簡(jiǎn)單的解決了后臺(tái)任務(wù)帶來(lái)的一系列問(wèn)題,Resque的設(shè)計(jì)也被Clone到Python、php、NodeJs等語(yǔ)言：比如Python下的pyres以及PHP下的php-resque等等,這里有各種語(yǔ)言版本的Resque實(shí)現(xiàn),而在本篇日志里,我們當(dāng)然要以PHP版本為例來(lái)說(shuō)明如何用php-resque運(yùn)行一個(gè)后臺(tái)任務(wù),可能一些細(xì)節(jié)方面會(huì)與Ruby版有出入,但是本文中以php版為準(zhǔn).PHP應(yīng)用

Resque是這樣解決這些問(wèn)題的：PHP應(yīng)用

后臺(tái)任務(wù)的角色劃分
其實(shí)從上面的問(wèn)題已經(jīng)可以看出,只靠一個(gè)消息隊(duì)列是無(wú)法解決所有問(wèn)題的,需要新的角色介入.在Resque中,一個(gè)后臺(tái)任務(wù)被抽象為由三種角色共同完成：PHP應(yīng)用

  • Job | 任務(wù) ： 一個(gè)Job就是一個(gè)需要在后臺(tái)完成的任務(wù),比如本文舉例的發(fā)送郵件,就可以抽象為一個(gè)Job.在Resque中一個(gè)Job就是一個(gè)Class.
  • Queue | 隊(duì)列 ： 也就是上文的消息隊(duì)列,在Resque中,隊(duì)列則是由Redis實(shí)現(xiàn)的.Resque還提供了一個(gè)簡(jiǎn)單的隊(duì)列管理器,可以實(shí)現(xiàn)將Job插入/取出隊(duì)列等功能.
  • Worker | 執(zhí)行者 ： 負(fù)責(zé)從隊(duì)列中取出Job并執(zhí)行,可以以守護(hù)進(jìn)程的方式運(yùn)行在后臺(tái).

那么基于這個(gè)劃分,一個(gè)后臺(tái)任務(wù)在Resque下的基本流程是這樣的：PHP應(yīng)用

  • 將一個(gè)后臺(tái)任務(wù)編寫(xiě)為一個(gè)獨(dú)立的Class,這個(gè)Class就是一個(gè)Job.
  • 在需要使用后臺(tái)程序的地方,系統(tǒng)將Job Class的名稱(chēng)以及所需參數(shù)放入隊(duì)列.
  • 以命令行方式開(kāi)啟一個(gè)Worker,并通過(guò)參數(shù)指定Worker所需要處理的隊(duì)列.
  • Worker作為守護(hù)進(jìn)程運(yùn)行,并且定時(shí)檢查隊(duì)列.
  • 當(dāng)隊(duì)列中有Job時(shí),Worker取出Job并運(yùn)行,即實(shí)例化Job Class并執(zhí)行Class中的方法.

至此就可以完整的運(yùn)行完一個(gè)后臺(tái)任務(wù).PHP應(yīng)用

在Resque中,還有一個(gè)很重要的設(shè)計(jì)：一個(gè)Worker,可以處理一個(gè)隊(duì)列,也可以處理很多個(gè)隊(duì)列,并且可以通過(guò)增加Worker的進(jìn)程/線程數(shù)來(lái)加快隊(duì)列的執(zhí)行速度.PHP應(yīng)用

php-resque的安裝
需要提前說(shuō)明的是,由于涉及到進(jìn)程的開(kāi)辟與管理,php-resque使用了php的PCNTL函數(shù),所以只能在Linux下運(yùn)行,并且需要php編譯PCNTL函數(shù).如果希望用Windows做同樣的工作,那么可以去找找Resque的其他語(yǔ)言版本,php在Windows下非常不適合做后臺(tái)任務(wù).PHP應(yīng)用

以Ubuntu12.04LTS為例,Ubuntu用apt安裝的php已經(jīng)默認(rèn)編譯了PCNTL函數(shù),無(wú)需任何配置,以下指令均為root帳號(hào)PHP應(yīng)用

安裝Redis
PHP應(yīng)用

apt-get install redis-server

安裝Composer
PHP應(yīng)用

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
假設(shè)web目錄在/opt/htdocsPHP應(yīng)用

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.編寫(xiě)一個(gè)Worker
其實(shí)php-resque已經(jīng)給出了簡(jiǎn)單的例子, demo/job.php文件就是一個(gè)最簡(jiǎn)單的Job：PHP應(yīng)用

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

這個(gè)Job就是在120秒后向STDOUT輸出字符Hello!PHP應(yīng)用

在Resque的設(shè)計(jì)中,一個(gè)Job必須存在一個(gè)perform方法,Worker則會(huì)自動(dòng)運(yùn)行這個(gè)方法.PHP應(yīng)用

2.將Job插入隊(duì)列
php-resque也給出了最簡(jiǎn)單的插入隊(duì)列實(shí)現(xiàn) demo/queue.php：PHP應(yīng)用

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";

在這個(gè)例子中,queue.php需要以cli方式運(yùn)行,將cli接收到的第一個(gè)參數(shù)作為Job名稱(chēng),插入名為'default'的隊(duì)列,同時(shí)向屏幕輸出剛才插入隊(duì)列的Job Id.在終端輸入：PHP應(yīng)用

php demo/queue.php PHP_Job

結(jié)果可以看到屏幕上輸出：PHP應(yīng)用

Queued job b1f01038e5e833d24b46271a0e31f6d6

即Job已經(jīng)添加成功.注意這里的Job名稱(chēng)與我們編寫(xiě)的Job Class名稱(chēng)保持一致：PHP_JobPHP應(yīng)用

3.查看Job運(yùn)行情況
php-resque同樣提供了查看Job運(yùn)行狀態(tài)的例子,直接運(yùn)行：PHP應(yīng)用

php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6

可以看到輸出為：PHP應(yīng)用

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

我們剛才創(chuàng)建的Job狀態(tài)為1.在Resque中,一個(gè)Job有以下4種狀態(tài)：PHP應(yīng)用

  • Resque_Job_Status::STATUS_WAITING = 1; (等待)
  • Resque_Job_Status::STATUS_RUNNING = 2; (正在執(zhí)行)
  • Resque_Job_Status::STATUS_FAILED = 3; (失敗)
  • Resque_Job_Status::STATUS_COMPLETE = 4; (結(jié)束)

因?yàn)闆](méi)有Worker運(yùn)行,所以剛才創(chuàng)建的Job還是等待狀態(tài).PHP應(yīng)用

4.運(yùn)行Worker
這次我們直接編寫(xiě)demo/resque.php：PHP應(yīng)用

<?php
date_default_timezone_set('GMT');
require 'job.php';
require '../bin/resque';

可以看到一個(gè)Worker至少需要兩部分：PHP應(yīng)用

可以直接包含Job類(lèi)文件,也可以使用php的自動(dòng)加載機(jī)制,指定好Job Class所在路徑并能實(shí)現(xiàn)自動(dòng)加載
包含Resque的默認(rèn)Worker： bin/resque
在終端中運(yùn)行：PHP應(yīng)用

QUEUE=default php demo/resque.php

前面的QUEUE部分是設(shè)置環(huán)境變量,我們指定當(dāng)前的Worker只負(fù)責(zé)處理default隊(duì)列.也可以使用PHP應(yīng)用

QUEUE=* php demo/resque.php

來(lái)處理所有隊(duì)列.PHP應(yīng)用

運(yùn)行后輸出為PHP應(yīng)用

#!/usr/bin/env php
*** Starting worker

用ps指令檢查一下：PHP應(yīng)用

ps aux | grep resque

可以看到有一個(gè)php的守護(hù)進(jìn)程已經(jīng)在運(yùn)行了PHP應(yīng)用

1000   4607 0.0 0.1 74816 11612 pts/3  S+  14:52  0:00 php demo/resque.php

再使用之前的檢查Job指令PHP應(yīng)用

php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6

2分鐘后可以看到PHP應(yīng)用

Status of b1f01038e5e833d24b46271a0e31f6d6 is: 4

任務(wù)已經(jīng)運(yùn)行完畢,同時(shí)屏幕上應(yīng)該可以看到輸出的Hello!PHP應(yīng)用

轉(zhuǎn)載請(qǐng)注明本頁(yè)網(wǎng)址：
http://www.fzlkiss.com/jiaocheng/6074.html


    標(biāo)簽：