한국어
한국어
sudo apt-get install php-stomp 설치가 완료되면 php.ini 파일에서 스톰프 확장을 활성화해야합니다. 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 Class의 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 예외를 잡고 처리합니다. 예외가 발생하는지 여부에 관계없이 최종 블록의 코드가 실행되어 연결이 안전하게 닫히도록합니다.