前一讲简单的介绍了一下JMS的基本概念, 这一讲结合一个例子让大家深入理解前一讲的基本概念。
首先需要做的是选择一个JMS提供者, 如果在JavaEE环境中可以不用考虑这些。我们选择ActiveMQ,官方地址:http://activemq.apache.org/,网上有很多介绍ActiveMQ的文档, 所以在这里就不介绍了。
按照上一讲的这个简图:
ConnectionFactory---->Connection--->Session--->Message Destination + Session------------------------------------>Producer Destination + Session------------------------------------>MessageConsumer
首先需要得到ConnectionFactoy和Destination,这里创建一个一对一的Queue作为Destination。
ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost"); Queue queue = new ActiveMQQueue("testQueue");
然后又ConnectionFactory创建一个Connection,再启动这个Connection:
Connection connection = factory.createConnection(); connection.start();
接下来需要由Connection创建一个Session:
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
现在暂且不用管参数的含义,以后会详细讲到。
下面就可以创建Message了,这里创建一个TextMessage。
Message message = session.createTextMessage("Hello JMS!");
要想把刚才创建的消息发送出去,需要由Session和Destination创建一个消息生产者:
MessageProducer producer = session.createProducer(queue);
下面就可以发送刚才创建的消息了:
producer.send(message);
消息发送完成之后,我们需要创建一个消息消费者来接收这个消息:
MessageConsumer comsumer = session.createConsumer(queue); Message recvMessage = comsumer.receive();
消息消费者接收到这个消息之后,就可以得到它的内容:
System.out.println(((TextMessage)recvMessage).getText());
至此,一个简单的JMS例子就完成了。下面是全部源码 :
package com.bijian.study; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.command.ActiveMQQueue; public class MessageSendAndReceive { public static void main(String[] args) throws Exception { ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = factory.createConnection(); connection.start(); Queue queue = new ActiveMQQueue("testQueue"); final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Message message = session.createTextMessage("Hello JMS!"); MessageProducer producer = session.createProducer(queue); producer.send(message); System.out.println("Send Message Completed!"); MessageConsumer comsumer = session.createConsumer(queue); Message recvMessage = comsumer.receive(); System.out.println(((TextMessage) recvMessage).getText()); } }
运行结果:
Send Message Completed! Hello JMS!
调试代码至发送完消息,但还未从队列中取消息时,打开ActiveMQ管理台,将可以看到消息的详细内容,如下所示:
点击testQueue。
再点击Message ID,将会看到消息的详细内容。
文章来源:http://www.cnblogs.com/guthing/archive/2010/06/12/1757140.html
相关推荐
JBOSST(Java Business Open Source Solutions)是一个开源的企业级应用服务器,它提供了全面的中间件服务,包括对Java消息服务(JMS)的支持。JMS是一种标准,用于在分布式环境中传递消息,提供了一种可靠且异步的...
通过“jmstest”这个例子,你可以亲自实践,从而深入理解JMS的工作机制,掌握如何在实际项目中应用JMS来实现解耦和异步通信。记住,理论学习固然重要,但动手实践才是提升技能的关键。所以,打开“jmstest”压缩包,...
通过这八个实例的学习,你将能够全面掌握JMS的核心特性和使用方式,理解其在实际项目中的应用,提升你在企业级应用开发中的消息处理能力。同时,结合Spring框架的使用,能让你更好地在实际工作中利用JMS实现高效、...
**JMS(Java Message Service)** 是一个Java平台上的标准接口,用于在分布式环境中传递消息。它提供了一种可靠的、异步的通信机制,使得不同的应用程序之间可以通过消息进行通信,而无需直接相互依赖。JMS通常用于...
ActiveMQ是Apache软件基金会的一个开源项目,它是JMS的实现,作为一个消息中间件,它允许应用程序之间通过消息进行通信。ActiveMQ支持多种协议,并且可以在分布式环境中高效地处理大量消息。 **集成Spring与...
WebLogic Server是由Oracle公司提供的一个企业级Java应用服务器,它支持Java EE标准,包括Java消息服务(JMS:Java Message Service)。JMS是一种为应用程序提供创建、发送、接收和读取消息的标准API。在WebLogic中...
总结起来,理解和掌握JMS和ActiveMQ对于构建分布式系统至关重要。它们提供了可靠的、异步的消息传递机制,有助于提升系统的可扩展性和容错性。通过配置和测试,你可以更好地了解这些组件如何协同工作,为你的项目...
这两个例子会覆盖创建、连接、发送和接收消息的关键操作,帮助你理解和掌握Weblogic上的JMS使用。 总的来说,通过这个Demo,开发者可以学习到如何在Weblogic环境中配置和使用JMS服务,这对于构建高可用性和可扩展性...
在IT行业中,Java消息服务(Java Message Service,简称...对于开发分布式系统、实现异步处理、提高系统解耦度等场景,掌握JMS和ActiveMQ是非常重要的技能。因此,深入理解和应用这些知识对于提升IT专业技能至关重要。
本篇将深入探讨如何在Spring框架中集成和使用ActiveMQ,通过一个简单的实例来阐述其基本用法。 首先,我们需要理解JMS的基本概念。JMS 是Java平台上的标准接口,允许应用程序创建、发送、接收和读取消息。消息可以...
总之,ActiveMQ是一个强大且灵活的消息中间件,学习和掌握它的使用,将有助于你构建更加稳定、可扩展的分布式系统。通过实际操作和不断实践,你可以更好地理解和利用ActiveMQ的特性,解决复杂系统中的通信问题。
这两种模式提供了不同类型的通信方式,队列模式确保每个消息仅被一个消费者接收,而发布/订阅模式则允许多个消费者接收同一消息。 JMS定义了五种消息类型,包括两种非结构化消息(TextMessage和BytesMessage)和三...
在这个“hormq学习资料 java例子”压缩包中,我们可以看到一个名为“HornetQMavenExample”的项目,这很可能是用于演示如何在Java环境中集成和使用HornetQ的实例。 1. **HornetQ介绍**: HornetQ是一个高性能、全...
《Java消息服务(第二版)》这本书深入探讨了JMS的使用,提供了丰富的示例代码。 JMS的核心概念包括: 1. **消息**:是数据的载体,包含了要传递的信息。 2. **消息生产者(Message Producer)**:创建并发送消息到...
一个典型的Servlet例子可能包括`doGet`和`doPost`方法,用于处理GET和POST请求。 接着是JSP(JavaServer Pages)。JSP是HTML与Java代码的混合,用于创建动态网页。开发者可以在JSP页面中直接写入HTML,同时插入Java...
下面将详细介绍ActiveMQ的学习内容,以及如何通过实际例子来理解和掌握它。 1. **ActiveMQ基本概念** - **消息中间件**:ActiveMQ作为一个消息中间件,负责在分布式系统中传递消息,解耦生产者和消费者。 - **JMS...
在这个“第一个EJB简单例子”中,我们将深入探讨如何创建和理解基本的EJB组件。 1. **EJB组件类型**: - **会话Bean(Session Beans)**:代表客户端的一次交互或会话。它们可以是状态ful(维护会话状态)或状态...
总之,这个“ActiveMQ的小例子”旨在引导初学者进入消息中间件的世界,提供一个简单的起点来探索和实践ActiveMQ的使用,从而提升他们对分布式系统中消息传递的理解和应用能力。通过博客链接和提供的源码,你可以深入...
总的来说,掌握JMS对于从事Java企业级应用开发的程序员来说至关重要,它能够帮助构建健壮、可扩展的应用系统,促进不同系统之间的高效通信。通过阅读本书和研究源码,开发者可以进一步提升自己的技能,为未来的项目...