Spring Boot 集成 RabbitMQ

要在Spring Boot中集成RabbitMQ，你需要做以下几步：

1. 添加依赖：在pom.xml中添加Spring Boot的RabbitMQ依赖。

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

2. 配置RabbitMQ：在application.properties或application.yml中配置RabbitMQ连接信息。

# application.properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建配置类：配置队列、交换器、路由等。

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

4. 发送和接收消息：使用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接收消息了。