发送消息到队列中
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();
}
执行上面代码,然后观察Jconsole和webconsole的变化:
附件:ActiveMQ客户端代码
相关推荐
**ActiveMQ学习笔记之一——ActiveMQ下载** ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它是基于Java消息服务(JMS)规范的,用于在分布式系统中传递消息。作为一个高性能、可伸缩且可靠的解决方案,...
### 消息队列Activemq学习笔记 #### MQ入门概述 消息队列(Message Queue,简称MQ)是一种用于在应用程序之间传递数据的机制。它允许应用之间通过发送消息进行通信,而无需直接调用对方。 ##### 前言:MQ=消息...
它是一种与具体平台无关的、面向消息的中间件的API,用于简化和规范化在两个应用程序之间,或分布式系统中发送消息的程序设计。 - **MOM(Message-Oriented Middleware)**是一种基于消息的中间件,它的核心作用是...
### Apache ActiveMQ 学习笔记 #### 一、ActiveMQ简介与安装 ##### 1.1 ActiveMQ概述 Apache ActiveMQ 是一个完全支持 JMS 1.1 和 J2EE 1.4 规范的消息服务器。它适用于 Java 消息服务 (JMS),并且是一个开源项目...
- **消息队列(Message Queue)**:ActiveMQ 中,消息被发送到队列,然后由消费者按需接收,遵循先进先出(FIFO)原则。 - **主题(Topic)**:与队列不同,主题支持发布/订阅模式,多个订阅者可以同时接收到同一...
在本篇ActiveMQ学习笔记中,我们将探讨JMS(Java Message Service)与Spring框架的集成。JMS是一种标准API,用于在分布式环境中进行异步消息传递,而Spring框架则为开发人员提供了强大的依赖注入和管理服务的能力。...
### ActiveMQ学习笔记知识点梳理 #### 一、ActiveMQ简介 **定义:** - **ActiveMQ**是由Apache出品的一款功能强大的开源消息中间件。作为消息队列(Message Queue,简称MQ)的一种,它主要用来在分布式系统之间...
- **点对点模型**:消息从一个生产者发送到一个队列,然后由一个或多个消费者接收。每个消息仅被一个消费者消费,确保了消息的顺序性和独占性。 - **发布/订阅模型**:消息从生产者发布到一个主题,多个订阅者...
**JMS学习笔记(一)——JMS简介与ActiveMQ安装** Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用间异步通信的标准接口。它为应用程序提供了一种标准的方式,用来创建、发送、接收和读取...
点对点(PTP)模型在JMS中表现为队列(Queue),其中每个消息只能被一个消费者接收,确保了一对一的消息传递。而发布/订阅(Pub/Sub)模型则通过主题(Topic)实现,允许一个消息被多个订阅者接收,实现一对多的广播...
learn-activemq 消息队列 ActiveMQ的使用,Spring整合ActiveMQ learn-data-tructure 数据结构 learn-design-pattern 设计模式 编码详解 learn-jedis Redis的客户端操作工具包 learn-jvm-juc 并发编程和JVM的测试项目...
消息队列在IT行业中,尤其是Java领域,是一个至关重要的技术组件,它被广泛应用于系统解耦、异步处理、削峰填谷等场景...在准备面试时,可以参考笔记和PPT中的内容,深入学习并加以实践,以便更好地应对各种面试挑战。
2. **ActiveMQ学习笔记.doc**: 这可能是个人或社区成员编写的笔记,涵盖了ActiveMQ的基本概念、安装步骤、配置和使用技巧。笔记通常更注重实践操作,是初学者快速上手的好资料。 3. **ActiveMQ与Tomcat整合.doc**...
生产者负责将消息发送到Broker,Broker负责存储消息,而消费者则负责从Broker中消费消息。 2. JMS规范 JMS(Java Message Service)是Java平台上的消息服务规范,提供了一种平台无关的消息传递机制。JMS规范定义了...
5. **生产者(Producer)**:生产者负责创建和发送消息到队列或主题。 6. **消费者(Consumer)**:消费者可以从队列中接收消息,或者订阅主题以接收消息。 7. **持久性(Persistence)**:消息提供者可以将消息...
3. **消息生产者和消费者**:生产者创建并发送消息,消费者则从目的地接收并处理消息。 4. **消息队列和主题**:队列提供FIFO(先进先出)的消息传递,而主题允许广播式的消息分发。 5. **持久化和非持久化消息**:...
4. **脑图笔记**:`消息中间件之ActiveMQ.mmap` 可能是一个MindMap格式的学习笔记,详细解释了ActiveMQ的关键概念和用法,特别地,笔记中提到已修正了一些错别字,以避免误解。 **四、应用场景** 1. **微服务架构*...
1. 消息生产者:生产者是发送消息的组件,它创建消息并将其发送到消息队列或主题。发送消息时,生产者无需等待接收者处理消息,这样实现了异步通信,提高了系统的响应速度和可扩展性。 2. 消息消费者:消费者是接收...