当前位置: 首页 > article >正文

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!  

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

注解/配置说明
@RabbitListener监听队列或交换机消息
@RabbitHandler处理消息的方法注解
@Exchange + @Binding声明交换机与队列绑定关系
spring.rabbitmq.listener.simple.retry.enabled=true启用消费失败重试

六、常见问题

  1. 消息未消费

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

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

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

七、其他MQ整合(简要)

MQ类型依赖配置核心注解
Kafkaspring-kafka@KafkaListener
RocketMQrocketmq-spring-boot-starter@RocketMQMessageListener

八、总结

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

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

官方文档:Spring AMQP Reference

原文地址:https://blog.csdn.net/2201_75559074/article/details/146278521
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.kler.cn/a/587495.html

相关文章:

  • 【小沐学Web3D】three.js 加载三维模型(React)
  • 微信小程序wx.request接口报错(errno: 600001, errMsg: “request:fail -2:net::ERR_FAILED“)
  • 有效封装一个 WebSocket 供全局使用
  • Vue 中如何实现自定义指令?
  • 《DeepSeek 开源 DeepGEMM:开启AI计算新时代的密钥》:此文为AI自动生成
  • 变量赋值汇编
  • 【C】嵌入式的中断,理解
  • Modbus TCP到RTU:轻松转换指南!
  • docker mysql 默认配置文件路径
  • 架构思维:软件建模与架构设计的关键要点
  • mac安装navicat及使用
  • 聊聊langchain4j的AiServicesAutoConfig
  • vue里面使用什么组件和后端接口通讯
  • <meta content=“no-siteapp“ data-n-head=“ssr“ http-equiv=“Cache-Control“/>什么作用?
  • WPF CommunityToolkit.MVVM库的简单使用
  • 安全相关Python脚本
  • Qt介绍面试题一
  • Midjourney绘图参数详解:从基础到高级的全面指南
  • Java基礎2小時速成(上篇) - 掌握核心技术「卷」
  • 第十五届蓝桥杯C/C++B组拔河问题详解