springboot +activemq实现

Spring Boot与ActiveMQ的集成可以实现消息队列的功能。以下是实现步骤：

1. 配置ActiveMQ依赖：在项目的pom.xml文件中添加ActiveMQ的依赖。

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

2. 配置ActiveMQ连接信息：在项目的application.properties（或application.yml）文件中配置ActiveMQ的连接信息。

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

3. 创建消息发送者：编写一个消息发送者类，使用JmsTemplate发送消息到ActiveMQ队列。

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

@Component
public class MessageSender {

    @Autowired
    private JmsTemplate jmsTemplate;

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

4. 创建消息接收者：编写一个消息接收者类，使用@JmsListener注解监听ActiveMQ队列，并处理接收到的消息。

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class MessageReceiver {

    @JmsListener(destination = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
        // 处理接收到的消息
    }
}

5. 发送和接收消息：在需要发送消息的地方，通过调用消息发送者的sendMessage方法发送消息；在消息接收者类中，使用@JmsListener注解监听到消息后进行处理。

通过以上步骤，你就可以在Spring Boot应用中使用ActiveMQ实现消息队列的功能了。记得在启动应用之前，确保你已经启动了ActiveMQ服务器。