Spring Boot整合RabbitMQ通常涉及以下步骤：
- 添加依赖：在
pom.xml中添加Spring Boot和RabbitMQ的依赖。
<dependencies>
<!-- Spring Boot相关依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- RabbitMQ支持 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
</dependencies>
- 配置RabbitMQ：在
application.properties或application.yml中配置RabbitMQ连接信息。
# application.properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
- 创建配置类：配置消息队列、交换器、队列及绑定关系。
@Configuration
public class RabbitMQConfig {
@Bean
Queue queue() {
return new Queue("myQueue", true);
}
@Bean
DirectExchange exchange() {
return new DirectExchange("myExchange");
}
@Bean
Binding binding(Queue queue, DirectExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("myRoutingKey");
}
}
- 发送消息：使用
RabbitTemplate发送消息到RabbitMQ。
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message);
}
- 接收消息：使用
@RabbitListener注解创建监听器来接收消息。
@Component
public class Receiver {
@RabbitListener(queues = "myQueue")
public void receiveMessage(String message) {
System.out.println("Received <" + message + ">");
}
}
以上步骤提供了一个基本的整合示例。在实际应用中，你可能需要根据具体需求进行更复杂的配置，比如消息确认、持久化、高可用性等。