Java SpringBoot如何整合ActiveMQ

整合ActiveMQ是Java SpringBoot项目中常见的需求之一，通过ActiveMQ我们可以实现消息的异步发送和接收，提高系统的解耦性和响应性。下面将介绍如何在SpringBoot中整合ActiveMQ。

第一步：引入ActiveMQ依赖
首先，在pom.xml文件中添加以下依赖来引入ActiveMQ：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

第二步：配置ActiveMQ连接信息
在application.properties（或application.yml）文件中添加ActiveMQ的连接信息，包括服务器地址、端口号、用户名和密码：

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

第三步：编写消息生产者
1. 创建一个消息生产者类，用于发送消息到ActiveMQ队列中：

@Component
public class MessageProducer {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(String message) {
        jmsTemplate.convertAndSend("myQueue", message);
        System.out.println("Message sent: " + message);
    }
}

2. 在SpringBoot启动类中添加注解@EnableJms来启用JMS功能：

@SpringBootApplication
@EnableJms
public class Application {

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

第四步：编写消息消费者
1. 创建一个消息消费者类，用于接收ActiveMQ队列中的消息：

@Component
public class MessageConsumer {

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

2. 在消息消费者类上添加@Component注解，使其成为Spring容器的Bean。

第五步：测试消息发送与接收
1. 在Controller中调用消息生产者的sendMessage方法发送消息：

@RestController
public class MessageController {

    @Autowired
    private MessageProducer messageProducer;

    @GetMapping("/sendMessage")
    public String sendMessage() {
        messageProducer.sendMessage("Hello ActiveMQ!");
        return "Message sent";
    }
}

2. 启动SpringBoot应用，访问"/sendMessage"接口发送消息到ActiveMQ队列。
3. 查看控制台，可以看到消息生产者和消息消费者打印出的日志，确认消息发送和接收成功。

至此，我们已经完成了Java SpringBoot与ActiveMQ的整合。通过以上配置和代码，我们可以方便地在SpringBoot项目中使用ActiveMQ来实现消息的异步发送和接收。当然，我们也可以使用更高级的特性，如消息订阅和消息持久化等。