範例 #1 物件導向風格
<?php
$queue = '/queue/foo';
$msg = 'bar';
/* 連線 */
try {
$stomp = new Stomp('tcp://127.0.0.1:61613');
} catch(StompException $e) {
die('連線失敗：' . $e->getMessage());
}
/* 發送訊息至佇列 'foo' */
$stomp->send($queue, $msg);
/* 訂閱來自佇列 'foo' 的訊息 */
$stomp->subscribe($queue);
/* 讀取框架 */
$frame = $stomp->readFrame();
if ($frame->body === $msg) {
var_dump($frame);
/* 確認已收到框架 */
$stomp->ack($frame);
}
/* 關閉連線 */
unset($stomp);
?>上述範例將輸出類似以下的內容
object(StompFrame)#2 (3) {
["command"]=>
string(7) "MESSAGE"
["headers"]=>
array(5) {
["message-id"]=>
string(41) "ID:php.net-55293-1257226743606-4:2:-1:1:1"
["destination"]=>
string(10) "/queue/foo"
["timestamp"]=>
string(13) "1257226805828"
["expires"]=>
string(1) "0"
["priority"]=>
string(1) "0"
}
["body"]=>
string(3) "bar"
}
範例 #2 程序式風格
<?php
$queue = '/queue/foo';
$msg = 'bar';
/* 連線 */
$link = stomp_connect('ssl://127.0.0.1:61612');
/* 檢查連線 */
if (!$link) {
die('連線失敗：' . stomp_connect_error());
}
/* 開始一個事務 */
stomp_begin($link, 't1');
/* 發送訊息到佇列 'foo' */
stomp_send($link, $queue, $msg, array('transaction' => 't1'));
/* 提交事務 */
stomp_commit($link, 't1');
/* 訂閱佇列 'foo' 的訊息 */
stomp_subscribe($link, $queue);
/* 讀取一個框架 */
$frame = stomp_read_frame($link);
if ($frame['body'] === $msg) {
var_dump($frame);
/* 確認已收到框架 */
stomp_ack($link, $frame['headers']['message-id']);
}
/* 關閉連線 */
stomp_close($link);
?>上述範例將輸出類似以下的內容
array(3) {
["command"]=>
string(7) "MESSAGE"
["body"]=>
string(3) "bar"
["headers"]=>
array(6) {
["transaction"]=>
string(2) "t1"
["message-id"]=>
string(41) "ID:php.net-55293-1257226743606-4:3:-1:1:1"
["destination"]=>
string(10) "/queue/foo"
["timestamp"]=>
string(13) "1257227037059"
["expires"]=>
string(1) "0"
["priority"]=>
string(1) "0"
}
}