アダプタ

« 戻る

Zend_Queue

アダプタ

Zend_Queueは、インターフェースZend_Queue_Adapter_AdapterInterfaceを実装するすべての待ち行列をサポートします。以下のメッセージ待ち行列サービスがサポートされます:

Apache ActiveMQ.
Zend_Dbを経たデータベースによる待ち行列
Memcacheによる MemcacheQ待ち行列
Zend Platform のジョブキュー。
内部配列。ユニットテストに役立ちます。

限定事項

メッセージ・トランザクション処理は、サポートされません。

固有のアダプタ - 設定の構成

デフォルトの設定が示される場合は、パラメータは任意です。デフォルトの設定が指定されない場合は、パラメータが必要です。

Apache ActiveMQ - Zend_Queue_Adapter_Activemq

ここでリストされたオプションは、既知の必須条件です。すべてのメッセージ発信サーバが、ユーザー名またはパスワードを必要とするというわけではありません。

$options['name'] = '/temp/queue1';

これは、使い始めたい待ち行列の名前です。（必須）
$options['driverOptions']['host'] = 'host.domain.tld';

$options['driverOptions']['host'] = '127.0.0.1';

ホストをIPアドレスまたはホスト名にセットするかもしれません。

ホストのデフォルトの設定は '127.0.0.1' です。
$options['driverOptions']['port'] = 61613;

ポートのデフォルトの設定は 61613 です。
$options['driverOptions']['username'] = 'username';

一部のメッセージ発信サーバのために選択できます。メッセージ発信サーバのためのマニュアルを読んでください。
$options['driverOptions']['password'] = 'password';

一部のメッセージ発信サーバのために選択できます。メッセージ発信サーバのためのマニュアルを読んでください。
$options['driverOptions']['timeout_sec'] = 2;

$options['driverOptions']['timeout_usec'] = 0;

これは、Zend_Queue_Adapter_Activemqがメッセージを返さない前にソケットで読み取り活動を待つ時間です。

Db - Zend_Queue_Adapter_Db

ドライバオプションは、多少の必須のオプションのためにチェックされます。（例えばtype、host、username、 passwordとdbname） $options['driverOptions']でパラメータとして、 Zend_DB::factory()のために付加パラメータに沿って渡すかもしれません。ここでは一覧に示されていませんが、渡すことができる付加的なオプションはportでしょう。

$options = array(
    'driverOptions' => array(
        'host'      => 'db1.domain.tld',
        'username'  => 'my_username',
        'password'  => 'my_password',
        'dbname'    => 'messaging',
        'type'      => 'pdo_mysql',
        'port'      => 3306, // optional parameter.
    ),
    'options' => array(
        // 更新のためにZend_Db_Selectを使います。
        // 全てのデータベースがこのフィーチャをサポートできるわけではありません。
        Zend_Db_Select::FOR_UPDATE => true
    )
);

// データベース待ち行列を作成
$queue = new Zend_Queue('Db', $options);

$options['name'] = 'queue1';

これは、使い始めたい待ち行列の名前です。（必須）
$options['driverOptions']['type'] = 'Pdo';

typeは、 Zend_Db::factory()を使ってもらいたいアダプタです。これは、Zend_Db::factory() クラス・メソッド呼び出しの最初のパラメータです。
$options['driverOptions']['host'] = 'host.domain.tld';

$options['driverOptions']['host'] = '127.0.0.1';

ホストをIPアドレスまたはホスト名にセットするかもしれません。

ホストのデフォルトの設定は '127.0.0.1' です。
$options['driverOptions']['username'] = 'username';
$options['driverOptions']['password'] = 'password';
$options['driverOptions']['dbname'] = 'dbname';

必須のテーブルを作成したデータベース名。下記の注意部分を見てください。

MemcacheQ - Zend_Queue_Adapter_Memcacheq

$options['name'] = 'queue1';

これは、使い始めたい待ち行列の名前です。（必須）
$options['driverOptions']['host'] = 'host.domain.tld';

$options['driverOptions']['host'] = '127.0.0.1;'

ホストをIPアドレスまたはホスト名にセットするかもしれません。

ホストのデフォルトの設定は '127.0.0.1' です。
$options['driverOptions']['port'] = 22201;

ポートのデフォルトの設定は 22201 です。

Zend Platform ジョブキュー - Zend_Queue_Adapter_PlatformJobQueue

$options['daemonOptions']['host'] = '127.0.0.1:10003';

利用したい Zend Platform ジョブキューデーモンに対応するホスト名とポート。（必須）
$options['daemonOptions']['password'] = '1234';

Zend Platform ジョブキューデーモンにアクセスするために必要なパスワード。（必須）

配列 - Zend_Queue_Adapter_Array

$options['name'] = 'queue1';

これは、使い始めたい待ち行列の名前です。（必須）

アダプタ固有の注意

下記のアダプタには注意があります:

Apache ActiveMQ

Zend_Queue_Adapter_Activemqのための可視性期間は利用できません。

ApacheのActiveMQが複数のサブスクリプションをサポートするのに対して、 Zend_Queueはそうしません。それぞれのサブスクリプションのために新しいZend_Queueオブジェクトを作成しなければなりません。

