PHP的Laravel框架中使用消息隊(duì)列queue及異步隊(duì)列的方法

2020-03-22 17:48:31

字體：大中小

供稿：網(wǎng)友

首先說(shuō)明一下我之前的項(xiàng)目中如何使用queue的。我們現(xiàn)在的項(xiàng)目都是用的symfony，老一點(diǎn)的項(xiàng)目用的symfony1.4，新一點(diǎn)的項(xiàng)目用的都是symfony2。symfony用起來(lái)整體感覺(jué)還是很爽的，尤其symfony2，整體上來(lái)講使用了很多java里面框架的設(shè)計(jì)思想。但是他不支持queue。在symfony，我們使用queue也經(jīng)歷了幾個(gè)過(guò)程。最開(kāi)始使用張堰同學(xué)的httpsqs。這個(gè)簡(jiǎn)單使用，但是存在單點(diǎn)。畢竟我們的項(xiàng)目還是正式對(duì)外服務(wù)的，所以我們研究了Apache旗下的開(kāi)源項(xiàng)目ActiveMQ，研究研究發(fā)現(xiàn)還有Apache旗下還有更新的MQ，那就是Apollo。最后我們決定使用的Apollo。queue在我們的項(xiàng)目中主要的應(yīng)用場(chǎng)景就是異步處理一些比較耗時(shí)的功能，比如同步第三方數(shù)據(jù)、數(shù)據(jù)有變動(dòng)了同步通知到我們的第三方數(shù)據(jù)使用者等等。我們大致的思路是這樣的，在各個(gè)controller里面如果需要異步處理的，就把一個(gè)json對(duì)象encode一下，塞到Apollo里面。再寫(xiě)一個(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。打算研究一下。如果可能替代一下也不是不可能。呵呵。由于才開(kāi)始學(xué)習(xí)，當(dāng)然直接上laravel5。routes、controller、view都基本上和symfony差別不到，上手倒是不困難。最后研究一下queue。1、安裝laravle，使用composer，倒是很簡(jiǎn)單。composer global require "laravel/installer=~1.1"vi ~/.bash_profile把~/.composer/vendor/bin 加入到html' target='_blank'>環(huán)境變量中。source ~/.bash_profile就可以直接在命令行中使用laravel了。試一下。laravel -V能夠看到下面的，就代表成功了。Laravel Installer version 1.2.12、創(chuàng)建項(xiàng)目。laravel new guagua3、配置redis和queue。 4、創(chuàng)建controller，php artisan make:controller DefaultController在controller的action中push100個(gè)queue的任務(wù)。for($i = 0; $i 100; $i ++) { Queue::push(new SendEmail("ssss".$i));5、創(chuàng)建queue的Commandphp artisan make:command SendEmail --queued修改app/Commands/SendEmail.php，添加一個(gè)私有變量。protected $msg;同時(shí)修改構(gòu)造函數(shù)。public function __construct($msg) $this- msg = $msg;再修改的handle方法public function handle() { sleep(4); echo $this- msg."/t".date("Y-m-d H:i:s")."/n"; $this- delete();6、修改routesRoute::get('/', [ 'as' = 'index', 'uses' = 'DefaultController@index'7、監(jiān)聽(tīng)queuephp artisan queue:listen為了驗(yàn)證多任務(wù)處理，我們同時(shí)開(kāi)三個(gè)窗口運(yùn)行同樣的命令。8、用laravel內(nèi)建的server啟動(dòng)服務(wù)php artisan serve --port 8080 打開(kāi)瀏覽器，訪問(wèn)http://localhost:8080/頁(yè)面。當(dāng)然也可以用nginx，apache之類的。但是需要各種配置，還是內(nèi)建的使用方便。在控制臺(tái)就能看到各個(gè)queue執(zhí)行的情況了，如下圖?？梢钥吹?00個(gè)任務(wù)被三個(gè)work平分了。
到此，基本達(dá)到了我想要的效果。驗(yàn)證了laravel可以簡(jiǎn)單實(shí)現(xiàn)queue，并且可以多任務(wù)處理。make command生成的代碼中use App/Commands/Command ，但是運(yùn)行時(shí)提示沒(méi)有這個(gè)文件。解決辦法，修改為 use Illuminate/Console/Command; 不知道為什么會(huì)出現(xiàn)這個(gè)低級(jí)問(wèn)題，難道是我mac系統(tǒng)問(wèn)題，還是我的人品問(wèn)題。
在controller的action中push隊(duì)列的時(shí)候，沒(méi)有異步執(zhí)行，還是在action的腳本中執(zhí)行的。發(fā)現(xiàn)是配置問(wèn)題，原來(lái)不僅僅要修改config中的queue.php，還要修改.evn中相關(guān)配置。雖然問(wèn)題解決了，但是還是覺(jué)得蛋疼，不能理解。還需要在學(xué)習(xí)學(xué)習(xí)laravel。異步隊(duì)列使用方法
1.配置關(guān)于隊(duì)列的定義，這里就不作介紹了。我們要使用異步隊(duì)列就有兩個(gè)關(guān)鍵：（1）存儲(chǔ)隊(duì)列的地方
（2）執(zhí)行任務(wù)的服務(wù)
打開(kāi) 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ù)，這就是異步方式了。'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 artisan queue:tablephp artisan migrate這樣就自動(dòng)在數(shù)據(jù)庫(kù)中創(chuàng)建了 jobs 表。2.啟動(dòng)隊(duì)列監(jiān)聽(tīng)服務(wù)通過(guò)下面這條指令啟動(dòng)隊(duì)列監(jiān)聽(tīng)服務(wù)，它會(huì)自動(dòng)處理 jobs 表中的隊(duì)列任務(wù)：php artisan queue:listen在linux中，如果想讓它在后臺(tái)執(zhí)行，可以這樣：nohup php artisan queue:listen &3.添加隊(duì)列任務(wù)關(guān)于隊(duì)列任務(wù)的添加，手冊(cè)里說(shuō)的比較詳細(xì)，這里就簡(jiǎn)單舉個(gè)例子吧。首先，通過(guò)artisan創(chuàng)建一個(gè)隊(duì)列命令：php artisan make:command SendEmail --queued這樣會(huì)生成 app/Commands/SendEmail.php 這個(gè)類文件，這個(gè)類會(huì)被標(biāo)識(shí)為隊(duì)列命令，你可以在 handle 方法中寫(xiě)自己的業(yè)務(wù)邏輯。在控制器中，可以簡(jiǎn)單通過(guò) Bus::dispatch 分發(fā)任務(wù):Bus::dispatch(new /App/Commands/SendEmail());你會(huì)發(fā)現(xiàn)任務(wù)不會(huì)立即執(zhí)行，而是被放到 jobs 表中，由隊(duì)列監(jiān)聽(tīng)服務(wù)處理。更詳細(xì)的用法建議參考 command bus 和 queue 相關(guān)的手冊(cè)章節(jié)。PHP教程

鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請(qǐng)第一時(shí)間聯(lián)系我們修改或刪除，多謝。

上一篇：php源碼之搭建站點(diǎn)實(shí)現(xiàn)登錄頁(yè)面的方法

下一篇：php5.4以下版本json不支持不轉(zhuǎn)義內(nèi)容中文的解決方法