activemq配置idea

### 在 IntelliJ IDEA 中配置 ActiveMQ 环境 要在 IntelliJ IDEA 中配置 ActiveMQ 环境，可以通过以下方式实现完整的集成和运行环境： #### 1. 下载并安装 ActiveMQ 首先需要下载 Apache ActiveMQ 的二进制分发包。访问官方站点获取最新版本的 ActiveMQ 并解压至本地目录。 ```bash wget https://archive.apache.org/dist/activemq/5.18.1/apache-activemq-5.18.1-bin.tar.gz tar -xvzf apache-activemq-5.18.1-bin.tar.gz cd apache-activemq-5.18.1/bin/ ./activemq start ``` 启动命令会初始化 ActiveMQ 服务，默认监听端口 `61616` 和管理控制台端口 `8161`[^4]。 #### 2. 创建 Maven 或 Gradle 工程 在 IntelliJ IDEA 中创建一个新的 Java 项目，并确保其构建工具为 Maven 或 Gradle。添加必要的依赖项来支持 ActiveMQ 客户端库。 对于 Maven，在项目的 `pom.xml` 文件中加入如下依赖： ```xml <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-client</artifactId> <version>5.18.1</version> </dependency> ``` 对于 Gradle，则可以在 `build.gradle` 文件中添加： ```gradle implementation 'org.apache.activemq:activemq-client:5.18.1' ``` #### 3. 编写 ActiveMQ 生产者与消费者代码 编写生产者和消费者的 Java 类用于测试消息传递功能。 ##### (a) 消息生产者类 以下是发送消息到队列的一个简单示例： ```java import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class MessageProducer { public static void main(String[] args) throws JMSException { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); try (Connection connection = connectionFactory.createConnection()) { connection.start(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("TEST_QUEUE"); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("Hello from Producer!"); producer.send(message); System.out.println("Sent message: " + message.getText()); } } } ``` ##### (b) 消息消费者类 接收来自指定队列的消息： ```java import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class MessageConsumer { public static void main(String[] args) throws JMSException { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); try (Connection connection = connectionFactory.createConnection()) { connection.start(); Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); Destination destination = session.createQueue("TEST_QUEUE"); MessageConsumer consumer = session.createConsumer(destination); TextMessage receivedMessage = (TextMessage) consumer.receive(); if (receivedMessage != null) { System.out.println("Received message: " + receivedMessage.getText()); receivedMessage.acknowledge(); // 手动确认消息已收到 } else { System.out.println("No messages available."); } } } } ``` #### 4. 配置 MyBatis 插件（可选） 如果计划结合 MyBatis 使用数据库操作，可以利用插件提升开发效率。推荐使用 **MyBatis Log Plugin** 来增强日志记录能力以及简化 Mapper XML 文件的操作流程[^3]。 --- ### 总结 完成上述步骤后即可成功搭建基于 IntelliJ IDEA 的 ActiveMQ 测试环境。这不仅有助于熟悉消息中间件的工作原理，还可以进一步扩展到实际业务场景的应用当中。