<"/queue/userReg";
    // 4.发送一个注册消息到队列
    $stomp->send($queneName, json_encode($obj));
  }
} catch (StompException $e) {
  die('Connection failed: ' . $e->getMessage());
}

<"htmlcode">

<"//img.jbzj.com/file_images/article/201802/201802051422001.jpg" alt="" />

使用发布/订阅(Publish Subscribe)模型
发布/订阅模型特点：
多个消费者都可以收到消息

能重复消费

生产者producer.php代码：


<"/topic/userReg";
    // 4.发送一个注册消息到队列
    $stomp->send($queneName, json_encode($obj));
  }
} catch (StompException $e) {
  die('Connection failed: ' . $e->getMessage());
}


消费者1consumer1.php代码：


<"htmlcode">

"//img.jbzj.com/file_images/article/201802/201802051422002.jpg" alt="" />


                                
                                

                                    PHP,ActiveMQ 
                                

                                    标签：
                                        
PHP,ActiveMQ
                                     

                                
明霞山资源网 Design By www.htccd.com