springboot 消费rabbitmq

Spring Boot是一个用于创建独立的、基于Spring的应用程序的框架。它简化了Spring应用程序的配置和部署过程，并提供了许多开箱即用的功能和插件，其中包括对消息队列的支持。

RabbitMQ是一个开源的消息队列中间件，它实现了高级消息队列协议（AMQP），提供了可靠的消息传递机制。在Spring Boot中，我们可以使用Spring AMQP来集成RabbitMQ。

要在Spring Boot中消费RabbitMQ，首先需要添加相关的依赖。在pom.xml文件中添加以下依赖：

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

接下来，我们需要配置RabbitMQ连接信息。在application.properties或application.yml文件中添加以下配置：

spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=your-rabbitmq-port
spring.rabbitmq.username=your-username
spring.rabbitmq.password=your-password

然后，我们可以创建一个消息监听器来消费RabbitMQ中的消息。可以使用@RabbitListener注解将方法标记为消息监听器，并指定要监听的队列名称。例如：

@Component
public class RabbitMQConsumer {

    @RabbitListener(queues = "your-queue-name")
    public void handleMessage(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

以上代码创建了一个名为RabbitMQConsumer的消息监听器，它会监听名为"your-queue-name"的队列，并在接收到消息时打印消息内容。

最后，我们需要在Spring Boot应用程序的入口类上添加@EnableRabbit注解，以启用RabbitMQ的支持。例如：

@SpringBootApplication
@EnableRabbit
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

这样，我们就完成了在Spring Boot中消费RabbitMQ的配置和实现。