ActiveMQの待ち行列または項目の名前は下記のうちの一つで始めなくてはいけません:

/queue/
/topic/
/temp-queue/
/temp-topic/

例えば: /queue/testing

下記の関数はサポートされません:

create() - 待ち行列の作成。この関数を呼ぶと例外を発生します。
delete() - 待ち行列の削除。この関数を呼ぶと例外を発生します。
getQueues() - 待ち行列の一覧。この関数を呼ぶと例外を発生します。

Zend_Db

データベースCREATE TABLE ( ... ) SQL 文がZend/Queue/Adapter/Db/mysql.sqlにあります。

MemcacheQ

Memcacheはhttp://www.danga.com/memcached/ からダウンロードできます。

MemcacheQはhttp://memcachedb.org/memcacheq/ からダウンロードできます。

deleteMessage() - メッセージは、待ち行列から受信と同時に削除されます。この関数を呼んでも効果がありません。この関数を呼ぶとエラーを発生します。
count()またはcount($adapter) - MemcacheQは、待ち行列で件数を数えるためのメソッドをサポートしません。この関数を呼ぶとエラーを発生します。

Zend Platform ジョブキュー

ジョブキューは、企業ソリューション商品 Zend Platform のフィーチャーです。それは伝統的なメッセージキューではなく、その代わりに渡したいパラメータと一緒に、実行するスクリプトを待ち行列に入れることができます。 zend.co.jpウェブサイトでジョブ・キューについてもっと知ることができます。

以下は、このアダプターの動作が標準的な提供物と相違するメソッドの一覧です:

create() - Zend Platformには、個別のキューの概念がありません。その代わりに、管理者が実行段階ジョブにスクリプトを与えることができます。新しいスクリプトを加えることは管理画面に制限されるので、このメソッドは、単にアクションが禁じられていることを示す例外を投げます。
isExists() - create() と同様に、ジョブキューには命名されたキューの概念がないので、このメソッドは呼び出されると例外を投げます。
delete() - create() と同様に、管理画面以外ではジョブキューのスクリプトの削除はできません。このメソッドは、例外を発生します。
getQueues() - Zend Platformは、 API によってスクリプトを取り扱う、タスク生成されたジョブを参照できません。このメソッドは、例外を投げます。
count() - ジョブキューで現在アクティブなジョブの数を返します。
send() - このメソッドは、恐らく最も他のアダプターと異なるメソッドの一つです。$message引数は３種類のどれか１つで、渡された値によって異なる動作をします。
- string - 実行するジョブキューに登録されるスクリプト名このように渡されると、引数はスクリプトに与えられません。
- array - ZendApi_Jobオブジェクトを設定する配列。これらは、以下を含むかもしれません。
  - script - 実行するジョブキュースクリプト名（必須）
  - priority - キューに名前を登録するときに使うジョブ優先順位
  - name - ジョブを記述する短い文字列
  - predecessor - これが始まるであろう前に実行されなければいけない、これがそれによって左右されるジョブのID
  - preserved - ジョブ・キュー・ヒストリの内部でジョブを保持するべきかどうか。デフォルトはoff。保持するためには、 TRUE を渡します。
  - user_variables - ジョブの実行中に、（命名された引数と同様に）保持したい変数すべての連想配列
  - interval - ジョブは、しばしば数秒単位で、実行しなければならないでしょう。デフォルトは0で、一度だけ実行されることを示します。
  - end_time - 期限満了時刻。それを過ぎるとジョブは動作しません。もしジョブが一回だけ実行するよう設定されているか、またはend_timeを過ぎると、ジョブは実行されません。ジョブが一定間隔ごとに実行するように設定されている場合、end_timeを過ぎると実行されません。
  - schedule_time - いつジョブを実行させるべきかを示すUNIXタイムスタンプ。デフォルトは0で、ジョブはできるだけ早く実行しなければならないことを示します。
  - application_id - ジョブのアプリケーション識別子。デフォルトは NULL で、キューがアプリケーションIDを割り当てられたら、アプリケーションIDがキューによって自動的に割り当てられることを示します。
  前述のように、script引数のみ必須です。他のすべては、どのように、そして、いつジョブを走らせるべきかというような、よりきめ細かい詳細を渡すために利用します。
- ZendApi_Job - 結局、単にZendApi_Jobのインスタンスを渡すかもしれません。そして、それはPlatformのジョブキューに一緒に渡されます。
send()は、インスタンスの全てで Zend_Queue_Message_PlatformJobオブジェクトを返します。そして、ジョブキューと通信するために使うZendApi_Job オブジェクトへのアクセスを提供します。
receive() - ジョブキューから実行中のジョブのリストを取得します。返されたセットの各々のジョブは、 Zend_Queue_Message_PlatformJobのインスタンスです。
deleteMessage() - このアダプターはジョブキューだけで機能するので、このメソッドは、与えられた$messageが Zend_Queue_Message_PlatformJobのインスタンスであることを期待します。さもなければ例外を発生します。

配列 (内部)

配列待ち行列はローカルメモリ上のPHP array()です。 Zend_Queue_Adapter_Arrayはユニットテスト用に適しています。

« 戻る

フレームワーク