springboot使用activemq

在Spring Boot中使用ActiveMQ，你需要添加ActiveMQ的依赖项并配置相关的参数。下面是使用ActiveMQ的步骤：

1. 首先，在`pom.xml`文件中添加ActiveMQ的依赖项：

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

2. 在`application.properties`（或`application.yml`）文件中配置ActiveMQ的连接信息，例如：

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

根据你的实际情况修改上述参数。

3. 创建一个消息生产者，发送消息到ActiveMQ队列或主题。示例代码如下：

import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;
import javax.jms.Queue;

@Component
public class MessageProducer {
    private final JmsTemplate jmsTemplate;
    private final Queue queue;

    public MessageProducer(JmsTemplate jmsTemplate, Queue queue) {
        this.jmsTemplate = jmsTemplate;
        this.queue = queue;
    }

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

你可以使用`JmsTemplate`来发送消息到队列。

4. 创建一个消息消费者，从ActiveMQ队列或主题接收消息。示例代码如下：

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);
    }
}

使用`@JmsListener`注解来监听指定的队列，并在接收到消息时执行对应的方法。