如何集成 Spring Boot 和 ActiveMQ?

2023-12-26 12:29:32

集成 Spring Boot 和 ActiveMQ 可以通过以下步骤完成:

  1. 添加依赖

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

<dependencies>
    <!-- Spring Boot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <!-- ActiveMQ -->
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-spring</artifactId>
        <version>5.16.2</version> <!-- 请根据实际情况选择版本 -->
    </dependency>
</dependencies>
  1. 配置 ActiveMQ

application.propertiesapplication.yml 文件中配置 ActiveMQ 的相关属性,如连接地址、端口、用户名和密码等。

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin
  1. 创建消息生产者

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

@Service
public class MessageProducer {
    @Autowired
    private ActiveMQTemplate<String> activeMQTemplate;
    
    public void sendMessage(String message) {
        activeMQTemplate.send("queueName", message);
    }
}
  1. 创建消息消费者

创建一个消息消费者类,使用 @Autowired 注解注入 DefaultMessageListenerContainer,并实现消息监听器接口。在监听器中处理接收到的消息。

@Component
public class MessageListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        // 处理接收到的消息逻辑
    }
}
  1. 配置监听器容器和队列

application.yml 文件中配置 DefaultMessageListenerContainer 的相关属性,如名称、自动启动、队列名称等。然后使用 @EnableBinding 注解将监听器容器绑定到需要监听的类上。

同时,需要在 Spring Boot 的配置类中配置 ActiveMQ 的连接地址和队列名称。例如:

@Configuration
public class ActiveMQConfig {
    @Bean(name = "queueName") // 队列名称配置,需要根据实际情况修改为实际使用的队列名称
    public Queue queue() {
        return new ActiveMQQueue("queueName"); // 使用 ActiveMQQueue 作为队列类型,确保正确绑定到 ActiveMQ 队列上
    }
}
  1. 启动应用并测试集成效果

启动 Spring Boot 应用,并发送一条消息到指定的队列上。在消息消费者中监听并处理接收到的消息。如果一切正常,应该能够成功地发送和接收消息。

文章来源:https://blog.csdn.net/qq_33240556/article/details/135193141
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。