(PECL stomp >= 0.1.0)
Stomp::ack -- stomp_ack — 確認已消費訊息
物件導向風格 (方法)
$msg, 陣列 $headers = ?): 布林值程序式風格
$link, 混合型別 $msg, 陣列 $headers = ?): 布林值使用用戶端確認機制，確認已從訂閱中取用訊息。
成功時返回 true，失敗時返回 false。
範例 #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) {
/* 確認已收到框架 */
$stomp->ack($frame);
}
/* 移除訂閱 */
$stomp->unsubscribe($queue);
/* 關閉連線 */
unset($stomp);
?>
範例 #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) {
/* 確認已收到框架 */
stomp_ack($link, $frame['headers']['message-id']);
}
/* 移除訂閱 */
stomp_unsubscribe($link, $queue);
/* 關閉連線 */
stomp_close($link);
?>備註:
可以指定一個事務標頭，表示訊息確認應作為指定事務的一部分。
Stomp 本質上是非同步的。可以透過添加一個 receipt 標頭來實現同步通訊。這將導致方法在伺服器確認收到訊息或讀取逾時之前不會返回任何內容。