RabbitMQ 进阶 -- SpringBoot 集成 RabbitMQ实现生产者与消耗者模式

蜂信物联FastBee平台https://gitee.com/beecue/fastbee
阿里资料开源项目https://gitee.com/vip204888
百度低代码前端框架https://gitee.com/baidu/amis
OpenHarmony开源项目https://gitcode.com/openharmony
仓颉编程语言开放项目https://gitcode.com/Cangjie

• 如果保证可靠性，需要自己去写
  
• 如果服务器承载不了，需要自己去写高可用
  

⚡异步消息队列

---

利用MQ异步消息队列的好处

• 完全解耦，用MQ建立桥接
  
• 有独立的线程池和运行模型
  
• 出现了消息丢失，MQ有长期化功能
  
• 如何保证消息的可靠性，死信队列和消息转移的等
  
• 如果服务器承载不了，你需要自己去写高可用，HA镜像模型高可用。
  

按照以上约定，用户的响应时间相称于是订单信息写入数据库的时间，也就是50毫秒。注册邮件，发送短信写入消息队列后，直接返回，因此写入消息队列的速率很快，基本可以忽略，因此用户的响应时间大概是50毫秒。因此架构改变后，体系的吞吐量进步到每秒20 QPS。比串行进步了3倍，比并行进步了两倍
因此MQ消息队列适用于

• 分布式事务的可靠消耗和可靠生产
  
• 索引、缓存、静态化处理的数据同步
  
• 流量监控
  
• 日志监控（ELK）
  
• 下单、订单分发、抢票
  

MQ消息队列可达到 高内聚、低耦合
六、SpringBoot 整合RabbitMQ实现消息的生产与消耗
====================================================================================================
RabbitMQ是Spring家族开辟的产品，Spring 自然支持RabbitMQ，快速方便引入RabbitMQ！
这里我们先容 SpringBoot 整合RabbitMQ 实现消息的生产与消耗（广播模式/发布订阅模式）
✅创建Maven聚合工程

---

File —> New —> Project —> Maven —> 直接Next 进入下一步创建平凡的Maven工程即可

创建一个默认的Maven聚合工程，将src文件夹删除，该工程就是一个Maven聚合工程