ZendQueueとKestrelでメッセージキューサーバーを体験 #PHP

Kestrel

Scalaで書かれたメッセージキューサーバー。Twitterで使われてるらしいです。

Twitterで使っているScalaで書かれたオープンソースのメッセージキューサーバー、Kestrel :侍ズム#samuraism

インストールと起動

$ curl -O http://robey.github.com/kestrel/download/kestrel-2.4.1.zip
$ unzip kestrel-2.4.1.zip
$ cd kestrel-2.4.1
$ sudo java -jar kestrel_2.9.2-2.4.1.jar

ZendQueue

Zend Frameworkのコンポーネントの１つで、メッセージキューを利用するために使います。　　

GitHub
https://github.com/zendframework/ZendQueue

メッセージを格納する方法によって複数のアダプタが用意されています。

Kestrel用のアダプタはありませんが、Kestrelはmemcachedプロトコルをサポートしているので、MemcacheQアダプタを利用します。

Memcache

あらかじめMemcachedライブラリもインストールしておいて下さい。

Macの場合はHomebrewを使うと簡単にインストールできます♪

$ brew install memcached
$ brew install memcache-php

メッセージキューサーバーを体験

２つのスクリプトを用意してください。

・worker.php : ワーカープロセス。キューからメッセージを取得して表示する。

<?php
// worker.php
$options = array(
  'name' => 'ack_queue',
    'driverOptions' => array(
        'host' => 'localhost',
        'port' => '22133',
        ),
    );

$queue = new ZendQueue\Queue('MemcacheQ', $options);

for (;;) {
    $messages = $queue->receive(1);
    foreach ($messages as $mess) if ($mess->body) echo $mess->body . PHP_EOL;
}

・front.php : キューにメッセージを送信する。

<?php
// front.php
$options = array(
  'name' => 'ack_queue',
    'driverOptions' => array(
        'host' => 'localhost',
        'port' => '22133',
        ),
    );

$queue = new ZendQueue\Queue('MemcacheQ', $options);
$queue->send('Hello, World!');

ターミナルを２つたちあげてください。

・ターミナル１でworker.phpを実行

プロンプトが返ってこない → Kestrelのキューを監視してくれています。

・ターミナル２でfront.phpを実行すると…

ターミナル１に「Hello, World!」と表示されます！

簡単ですが以上です。

Hello, Worldが表示された時には感動しますね (・∀・)

worker.phpを実行するターミナルを増やしたりするとなお楽しくなってきます♪

参考

Twitterで使っているScalaで書かれたオープンソースのメッセージキューサーバー、Kestrel :侍ズム#samuraism

PHP+Kestrel+Supervisorでお手軽タスクキューイング :アシアルブログ

 PHPアプリでメッセージキューサーバを活用する - Zend_Queue - :CodeZine