《Spring中使用JMS》.pdfVIP

JMS JMS 的概念 JMS(JavaMessage Service)，即Java消息服务，是一组Java 应用程序接口，用以提供创 建、发接、接收、读取消息的服务。SUN 只提供接口，由不同的厂商根据该接口提供自己 的实现。 JMS 的中间件 � IBM MQ 系列产品提供的服务使得应用程序可以使用消息队列进行交流，通过一系列 基于Java 的API 提供了MQseries 在Java 中应用开发的方法。它支持点到点和发布/订 阅两种消息模式。 � WebLogic是BEA公司实现的基于工业标准的J2EE应用服务器，支持大多数企业级Java API，它完全兼容JMS 规范，支持点到点和发布/订阅消息模式，它支持消息的多点广 播、持久消息存储的文件和数据库、XML 消息，以及动态创建持久队列和主题。 � JBoss是JBoss 公司开发的一个免费开源的应用服务器，它提供了EJB 运行的环境，并 能够结合EJB 进行JMS 消息的收取，支持点到点模型和发布/订阅模型。 � ActiveMQ是一个基于Apache2.0Licenced发布的开放源代码的JMS 产品，它能够提供 点到点消息模式和发布/订阅消息模式，支持JBoss、Geronimo 等开源应用服务器，支 持Spring框架的消息驱动，新增了一个P2P 传输层，可以用于创建可靠的P2PJMS 网 络连接，拥有消息持久化、事务、集群支持等JMS 基础设施服务。 � OpenJMS 是一个开源的JMS 规范的实现，它支持点对点模型和发布/订阅模型，支持同 步与异步消息发送、可视化管理界面，支持Applet，能够与JakartaTomcat这样的Servlet 容器结合，支持RMI、TCP、HTTP与SSL 协议。 在这里我们使用ActiveMQ中间件来做演示 .ActiveMQ .ActiveMQ 一..AAccttiivveeMMQQ演示 首先创建一个消息提供者JmsProducerDemo packagecom.sszd.jms; importjavax.jms.Connection; importjavax.jms.ConnectionFactory; importjavax.jms.Destination; importjavax.jms.JMSException; importjavax.jms.MessageProducer; importjavax.jms.Session; importjavax.jms.TextMessage; importorg.apache.activemq.ActiveMQConnectionFactory; mand.ActiveMQQueue; /** *Title: *Description: 消息产生类 *Copyright: Copyright(c)2010 *Company:YeePay *@authorqi.zhang * */ publicclass JmsProducerDemo{ publicstatic voidmain(String[]args) { // 产生连接工厂 ConnectionFactorycf=newActiveMQConnectionFactory(tcp://localhost:61616); Connectionconn=null; Sessionsession= null; try { // 产生连接 conn= cf.createConnection(); Session=conn.createSession(false,Session.AUTO_ACKNOWLEDGE); // 设置消息目的地类型（ActiveMQTopic为订阅目的地） Destinationdestination=newActiveMQQueue(myQueue); MessageProducerproducer= session.createProducer(destination); Text