지점 간 모델의 특징: 한 명의 소비자만 메시지를 받을 수 있으며 반복적으로 소비할 수 없습니다. 이 기사는 주로 PHP에서 ActiveMQ를 사용하는 방법을 공유합니다. 도움이 되기를 바랍니다.
Producer producer.php 코드:
<? phptry { // 1.建立连接 $stomp = new Stomp('tcp://47.52.119.21:61613'); // 2.实例化类 $obj = new Stdclass(); // 3.获取数据 for($i=0; $i<3; $i++) { $obj->username = 'test'; $obj->password = '123456'; $queneName = "/queue/userReg"; // 4.发送一个注册消息到队列 $stomp->send($queneName, json_encode($obj)); }} catch (StompException $e) { die('Connection failed: ' . $e->getMessage()); }
Consumer1consumer1.php 코드:
<? php$stomp = new Stomp('tcp://localhost:61613'); $stomp->subscribe('/queue/userReg');while (true) { //判断是否有读取的信息 if ($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); var_dump($data); $stomp->ack($frame); }}
Consumer2consumer2.php 코드:
<?php $stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/queue/userReg');while (true) { //判断是否有读取的信息 if ($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); var_dump($data); $stomp->ack($frame); }}
실행 결과는 다음과 같습니다.
Publish/Subscribe(Publish Subscribe) 모델 사용
게시/구독 모델의 특징:
여러 소비자가 메시지를 받을 수 있습니다.
반복적으로 소비될 수 있습니다.
Producer producer.php 코드:
{ // 1.建立连接 $stomp = new Stomp('tcp://47.52.119.21:61613'); // 2.实例化类 $obj = new Stdclass(); // 3.获取数据 for($i = 0; $i < 3; $i++) { $obj->username = 'test'; $obj->password = '123456'; $queneName = "/topic/userReg"; // 4.发送一个注册消息到队列 $stomp->send($queneName, json_encode($obj)); }} catch (StompException $e) { die('Connection failed: ' . $e->getMessage()); }
Consumer1consumer1.php 코드:
<?php$stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/topic/userReg'); while (true) { //判断是否有读取的信息 if ($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); var_dump($data); $stomp->ack($frame); }}
Consumer2consumer2.php 코드 :
<?php$stomp = new Stomp('tcp://localhost:61613');$stomp->subscribe('/topic/userReg'); while (true) { //判断是否有读取的信息 if ($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); var_dump($data); $stomp->ack($frame); }}
실행 결과 사진은 다음과 같습니다.
관련 권장 사항:
위 내용은 PHP와 ActiveMQ 인스턴스 공유를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!