《PHP應(yīng)用：PHP的Laravel框架中使用消息隊(duì)列queue及異步隊(duì)列的方法》要點(diǎn)：
本文介紹了PHP應(yīng)用：PHP的Laravel框架中使用消息隊(duì)列queue及異步隊(duì)列的方法，希望對(duì)您有用。如果有疑問(wèn)，可以聯(lián)系我們。

queue配置PHP利用

首先闡明一下我之前的項(xiàng)目中如何使用queue的.PHP應(yīng)用

我們現(xiàn)在的項(xiàng)目都是用的symfony,老一點(diǎn)的項(xiàng)目用的symfony1.4,新一點(diǎn)的項(xiàng)目用的都是symfony2.symfony用起來(lái)整體感覺還是很爽的,尤其symfony2,整體上來(lái)講使用了很多java里面框架的設(shè)計(jì)思想.但是他不支持queue.在symfony,我們使用queue也經(jīng)歷了幾個(gè)過(guò)程.最開始使用張堰同學(xué)的httpsqs.這個(gè)簡(jiǎn)單使用,但是存在單點(diǎn).究竟我們的項(xiàng)目還是正式對(duì)外服務(wù)的,所以我們研究了Apache旗下的開源項(xiàng)目ActiveMQ,研究研究發(fā)現(xiàn)還有Apache旗下還有更新的MQ,那就是Apollo.最后我們決定使用的Apollo.PHP應(yīng)用

queue在我們的項(xiàng)目中主要的應(yīng)用場(chǎng)景就是異步處理一些比較耗時(shí)的功能,比如同步第三方數(shù)據(jù)、數(shù)據(jù)有變動(dòng)了同步通知到我們的第三方數(shù)據(jù)使用者等等.我們大致的思路是這樣的,在各個(gè)controller里面如果需要異步處理的,就把一個(gè)json對(duì)象encode一下,塞到Apollo里面.再寫一個(gè)work的Command,在這個(gè)Command中解析json對(duì)象,根據(jù)里面的action和參數(shù)決定來(lái)調(diào)用不同的辦法處理.根據(jù)業(yè)務(wù)需要同時(shí)在不同的機(jī)器上運(yùn)行Command作為守護(hù)進(jìn)程一直跑著,也算實(shí)現(xiàn)異步多任務(wù)處理應(yīng)用的方案.就這么一直使用著,直到發(fā)現(xiàn)了laravel.打算研究一下.如果可能替代一下也不是不可能.呵呵.PHP應(yīng)用

由于才開始學(xué)習(xí),當(dāng)然直接上laravel5.routes、controller、view都基本上和symfony差異不到,上手倒是不困難.最后研究一下queue.PHP應(yīng)用

1、安裝laravle,使用composer,卻是很簡(jiǎn)單.PHP應(yīng)用

composer global require "laravel/installer=~1.1"
vi ~/.bash_profile

把~/.composer/vendor/bin 參加到環(huán)境變量中.PHP應(yīng)用

source ~/.bash_profile

就可以直接在命令行中使用laravel了.試一下.PHP利用

laravel -V

能夠看到下面的,就代表勝利了.PHP應(yīng)用

Laravel Installer version 1.2.1

2、創(chuàng)立項(xiàng)目.PHP應(yīng)用

laravel new guagua

3、配置redis和queue. PHP利用

4、創(chuàng)立controller,PHP應(yīng)用

php artisan make:controller DefaultController

在controller的action中push100個(gè)queue的任務(wù).PHP利用

for($i = 0; $i < 100; $i ++) {
  Queue::push(new SendEmail("ssss".$i));
}

5、創(chuàng)立queue的CommandPHP應(yīng)用

php artisan make:command SendEmail --queued

改動(dòng)app/Commands/SendEmail.php,添加一個(gè)私有變量.PHP應(yīng)用

protected $msg;

同時(shí)改動(dòng)構(gòu)造函數(shù).PHP應(yīng)用

public function __construct($msg)
{
  $this->msg = $msg;
}

再修改的handle辦法PHP應(yīng)用

public function handle() {
  sleep(4);
  echo $this->msg."\t".date("Y-m-d H:i:s")."\n";
  $this->delete();
}

6、改動(dòng)routesPHP應(yīng)用

Route::get('/', [
  'as' => 'index',
  'uses' => 'DefaultController@index'
]);

7、監(jiān)聽queuePHP利用

php artisan queue:listen

為了驗(yàn)證多任務(wù)處置,我們同時(shí)開三個(gè)窗口運(yùn)行同樣的命令.PHP應(yīng)用

8、用laravel內(nèi)建的server啟動(dòng)服務(wù)PHP利用

php artisan serve --port 8080 

打開瀏覽器,拜訪http://localhost:8080/頁(yè)面.當(dāng)然也可以用nginx,apache之類的.但是需要各種配置,還是內(nèi)建的使用方便.PHP應(yīng)用

