自已建网站微信登录,网站建设课程设计实训报告,文创产品设计作品案例欣赏,如何创建网站小程序1. MQ简介#xff1a; 消息队列#xff08;Message Queue#xff0c;简称MQ#xff09;,是应用程序与应用程序之间的一种通信方法。应用程序通过发送和检索出入列队的针对应用程序的数据 - 消息来通信#xff0c;而无需专用连接来链接它们。程序之间通过在消息中发送数据进… 1. MQ简介 消息队列Message Queue简称MQ,是应用程序与应用程序之间的一种通信方法。应用程序通过发送和检索出入列队的针对应用程序的数据 - 消息来通信而无需专用连接来链接它们。程序之间通过在消息中发送数据进行通信而不是通过直接调用彼此来通信直接调用通常是用于诸如RPC远程过程调用的技术。队列的使用消除了接收和发送应用程序需同时执行的要求。 2. JMS基本概念 JMS(Java Message Service) 即Java消息服务是由Sun开发的。它提供标准的产生、发送、接收消息的接口简化企业应用的开发。 JMS是一系列的接口及相关语义的集合通过这些接口和和其中的方法JMS客户端如何去访问消息系统完成创建、发送、接收和读取企业消息系统中消息。 它支持两种消息通信模型点对点模型point-to-point、P2P和发布者/订阅者模型Pub/Sub。P2P模型规定了一个消息只能有一个接收者;Pub/Sub 模型允许一个消息可以有多个接收者。 2.1 P2P模型 - 打电话模型 对于P2P模型消息生产者产生一个消息后把这个消息发送到一个Queue队列中然后消息接收者再从这个Queue中读取一旦这个消息被一个接收者读取之后它就在这个Queue中消失了所以一个消息只能被一个接收者消费。 2.2 Pub/Sub模型 - 订报纸模型 与P2P模型不同Pub/Sub模型中消息生产者产生一个消息后把这个消息发送到一个Topic中这个Topic可以同时有多个接收者在监听当一个消息到达这个Topic之后所有消息接收者都会收到这个消息。 3. 支持JMS的开源MQ - ActiveMQ ActiveMQ 是Apache出品最流行的能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。 主要特点 多种语言和协议编写客户端。语言: Java、 C、 C、 C#、 Ruby、 Perl、 Python、 PHP。应用协议: OpenWire、Stomp、Rest、WSNotification、XMPP、AMQP完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)支持多种传送协议:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA支持高速的消息持久化从设计上保证了高性能的集群,客户端-服务器,点对点支持Ajax注 在查询资料的过程中发现PHP与ActiveMQ整合的方式可以直接使用Rest接口调用但更高效的方式应该是安装Stomp协议的PHP扩展。 Stomp 提供了客户端和代理之间进行广泛消息传输的框架。Stomp 是一个非常简单而且易用的通讯协议实现尽管代理端的编写可能非常复杂但是编写一个 Stomp 客户端却是很简单的事情另外你可以使用 Telnet 来与你的 Stomp 代理进行交互。 PHP可以通过PECL编译安装Stomp扩展。 stomp_common.php //connection ActiveMQ
function openMQ($queueFALSE) {$amq array(url tcp://127.0.0.1:61613,id xxx,pswd xxx,queue /queue/mytest,enable TRUE);$link stomp_connect($amq[url], $amq[id], $amq[pswd]);if (!$link) {die(Cant connect MQ !!);} else {return $link;}
}//send a message to the queue
function sendMQ($data) {$link openMQ();foreach ($data as $pitem) {//使用 persistent message$result stomp_send($link, $amq[queue], $pitem, array(persistent true));if (FALSE $result) {//do something}}
}//receive message
function receiveMQ() {$link openMQ($queue);//stomp_subscribe($link, $queue);stomp_subscribe($link, $queue, array(activemq.prefetchSize 1000));while (1) {if (TRUE stomp_has_frame($link)) {$frame stomp_read_frame($link);if (FALSE ! $frame) {stomp_ack($link, $frame[headers][message-id]); } else {//do somethingbreak; } } else { break; } } stomp_unsubscribe($link, $queue); stomp_close($link);
} stomp_sender.php // 消息发送服务 stomp_consumer.php // 消息消费服务
