Spring Boot集成ActiveMQ消息队列

Spring Boot集成ActiveMQ消息队列是一个常见的任务，可以帮助你在应用程序中实现异步通信和处理。下面是一个详细的步骤指南，帮助你完成这个集成。

1. 添加依赖

首先，在你的pom.xml文件中添加Spring Boot和ActiveMQ的依赖。

<dependencies>
    <!-- Spring Boot Starter Web -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- Spring Boot Starter ActiveMQ -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>

    <!-- ActiveMQ Broker -->
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-broker</artifactId>
    </dependency>

    <!-- ActiveMQ Client -->
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-client</artifactId>
    </dependency>
</dependencies>

2. 配置ActiveMQ

在application.properties或application.yml文件中配置ActiveMQ连接信息。

application.properties

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin
spring.activemq.packages.default=com.example.demo.message

application.yml

spring:
  activemq:
    broker-url: tcp://localhost:61616
    user: admin
    password: admin
    packages:
      default: com.example.demo.message

3. 创建消息生产者

创建一个生产者类，用于发送消息到ActiveMQ。

package com.example.demo.producer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(String message) {
        jmsTemplate.convertAndSend("myQueue", message);
    }
}

4. 创建消息消费者

创建一个消费者类，用于接收和处理来自ActiveMQ的消息。

package com.example.demo.consumer;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

    @JmsListener(destination = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

5. 启动应用程序

在你的主应用程序类上添加@EnableJms注解，以启用JMS支持。

package com.example.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.jms.annotation.EnableJms;

@SpringBootApplication
@EnableJms
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

6. 测试集成

你可以通过以下几种方式测试集成：

1. 手动发送消息：使用ActiveMQ控制台或其他客户端工具发送消息到myQueue。
2. 自动发送消息：在你的应用程序中调用MessageProducer的sendMessage方法发送消息。
3. 监控ActiveMQ：使用ActiveMQ管理控制台查看消息的生产和消费情况。

通过以上步骤，你应该能够成功地在Spring Boot应用程序中集成ActiveMQ消息队列。