Spring Boot整合RabbitMQ极简教程

一、消息队列能解决什么问题？

• 异步处理：解耦耗时操作（如发短信、日志记录）
• 流量削峰：应对突发请求，避免系统过载
• 应用解耦：服务间通过消息通信，降低依赖

二、快速整合RabbitMQ

1. 环境准备

• 安装RabbitMQ（推荐Docker一键部署）：

  docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:management  
  

• 访问管理界面：http://localhost:15672（账号/密码：guest/guest）

2. Spring Boot项目配置

① 添加依赖

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

② 配置连接信息

# application.yml  
spring:  
  rabbitmq:  
    host: localhost  
    port: 5672  
    username: guest  
    password: guest  
    virtual-host: /  

三、核心代码实现

1. 生产者（发送消息）

@Component  
public class MsgProducer {  

    @Autowired  
    private AmqpTemplate amqpTemplate;  

    // 发送到指定队列  
    public void send(String message) {  
        amqpTemplate.convertAndSend("demo_queue", message);  
        System.out.println("消息已发送: " + message);  
    }  
}  

2. 消费者（接收消息）

@Component  
public class MsgConsumer {  

    // 监听指定队列  
    @RabbitListener(queues = "demo_queue")  
    public void handle(String message) {  
        System.out.println("收到消息: " + message);  
    }  
}  

3. 自动创建队列（可选）

@Configuration  
public class RabbitConfig {  

    // 声明队列（若不存在则自动创建）  
    @Bean  
    public Queue demoQueue() {  
        return new Queue("demo_queue");  
    }  
}  

四、测试消息收发

@SpringBootTest  
class DemoApplicationTests {  

    @Autowired  
    private MsgProducer msgProducer;  

    @Test  
    void testSend() {  
        msgProducer.send("Hello RabbitMQ!");  
    }  
}  

控制台输出：

消息已发送: Hello RabbitMQ!  
收到消息: Hello RabbitMQ!  

五、扩展：常用注解与配置

六、常见问题

1. 消息未消费

   • 检查队列名是否一致
   • 消费者是否添加了@Component注解
   • 确认RabbitMQ服务是否正常运行

2. 连接失败

   • 检查application.yml中的host、port、账号密码
   • 防火墙是否开放5672端口

3. 消息重复消费

   • 启用消费者幂等处理
   • 使用@RabbitListener(id = "唯一ID")

七、其他MQ整合（简要）

八、总结

通过Spring Boot整合RabbitMQ只需三步：

1. 加依赖：spring-boot-starter-amqp
2. 配连接：application.yml中设置RabbitMQ地址
3. 用注解：@RabbitListener实现消息监听

官方文档：Spring AMQP Reference