Java语言ActiveMQ教程（从零开始掌握Java消息队列与ActiveMQ入门）

准备工作

在开始编码前，请确保你已安装以下工具：

• Java JDK 8 或更高版本
• Maven（用于依赖管理）
• ActiveMQ 服务器（可从 官网 下载）

第一步：启动ActiveMQ服务

1. 下载ActiveMQ压缩包并解压。

2. 进入解压目录，运行以下命令启动服务（Windows使用 bin\activemq start，Linux/macOS使用 bin/activemq start）。

3. 打开浏览器访问 http://localhost:8161/admin，默认账号密码均为 admin。若能成功登录，说明服务已正常运行。

第二步：创建Maven项目并添加依赖

在你的 pom.xml 文件中添加以下依赖：

<dependencies>    <!-- ActiveMQ客户端依赖 -->    <dependency>        <groupId>org.apache.activemq</groupId>        <artifactId>activemq-client</artifactId>        <version>5.17.2</version>    </dependency>        <!-- JMS API -->    <dependency>        <groupId>javax.jms</groupId>        <artifactId>javax.jms-api</artifactId>        <version>2.0.1</version>    </dependency></dependencies>  

第三步：编写Java代码发送消息（生产者）

下面是一个简单的消息生产者示例：

import javax.jms.*;import org.apache.activemq.ActiveMQConnectionFactory;public class Producer {    public static void main(String[] args) throws Exception {        // 1. 创建连接工厂        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");                // 2. 创建连接并启动        Connection connection = factory.createConnection();        connection.start();                // 3. 创建会话（非事务，自动确认）        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);                // 4. 创建目标队列        Destination destination = session.createQueue("MyQueue");                // 5. 创建消息生产者        MessageProducer producer = session.createProducer(destination);                // 6. 创建并发送文本消息        TextMessage message = session.createTextMessage("Hello, ActiveMQ!");        producer.send(message);                System.out.println("消息已发送: " + message.getText());                // 7. 关闭资源        producer.close();        session.close();        connection.close();    }}  

第四步：编写Java代码接收消息（消费者）

消费者代码如下：

import javax.jms.*;import org.apache.activemq.ActiveMQConnectionFactory;public class Consumer {    public static void main(String[] args) throws Exception {        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");        Connection connection = factory.createConnection();        connection.start();                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        Destination destination = session.createQueue("MyQueue");                // 创建消息消费者        MessageConsumer consumer = session.createConsumer(destination);                // 接收消息（阻塞式）        TextMessage message = (TextMessage) consumer.receive();                if (message != null) {            System.out.println("收到消息: " + message.getText());        }                consumer.close();        session.close();        connection.close();    }}  

运行测试

1. 先运行 Consumer 类（它会等待消息）。

2. 再运行 Producer 类发送消息。

你会看到消费者控制台输出：收到消息: Hello, ActiveMQ!

总结

通过本篇Java ActiveMQ示例教程，你已经掌握了如何在Java中使用ActiveMQ实现基本的消息发送与接收。这为你后续学习更高级的消息模式（如主题订阅、持久化、事务等）打下了坚实基础。

记住，Java消息队列是构建高可用、高并发系统的关键技术之一。掌握ActiveMQ不仅能提升你的开发能力，还能让你在面试中脱颖而出！

赶快动手试试吧！如果你觉得这篇ActiveMQ入门教程对你有帮助，欢迎分享给更多朋友～