要在Spring Boot中集成RabbitMQ，你需要做以下几步：
- 添加依赖：在
pom.xml中添加Spring Boot的RabbitMQ依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>- 配置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 myQueue() {
return new Queue("myQueue", true);
}
@Bean
DirectExchange myExchange() {
return new DirectExchange("myExchange");
}
@Bean
Binding myBinding() {
return BindingBuilder.bind(myQueue()).to(myExchange()).with("myRoutingKey");
}
}- 发送和接收消息：使用
RabbitTemplate发送消息，使用@RabbitListener注解接收消息。
@Service
public class RabbitMQService {
@Autowired
private RabbitTemplate rabbitTemplate;
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message);
}
}
@Component
public class RabbitMQListener {
@RabbitListener(queues = "myQueue")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}确保你的RabbitMQ服务器正在运行，并且你的Spring Boot应用程序可以成功连接到它。这样你就可以通过RabbitMQService发送消息，并通过RabbitMQListener接收消息了。