queue配置

首先說明一下我之前的項目中如何使用queue的。

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

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

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

1、安裝laravle，使用composer，倒是很簡單。

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

把~/.composer/vendor/bin 加入到環(huán)境變量中。

source ~/.bash_profile

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

laravel -V

能夠看到下面的，就代表成功了。

Laravel Installer version 1.2.1

2、創(chuàng)建項目。

laravel new guagua

3、配置redis和queue。

4、創(chuàng)建controller，

php artisan make:controller DefaultController

在controller的action中push100個queue的任務(wù)。

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

5、創(chuàng)建queue的Command

php artisan make:command SendEmail --queued

修改app/Commands/SendEmail.php，添加一個私有變量。

protected $msg;

同時修改構(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、修改routes

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

7、監(jiān)聽queue

php artisan queue:listen

為了驗證多任務(wù)處理，我們同時開三個窗口運行同樣的命令。

8、用laravel內(nèi)建的server啟動服務(wù)

php artisan serve --port 8080 

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

在控制臺就能看到各個queue執(zhí)行的情況了，如下圖?？梢钥吹?00個任務(wù)被三個work平分了。

到此，基本達到了我想要的效果。驗證了laravel可以簡單實現(xiàn)queue，并且可以多任務(wù)處理。

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

異步隊列使用方法

1.配置

關(guān)于隊列的定義，這里就不作介紹了。我們要使用異步隊列就有兩個關(guān)鍵：

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

'default' => 'database'

修改完配置后，我們需要創(chuàng)建一個表來存放隊列任務(wù)，Laravel5已經(jīng)在自帶artisan命令中內(nèi)置了一個指令用來生成數(shù)據(jù)遷移，只需要兩條命令即可，當(dāng)然你得實現(xiàn)配置好數(shù)據(jù)庫連接。

php artisan queue:table
php artisan migrate

2.啟動隊列監(jiān)聽服務(wù)

通過下面這條指令啟動隊列監(jiān)聽服務(wù)，它會自動處理 jobs 表中的隊列任務(wù)：

php artisan queue:listen

在linux中，如果想讓它在后臺執(zhí)行，可以這樣：

nohup php artisan queue:listen &

3.添加隊列任務(wù)

關(guān)于隊列任務(wù)的添加，手冊里說的比較詳細(xì)，這里就簡單舉個例子吧。

首先，通過artisan創(chuàng)建一個隊列命令：

php artisan make:command SendEmail --queued

這樣會生成 app/Commands/SendEmail.php 這個類文件，這個類會被標(biāo)識為隊列命令，你可以在 handle 方法中寫自己的業(yè)務(wù)邏輯。

在控制器中，可以簡單通過 Bus::dispatch 分發(fā)任務(wù):

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

你會發(fā)現(xiàn)任務(wù)不會立即執(zhí)行，而是被放到 jobs 表中，由隊列監(jiān)聽服務(wù)處理。

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

最新評論