Zend_Queueは、
待ち行列サービスの詳細を隠す代理です。
待ち行列サービスは、Zend_Queue_Adapter_<service>によって表現されます。
たとえば、Zend_Queue_Adapter_Dbは、
メッセージを格納・読み出しするためにデータベーステーブルを使う待ち行列です。
下記は、待ち行列システムのためにデータベーステーブルを利用する例です:
$options = array(
'name' => 'queue1',
'driverOptions' => array(
'host' => '127.0.0.1',
'port' => '3306',
'username' => 'queue',
'password' => 'queue',
'dbname' => 'queue',
'type' => 'pdo_mysql'
)
);
// データベース待ち行列を作成します。
// Zend_Queue はクラス名として Zend_Queue_Adapter_ の後に 'Db' を付加します。
$queue = new Zend_Queue('Db', $options);
Zend_QueueコンストラクタはZend_Queue_Adapter_Dbを作成して、
構成設定値でアダプタを初期化します。
各々のアダプタに認められた構成設定値は、 アダプタの注意で示されます
Zend_Queueは
クラスZend_Queue_Message_Iteratorを用いてメッセージを返します。
そして、それはSPL Iterator及びCountableの実装です。
Zend_Queue_Message_Iteratorは、
Zend_Queue_Messageオブジェクトの配列を含みます。
$messages = $queue->receive(5);
foreach ($messages as $i => $message) {
echo "$i) Message => ", $message->body, "\n";
}
投げられるどんな例外も、クラスZend_Queue_Exceptionです。
Zend_Queueは、
アダプタを表現する代理クラスです。
send()や
count($queue)、そして
receive()メソッドは、
待ち行列と相互に作用するために、それぞれのアダプタによって使用されます。
createQueue()及び
deleteQueue()メソッドは待ち行列を管理するために使われます。
Zend_Queueによってサポートされる待ち行列サービスは、
同じ関数をサポートするとは限りません。
例えば、Zend_Queue_Adapter_Array及び
Zend_Queue_Adapter_Dbは全ての関数をサポートしますが、
一方、Zend_Queue_Adapter_Activemqは
待ち行列の一覧や削除、そしてメッセージのカウントをサポートしません。
Zend_Queue::isSupported()または
Zend_Queue::getCapabilities()を使って
どんな関数がサポートされるか判定できます。
-
createQueue()- 待ち行列を作成 -
deleteQueue()- 待ち行列を削除 -
send()- メッセージを送信send()はアダプタ全てで利用可能なわけではありません;Zend_Queue_Adapter_Nullはsend()をサポートしません。 -
receive()- メッセージを受信receive()はアダプタ全てで利用可能なわけではありません;Zend_Queue_Adapter_Nullはreceive()をサポートしません。 -
deleteMessage()- メッセージを削除 -
count()- 待ち行列内のメッセージ数をカウント -
isExists()- 待ち行列が存在するかチェック
receive()メソッドは、
待ち行列と相互に作用するために、それぞれのアダプタによって使用されます。
createQueue()及び
deleteQueue()メソッドは待ち行列を管理するために使われます。