Spring boot RabbitMQ 消费者怎么写

在Spring Boot中编写RabbitMQ消费者很简单，你可以按照以下步骤进行操作：

1. 首先，确保你的Spring Boot项目已经添加了RabbitMQ的依赖。你可以在pom.xml文件中添加以下依赖：

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

2. 创建一个消息处理类，用于处理接收到的消息。这个类需要实现`org.springframework.amqp.rabbit.annotation.RabbitListener`注解，该注解用于指定消费者监听的队列名称。示例如下：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

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

在上面的示例中，我们创建了一个名为`MessageConsumer`的类，并使用`@RabbitListener`注解指定了消费者监听的队列名称为`your_queue_name`。`receiveMessage`方法用于处理接收到的消息，在这里你可以自定义你的业务逻辑。

3. 在应用程序启动类上添加`@EnableRabbit`注解，开启RabbitMQ的支持。例如：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.amqp.rabbit.annotation.EnableRabbit;

@SpringBootApplication
@EnableRabbit
public class YourApplication {

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

通过添加`@EnableRabbit`注解，Spring Boot会自动扫描并创建RabbitMQ的相关实例。

现在，你已经完成了RabbitMQ消费者的编写。当消息被发送到指定的队列时，消费者将会自动接收并处理这些消息。