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

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

    博客分类:
  • java
 
阅读更多

发送消息到队列中

ActiveMQ客户端最小依赖JAR包:



 
public static void testSend() throws Exception {

    ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER/*NULL*/,

       ActiveMQConnection.DEFAULT_PASSWORD/*NULL*/"tcp://localhost:61616");

    Connection connection = factory.createConnection();

    connection.start();

 

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

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

    MessageProducer producer = session.createProducer(queue/*也可以为NULL,则在发送时才指定目标队列*/);

    producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

 

    TextMessage message = session.createTextMessage();

    message.setText("你好!!");

    message.setJMSPriority(Message.DEFAULT_PRIORITY);

    producer.send(message);

 

    session.commit();

    session.close();

    connection.close();

}

执行上面代码,然后观察Jconsolewebconsole的变化:



 

 附件:ActiveMQ客户端代码

  • 大小: 10.2 KB
  • 大小: 8.6 KB
  • 大小: 4.8 KB
分享到:
评论

相关推荐

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

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

    消息队列activemq学习笔记

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

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

    它是一种与具体平台无关的、面向消息的中间件的API,用于简化和规范化在两个应用程序之间,或分布式系统中发送消息的程序设计。 - **MOM(Message-Oriented Middleware)**是一种基于消息的中间件,它的核心作用是...

    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)**:与队列不同,主题支持发布/订阅模式,多个订阅者可以同时接收到同一...

    ActiveMQ学习笔记(二) JMS与Spring

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

    active mq 学习笔记

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

    activemq系列笔记

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

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

    **JMS学习笔记(一)——JMS简介与ActiveMQ安装** Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用间异步通信的标准接口。它为应用程序提供了一种标准的方式,用来创建、发送、接收和读取...

    ActiveMQ+In+Action学习笔记.docx

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

    My-Note-Utils-Learn:学习笔记,类库。ActiveMQ消息队列,Layui常用公共类库,设计模式编码,多线程,JVM等

    learn-activemq 消息队列 ActiveMQ的使用,Spring整合ActiveMQ learn-data-tructure 数据结构 learn-design-pattern 设计模式 编码详解 learn-jedis Redis的客户端操作工具包 learn-jvm-juc 并发编程和JVM的测试项目...

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

    消息队列在IT行业中,尤其是Java领域,是一个至关重要的技术组件,它被广泛应用于系统解耦、异步处理、削峰填谷等场景...在准备面试时,可以参考笔记和PPT中的内容,深入学习并加以实践,以便更好地应对各种面试挑战。

    分享一些ActiveMQ的资料

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

    RocketMQ学习笔记 1

    生产者负责将消息发送到Broker,Broker负责存储消息,而消费者则负责从Broker中消费消息。 2. JMS规范 JMS(Java Message Service)是Java平台上的消息服务规范,提供了一种平台无关的消息传递机制。JMS规范定义了...

    JMS学习笔记精心总结

    5. **生产者(Producer)**:生产者负责创建和发送消息到队列或主题。 6. **消费者(Consumer)**:消费者可以从队列中接收消息,或者订阅主题以接收消息。 7. **持久性(Persistence)**:消息提供者可以将消息...

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

    3. **消息生产者和消费者**:生产者创建并发送消息,消费者则从目的地接收并处理消息。 4. **消息队列和主题**:队列提供FIFO(先进先出)的消息传递,而主题允许广播式的消息分发。 5. **持久化和非持久化消息**:...

    ActiveMQ.zip

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

    jms学习笔记jms学习笔记

    1. 消息生产者:生产者是发送消息的组件,它创建消息并将其发送到消息队列或主题。发送消息时,生产者无需等待接收者处理消息,这样实现了异步通信,提高了系统的响应速度和可扩展性。 2. 消息消费者:消费者是接收...

Global site tag (gtag.js) - Google Analytics