日本語
日本語
sudo apt-get install php-stompインストールが完了したら、php.iniファイルのstomp延長を有効にする必要があります。 php.iniファイルを開き、次の行を見つけて、最初のセミコロンを削除します。 ;extension=stompファイルを保存した後、PHPサービスを再起動して変更を有効にします。 <?php
$queueUrl = 'tcp://localhost:61613';
$queueClientId = 'php-stomp-client';
$queueConnectOptions = [];
$stomp = new Stomp($queueUrl, $queueClientId, $queueConnectOptions);
$stomp->connect();
// 接続が成功した後，後続の操作を実行できます
$stomp->disconnect();
?>この例では、StompクラスのConnectメソッドを使用してメッセージキューサーバーに接続し、メッセージキューのURL、クライアントID、および接続オプションを提供します。接続が成功した後、後続の操作を実行できます。 <?php
$queueName = '/queue/test';
$message = 'Hello, World!';
// メッセージを送信します
$stomp->send($queueName, $message);
// メッセージを購読します
$stomp->subscribe($queueName);
// メッセージを受信します
$message = $stomp->read();
if ($message !== false) {
echo $message->body;
$stomp->ack($message);
} else {
echo 'No message received. ';
}
?>この例では、最初に送信メソッドを使用してメッセージを送信し、メッセージキューの名前を指定します。次に、購読メソッドを使用してキューをサブスクライブします。次に、読み取りメソッドを使用してメッセージキュー内のメッセージを読み取り、メッセージがある場合は、ACKメソッドを使用してメッセージを出力して確認します。 <?php
try {
// メッセージキューサーバーに接続します
$stomp->connect();
// 関連する操作を実行します...
} catch (StompException $e) {
echo 'Error: ' . $e->getMessage();
} finally {
// 接続を閉じます
if ($stomp->isConnected()) {
$stomp->disconnect();
}
}
?>この例では、Try-Catchブロックを使用して、Stompexceptionの例外をキャッチして処理します。例外が発生するかどうかに関係なく、最終的なブロックのコードが実行され、接続が安全に閉じられていることを確認します。