springboot 如何消费rabbitmq

Spring Boot 可以通过使用 RabbitTemplate 或 @RabbitListener 注解来消费 RabbitMQ 消息。下面是一个简单的消费者示例：

1. 首先，在 pom.xml 文件中添加以下依赖：

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

2. 在 application.properties 文件中添加 RabbitMQ 连接配置：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建一个消息处理类：

@Component
public class MessageHandler {
    @RabbitListener(queues = "rabbitmq-queue")
    public void handleMessage(String message) {
        // 处理消息
    }
}

4. 在你的代码中使用 RabbitTemplate 向队列发送消息：

@Autowired
private RabbitTemplate rabbitTemplate;

public void sendMessage(String message) {
    rabbitTemplate.convertAndSend("rabbitmq-queue", message);
}

以上就是消费 RabbitMQ 消息的 Spring Boot 示例，如需了解更多细节，可以参考官方文档：https://docs.spring.io/spring-boot/docs/current/reference/html/spring-boot-features.html#boot-features-amqp