`

深入掌握JMS(二):一个JMS例子

阅读更多

        前一讲简单的介绍了一下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

  • 大小: 20.6 KB
  • 大小: 29.9 KB
  • 大小: 9 KB
  • 大小: 23.7 KB
分享到:
评论

相关推荐

    JBOSS建立JMS应用实例

    JBOSST(Java Business Open Source Solutions)是一个开源的企业级应用服务器,它提供了全面的中间件服务,包括对Java消息服务(JMS)的支持。JMS是一种标准,用于在分布式环境中传递消息,提供了一种可靠且异步的...

    Jms的例子 不错的例子

    通过“jmstest”这个例子,你可以亲自实践,从而深入理解JMS的工作机制,掌握如何在实际项目中应用JMS来实现解耦和异步通信。记住,理论学习固然重要,但动手实践才是提升技能的关键。所以,打开“jmstest”压缩包,...

    JMS完全实例(八个实例)

    通过这八个实例的学习,你将能够全面掌握JMS的核心特性和使用方式,理解其在实际项目中的应用,提升你在企业级应用开发中的消息处理能力。同时,结合Spring框架的使用,能让你更好地在实际工作中利用JMS实现高效、...

    JMS的一个非常好的demo

    **JMS(Java Message Service)** 是一个Java平台上的标准接口,用于在分布式环境中传递消息。它提供了一种可靠的、异步的通信机制,使得不同的应用程序之间可以通过消息进行通信,而无需直接相互依赖。JMS通常用于...

    jms+sping+activeMq的例子serd和recevice

    ActiveMQ是Apache软件基金会的一个开源项目,它是JMS的实现,作为一个消息中间件,它允许应用程序之间通过消息进行通信。ActiveMQ支持多种协议,并且可以在分布式环境中高效地处理大量消息。 **集成Spring与...

    WebLogic下配置的JMS.+例子

    WebLogic Server是由Oracle公司提供的一个企业级Java应用服务器,它支持Java EE标准,包括Java消息服务(JMS:Java Message Service)。JMS是一种为应用程序提供创建、发送、接收和读取消息的标准API。在WebLogic中...

    JMS消息服务AcitveMQ的配置和测试小例子

    总结起来,理解和掌握JMS和ActiveMQ对于构建分布式系统至关重要。它们提供了可靠的、异步的消息传递机制,有助于提升系统的可扩展性和容错性。通过配置和测试,你可以更好地了解这些组件如何协同工作,为你的项目...

    Weblogic提供JMS服务Demo

    这两个例子会覆盖创建、连接、发送和接收消息的关键操作,帮助你理解和掌握Weblogic上的JMS使用。 总的来说,通过这个Demo,开发者可以学习到如何在Weblogic环境中配置和使用JMS服务,这对于构建高可用性和可扩展性...

    jms之activeMQ 队列和广播模式例子(主要给初学者提供入门知识)

    在IT行业中,Java消息服务(Java Message Service,简称...对于开发分布式系统、实现异步处理、提高系统解耦度等场景,掌握JMS和ActiveMQ是非常重要的技能。因此,深入理解和应用这些知识对于提升IT专业技能至关重要。

    activemq-jms-spring:关于ActiveMQ,一个简单的例子

    本篇将深入探讨如何在Spring框架中集成和使用ActiveMQ,通过一个简单的实例来阐述其基本用法。 首先,我们需要理解JMS的基本概念。JMS 是Java平台上的标准接口,允许应用程序创建、发送、接收和读取消息。消息可以...

    ActiveMQ入门及深入使用的例子

    总之,ActiveMQ是一个强大且灵活的消息中间件,学习和掌握它的使用,将有助于你构建更加稳定、可扩展的分布式系统。通过实际操作和不断实践,你可以更好地理解和利用ActiveMQ的特性,解决复杂系统中的通信问题。

    JMS入门

    这两种模式提供了不同类型的通信方式,队列模式确保每个消息仅被一个消费者接收,而发布/订阅模式则允许多个消费者接收同一消息。 JMS定义了五种消息类型,包括两种非结构化消息(TextMessage和BytesMessage)和三...

    hormq学习资料 java例子

    在这个“hormq学习资料 java例子”压缩包中,我们可以看到一个名为“HornetQMavenExample”的项目,这很可能是用于演示如何在Java环境中集成和使用HornetQ的实例。 1. **HornetQ介绍**: HornetQ是一个高性能、全...

    java 消息服务(第二版)源码

    《Java消息服务(第二版)》这本书深入探讨了JMS的使用,提供了丰富的示例代码。 JMS的核心概念包括: 1. **消息**:是数据的载体,包含了要传递的信息。 2. **消息生产者(Message Producer)**:创建并发送消息到...

    J2EE几个经典例子

    一个典型的Servlet例子可能包括`doGet`和`doPost`方法,用于处理GET和POST请求。 接着是JSP(JavaServer Pages)。JSP是HTML与Java代码的混合,用于创建动态网页。开发者可以在JSP页面中直接写入HTML,同时插入Java...

    ActiveMQ学习 完整例子

    下面将详细介绍ActiveMQ的学习内容,以及如何通过实际例子来理解和掌握它。 1. **ActiveMQ基本概念** - **消息中间件**:ActiveMQ作为一个消息中间件,负责在分布式系统中传递消息,解耦生产者和消费者。 - **JMS...

    第一个EJB简单例子

    在这个“第一个EJB简单例子”中,我们将深入探讨如何创建和理解基本的EJB组件。 1. **EJB组件类型**: - **会话Bean(Session Beans)**:代表客户端的一次交互或会话。它们可以是状态ful(维护会话状态)或状态...

    activemq的小例子

    总之,这个“ActiveMQ的小例子”旨在引导初学者进入消息中间件的世界,提供一个简单的起点来探索和实践ActiveMQ的使用,从而提升他们对分布式系统中消息传递的理解和应用能力。通过博客链接和提供的源码,你可以深入...

    java消息服务(第二版).pdf+源码

    总的来说,掌握JMS对于从事Java企业级应用开发的程序员来说至关重要,它能够帮助构建健壮、可扩展的应用系统,促进不同系统之间的高效通信。通过阅读本书和研究源码,开发者可以进一步提升自己的技能,为未来的项目...

Global site tag (gtag.js) - Google Analytics