springboot 消费Rabbitmq 队列的示例

好的，下面是一个简单的 Spring Boot 消费 RabbitMQ 队列的示例。

首先，需要在 pom.xml 文件中添加 RabbitMQ 的依赖：

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

然后，在 application.properties 文件中设置 RabbitMQ 的连接信息：

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

接着，创建一个 RabbitMQ 的配置类，用于创建队列和交换机：

@Configuration
public class RabbitMQConfig {
    
    @Bean
    public Queue queue() {
        return new Queue("myqueue", true);
    }

    @Bean
    public TopicExchange exchange() {
        return new TopicExchange("myexchange");
    }

    @Bean
    public Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("mykey");
    }
}

上面的代码创建了一个名为 "myqueue" 的队列，一个名为 "myexchange" 的交换机，并使用 "mykey" 绑定它们。

最后，创建一个消费者类，用于监听队列并处理消息：

@Component
public class Consumer {

    @RabbitListener(queues = "myqueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

上面的代码使用 @RabbitListener 注解监听名为 "myqueue" 的队列，并在接收到消息时打印消息内容。

这样，当消息发送到 "myqueue" 队列时，消费者就会自动接收并处理消息了。

希望这个示例能对你有所帮助！