在控制臺(tái)就能看到各個(gè)queue執(zhí)行的環(huán)境了,如下圖.可以看到100個(gè)任務(wù)被三個(gè)work平分了.
PHP應(yīng)用

PHP利用

到此,基本達(dá)到了我想要的效果.驗(yàn)證了laravel可以簡(jiǎn)單實(shí)現(xiàn)queue,而且可以多任務(wù)處理.PHP應(yīng)用

make command生成的代碼中use App\Commands\Command ,但是運(yùn)行時(shí)提示沒有這個(gè)文件. 解決方法,修改為 use Illuminate\Console\Command; 不知道為什么會(huì)出現(xiàn)這個(gè)低級(jí)問(wèn)題,難道是我mac系統(tǒng)問(wèn)題,還是我的人品問(wèn)題.
在controller的action中push隊(duì)列的時(shí)候,沒有異步執(zhí)行,還是在action的腳本中執(zhí)行的. 發(fā)現(xiàn)是配置問(wèn)題,原來(lái)不僅僅要修改config中的queue.php,還要修改.evn中相關(guān)配置. 雖然問(wèn)題解決了,但是還是覺得蛋疼,不能理解.還需要在學(xué)習(xí)學(xué)習(xí)laravel.PHP應(yīng)用

異步隊(duì)列使用辦法
PHP應(yīng)用

1.配置PHP利用

關(guān)于隊(duì)列的定義,這里就不作介紹了.我們要使用異隊(duì)伍列就有兩個(gè)關(guān)鍵：PHP應(yīng)用

(1)存儲(chǔ)隊(duì)列的地方
(2)執(zhí)行任務(wù)的服務(wù)
打開 config/queue.php ,這是Laravel5關(guān)于隊(duì)列的配置文件.首先我們可以通過(guò) default 參數(shù)指定默認(rèn)隊(duì)列驅(qū)動(dòng),默認(rèn)配置是 sync , 這是同步隊(duì)列,我們要做異步隊(duì)列首先就要改變這里.假設(shè)我們用 database 作為驅(qū)動(dòng),隊(duì)列任務(wù)將會(huì)存放在數(shù)據(jù)庫(kù)中,而我們后面會(huì)另外啟動(dòng)一個(gè)后臺(tái)服務(wù)來(lái)處理隊(duì)列任務(wù),這便是異步方式了.PHP應(yīng)用

'default' => 'database'

修改完配置后,我們必要?jiǎng)?chuàng)建一個(gè)表來(lái)存放隊(duì)列任務(wù),Laravel5已經(jīng)在自帶artisan命令中內(nèi)置了一個(gè)指令用來(lái)生成數(shù)據(jù)遷移,只必要兩條命令即可,當(dāng)然你得實(shí)現(xiàn)配置好數(shù)據(jù)庫(kù)連接.PHP應(yīng)用

php artisan queue:table
php artisan migrate

2.啟動(dòng)隊(duì)列監(jiān)聽服務(wù)PHP利用

通過(guò)下面這條指令啟動(dòng)隊(duì)列監(jiān)聽服務(wù),它會(huì)自動(dòng)處置 jobs 表中的隊(duì)列任務(wù)：PHP應(yīng)用

php artisan queue:listen

在linux中,如果想讓它在后臺(tái)執(zhí)行,可以這樣：PHP利用

nohup php artisan queue:listen &

3.添加隊(duì)列任務(wù)PHP利用

關(guān)于隊(duì)列任務(wù)的添加,手冊(cè)里說(shuō)的比擬詳細(xì),這里就簡(jiǎn)單舉個(gè)例子吧.PHP應(yīng)用

首先,通過(guò)artisan創(chuàng)立一個(gè)隊(duì)列命令：PHP應(yīng)用

php artisan make:command SendEmail --queued

這樣會(huì)生成 app/Commands/SendEmail.php 這個(gè)類文件,這個(gè)類會(huì)被標(biāo)識(shí)為隊(duì)列命令,你可以在 handle 辦法中寫自己的業(yè)務(wù)邏輯.PHP應(yīng)用

在節(jié)制器中,可以簡(jiǎn)單通過(guò) Bus::dispatch 分發(fā)任務(wù):PHP應(yīng)用

Bus::dispatch(new \App\Commands\SendEmail());

你會(huì)發(fā)現(xiàn)任務(wù)不會(huì)立即執(zhí)行,而是被放到 jobs 表中,由隊(duì)列監(jiān)聽服務(wù)處置.PHP應(yīng)用

更詳細(xì)的用法建議參考 command bus 和 queue 相關(guān)的手冊(cè)章節(jié).PHP利用

《PHP應(yīng)用：PHP的Laravel框架中使用消息隊(duì)列queue及異步隊(duì)列的方法》是否對(duì)您有啟發(fā)，歡迎查看更多與《PHP應(yīng)用：PHP的Laravel框架中使用消息隊(duì)列queue及異步隊(duì)列的方法》相關(guān)教程，學(xué)精學(xué)透。維易PHP學(xué)院為您提供精彩教程。

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