`
sswh
  • 浏览: 163806 次
  • 性别: Icon_minigender_1
社区版块
存档分类
最新评论

ActiveMQ学习笔记之十--从队列中接收消息

    博客分类:
  • java
 
阅读更多

从队列中接收消息

public static void testReceive() throws Exception {

    ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");

    Connection connection = factory.createConnection();

    connection.start();

 

    final Session session = connection.createSession(true/*支持事务*/, Session.AUTO_ACKNOWLEDGE);

    Destination queue = session.createQueue("test_123");

    MessageConsumer consumer = session.createConsumer(queue);

    consumer.setMessageListener(new MessageListener() {

 

       @Override

       public void onMessage(Message message) {

           try {

              if (message instanceof TextMessage) {

                  String text = ((TextMessage) message).getText();

                  session.commit();//如果开启事务,这儿就需要提交,才会消费掉这条消息

                  System.out.println(text);

              }

           }

           catch (Exception e) {

              e.printStackTrace();

           }

       }

    });

}

可以观察到队列的变化:



 

 

  • 大小: 12.8 KB
  • 大小: 16.3 KB
分享到:
评论

相关推荐

    ActiveMQ学习笔记之九--发送消息到队列中

    这篇"ActiveMQ学习笔记之九--发送消息到队列中"主要探讨的是如何通过编程方式向ActiveMQ队列发送消息,这对于理解和应用消息中间件至关重要。 首先,我们要理解ActiveMQ中的队列(Queue)概念。队列是一种先进先出...

    ActiveMQ学习笔记之一--ActiveMQ下载

    **ActiveMQ学习笔记之一——ActiveMQ下载** ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它是基于Java消息服务(JMS)规范的,用于在分布式系统中传递消息。作为一个高性能、可伸缩且可靠的解决方案,...

    消息队列activemq学习笔记

    ### 消息队列Activemq学习笔记 #### MQ入门概述 消息队列(Message Queue,简称MQ)是一种用于在应用程序之间传递数据的机制。它允许应用之间通过发送消息进行通信,而无需直接调用对方。 ##### 前言:MQ=消息...

    ActiveMQ In Action翻译笔记-更新版2011

    作为JMS规范的实现之一,ActiveMQ提供了强大的消息处理能力,适用于大规模分布式系统中的消息传递场景。 #### 二、JMS与MOM **JMS**(Java Message Service)是Sun Microsystems提出的一个Java平台中关于面向消息...

    Apache ActiveMQ学习笔记【原创:mq的方式有两种:点到点和发布/订阅】

    ### Apache ActiveMQ 学习笔记 #### 一、ActiveMQ简介与安装 ##### 1.1 ActiveMQ概述 Apache ActiveMQ 是一个完全支持 JMS 1.1 和 J2EE 1.4 规范的消息服务器。它适用于 Java 消息服务 (JMS),并且是一个开源项目...

    ActiveMQ 教学视频/教程 /附带笔记等资源

    - **消息队列(Message Queue)**:ActiveMQ 中,消息被发送到队列,然后由消费者按需接收,遵循先进先出(FIFO)原则。 - **主题(Topic)**:与队列不同,主题支持发布/订阅模式,多个订阅者可以同时接收到同一...

    active mq 学习笔记

    ### ActiveMQ学习笔记知识点梳理 #### 一、ActiveMQ简介 **定义:** - **ActiveMQ**是由Apache出品的一款功能强大的开源消息中间件。作为消息队列(Message Queue,简称MQ)的一种,它主要用来在分布式系统之间...

    ActiveMQ学习笔记(二) JMS与Spring

    在本篇ActiveMQ学习笔记中,我们将探讨JMS(Java Message Service)与Spring框架的集成。JMS是一种标准API,用于在分布式环境中进行异步消息传递,而Spring框架则为开发人员提供了强大的依赖注入和管理服务的能力。...

    activemq系列笔记

    - **点对点模型**:消息从一个生产者发送到一个队列,然后由一个或多个消费者接收。每个消息仅被一个消费者消费,确保了消息的顺序性和独占性。 - **发布/订阅模型**:消息从生产者发布到一个主题,多个订阅者...

    ActiveMQ+In+Action学习笔记.docx

    点对点(PTP)模型在JMS中表现为队列(Queue),其中每个消息只能被一个消费者接收,确保了一对一的消息传递。而发布/订阅(Pub/Sub)模型则通过主题(Topic)实现,允许一个消息被多个订阅者接收,实现一对多的广播...

    JMS学习笔记(一)——JMS简介安装ActiveMQ

    以上代码展示了如何通过JMS API与ActiveMQ交互,创建一个连接,发送一条消息到名为"MyQueue"的队列,并从该队列接收一条消息。在实际应用中,你可能需要处理异常、使用事务、设置消息属性等更复杂的功能。 总结起来...

    12_总结一下消息队列相关问题的面试技巧.zip

    - 点对点(Point-to-Point)模型:每个消息只有一个消费者,且消费后即从队列中删除,确保消息不会被重复消费。 - 发布/订阅(Publish/Subscribe)模型:多个消费者可以订阅同一主题,发布到主题的消息会被所有...

    分享一些ActiveMQ的资料

    2. **ActiveMQ学习笔记.doc**: 这可能是个人或社区成员编写的笔记,涵盖了ActiveMQ的基本概念、安装步骤、配置和使用技巧。笔记通常更注重实践操作,是初学者快速上手的好资料。 3. **ActiveMQ与Tomcat整合.doc**...

    JMS学习笔记精心总结

    在点对点模型中,消息由一个生产者发送到一个队列,然后由一个或多个消费者从队列中接收。发布/订阅模型中,消息由发布者发送到主题,多个订阅者可以订阅同一个主题并接收到消息。 JMS中主要有两个角色:消息提供者...

    JMS相关,教程,例子,学习笔记

    例如,一个例子可能演示如何通过JMS API创建一个生产者,向队列发送一条消息,然后创建一个消费者来从该队列接收并处理消息。 **基于XML和JMS的异构数据交换集成** 是一种跨系统通信的解决方案。XML作为数据交换的...

    ActiveMQ.zip

    4. **脑图笔记**:`消息中间件之ActiveMQ.mmap` 可能是一个MindMap格式的学习笔记,详细解释了ActiveMQ的关键概念和用法,特别地,笔记中提到已修正了一些错别字,以避免误解。 **四、应用场景** 1. **微服务架构*...

    jms学习笔记jms学习笔记

    消费者可以从消息队列中获取消息,或者订阅主题以接收消息。消息队列保证消息至少被消费一次(至少一次语义),而主题则允许多个订阅者同时接收消息(发布/订阅模式)。 3. 消息队列和主题:消息队列遵循“先进先出...

    RocketMQ学习笔记1

    RocketMQ学习笔记1 RocketMQ是Apache旗下的一个开源的消息队列系统,具有分布式、可靠、可扩展、高性能等特点。下面是对RocketMQ的学习笔记的总结。 分布式架构 RocketMQ原生支持分布式,解决了单点故障问题,...

Global site tag (gtag.js) - Google Analytics