SpringBoot

简述SpringBoot 和 ActiveMQ的集成方式？

参考答案：

SpringBoot和ActiveMQ的集成方式可以通过以下步骤完成：

添加依赖：在项目的pom.xml文件中添加Spring Boot和ActiveMQ的依赖。

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

配置ActiveMQ：在application.properties或application.yml文件中配置ActiveMQ的相关参数，如broker-url、用户名和密码等。例如：

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

创建消息生产者：创建一个消息生产者类，使用@Autowired注解注入ActiveMQTemplate，并使用其发送消息。例如：

@Service
public class MessageProducer {

    @Autowired
    private ActiveMQTemplate activeMQTemplate;

    public void sendMessage(String queueName, String message) {
        activeMQTemplate.convertAndSend(queueName, message);
    }
}

创建消息消费者：创建一个消息消费者类，使用@JmsListener注解监听指定的队列，并在方法中处理接收到的消息。例如：

@Service
public class MessageConsumer {

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

以上步骤完成后，SpringBoot和ActiveMQ就成功集成了。你可以通过调用MessageProducer的sendMessage方法发送消息，然后在MessageConsumer的receiveMessage方法中处理接收到的消息。

需要注意的是，以上示例代码仅供参考，具体实现可能因项目需求而有所不同。在实际开发中，你可能还需要考虑其他因素，如异常处理、事务管理等。