ActiveMQ如何在PHP中使用

　　介绍

这期内容当中小编将会给大家带来有关ActiveMQ如何在PHP中使用,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。

使用点对点(点对点)模型

点对点模型特点:

<李>

只有一个消费者可以接收到消息

<李>

不能重复消费

生产者生产国。php代码:

& lt; php ? 　　try  {//1。才能建立连接 　　时间=美元才能stomp  new 跺脚(& # 39;tcp://47.52.119.21:61613& # 39;);//2。才能实例化类 　　时间=美元才能obj  new  Stdclass ();//3。才能获取数据 　　,,(i=0美元;,i<美元;3;,我+ +美元){ 　　,,,美元obj→username =, & # 39;测试# 39;; 　　,,,美元obj→password =, & # 39; 123456 & # 39;; 　　queneName 美元,,,,,,=,“/队列/userReg"; 　　,,,//4。发送一个注册消息到队列 　　,,,跺脚→美元发送(queneName美元,json_encode (obj美元)); 　　,,} 　　},catch  (StompException  $ e), { 　　死才能(& # 39;Connection 失败:,& # 39;,只$ e→getMessage ()); 　　}

消费者1 consumer1。php代码:

& lt; php ? 　　 　　$ stomp =, new 跺脚(& # 39;tcp://localhost: 61613 & # 39;); 　　stomp→美元订阅(& # 39;/队列/userReg& # 39;); 　　 　　while (真实),{//才能判断是否有读取的信息 　　if 才能;(跺脚→美元hasFrame ()), { 　　,,,frame 美元;=,跺脚→美元readFrame (); 　　,,,data 美元;=,json_decode()美元框架→身体,,真的); 　　,,,var_dump(元数据); 　　,,,跺脚→美元ack(框架); 　　,,} 　　}

消费者2 consumer2。php代码:

& lt; php ? 　　 　　$ stomp =, new 跺脚(& # 39;tcp://localhost: 61613 & # 39;); 　　stomp→美元订阅(& # 39;/队列/userReg& # 39;); 　　 　　while (真实),{//才能判断是否有读取的信息 　　if 才能;(跺脚→美元hasFrame ()), { 　　,,,frame 美元;=,跺脚→美元readFrame (); 　　,,,data 美元;=,json_decode()美元框架→身体,,真的); 　　,,,var_dump(元数据); 　　,,,跺脚→美元ack(框架); 　　,,} 　　}

使用发布/订阅(发布订阅)模型

发布/订阅模型特点:

多个消费者都可以收到消息
能重复消费
生产者生产国。php代码:

& lt; php ? 　　try  {//1。才能建立连接 　　时间=美元才能stomp  new 跺脚(& # 39;tcp://47.52.119.21:61613& # 39;);//2。才能实例化类 　　时间=美元才能obj  new  Stdclass ();//3。才能获取数据 　　,,($小姐:=,0;,美元小姐:& lt;, 3;,我+ +美元){ 　　,,,美元obj→username =, & # 39;测试# 39;; 　　,,,美元obj→password =, & # 39; 123456 & # 39;; 　　queneName 美元,,,,,,=,“/主题/userReg"; 　　,,,//4。发送一个注册消息到队列 　　,,,跺脚→美元发送(queneName美元,json_encode (obj美元)); 　　,,} 　　},catch  (StompException  $ e), { 　　死才能(& # 39;Connection 失败:,& # 39;,只$ e→getMessage ()); 　　}

消费者1 consumer1。php代码:

& lt; php ? 　　 　　$ stomp =, new 跺脚(& # 39;tcp://localhost: 61613 & # 39;); 　　stomp→美元订阅(& # 39;/主题/userReg& # 39;); 　　 　　while (真实),{//才能判断是否有读取的信息 　　if 才能;(跺脚→美元hasFrame ()), { 　　,,,frame 美元;=,跺脚→美元readFrame (); 　　,,,data 美元;=,json_decode()美元框架→身体,,真的); 　　,,,var_dump(元数据); 　　,,,跺脚→美元ack(框架); 　　,,} 　　}

消费者2 consumer2。php代码:

? php 　　 　　$ stomp =, new 跺脚(& # 39;tcp://localhost: 61613 & # 39;); 　　stomp→美元订阅(& # 39;/主题/userReg& # 39;); 　　while (真实),{//才能判断是否有读取的信息 　　if 才能;(跺脚→美元hasFrame ()), { 　　,,,frame 美元;=,跺脚→美元readFrame (); 　　,,,data 美元;=,json_decode()美元框架→身体,,真的); 　　,,,var_dump(元数据); 　　,,,跺脚→美元ack(框架); 　　,,} 　　}

上述就是小编为大家分享的ActiveMQ如何在PHP中使用了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注行业资讯频道。

ActiveMQ如何在PHP中使用