PHP使用ActiveMQ实例

<"/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页面静态化
            
下一篇：详解PHP中mb_strpos的使用