消息队列MQ使用场景有哪些？
MQ 在实际项目中的应用场景主要围绕异步处理、系统解耦、流量控制三大核心能力展开，结合具体业务需求可细分为以下场景：
1. 异步处理
- 典型场景：用户注册成功后发送短信/邮件、支付成功后通知物流系统发货、商品上架后同步至搜索引擎。
- 优势：将非核心业务异步化，避免主流程阻塞。例如，注册接口只需完成用户信息存储，短信通知通过 MQ 异步执行，提升接口响应速度。
- 技术实现：生产者将消息发送至 MQ，消费者独立处理耗时操作（如调用第三方 API）。
2. 系统解耦
- 典型场景：微服务架构中服务间通信（如订单服务与库存服务）、多系统数据同步（如 CRM 系统与 ERP 系统）。
- 优势：通过消息协议替代直接 API 调用，降低服务间耦合。例如，订单服务只需将订单状态变更事件投递到 MQ，下游系统（积分、物流等）自行订阅处理。
- 技术实现：使用发布-订阅模式（如 Kafka Topic、RabbitMQ Exchange），支持一对多消息分发。
3. 流量削峰
- 典型场景：秒杀活动、电商大促、突发流量场景（如微博热点事件）。
- 优势：MQ 作为缓冲区，平滑突发流量。例如，秒杀请求先写入 MQ 队列，后端服务按处理能力消费，避免系统过载崩溃。
- 技术实现：结合限流策略（如令牌桶算法）和消费者并发控制，确保系统稳定。
4. 日志收集与分析
- 典型场景：分布式系统日志聚合（如 ELK 架构）、用户行为日志采集。
- 优势：利用 MQ 高吞吐特性（如 Kafka）作为日志传输中间层，解耦日志生产与消费。
- 技术实现：Filebeat 采集日志 → Kafka 缓冲 → Logstash 处理 → Elasticsearch 存储 → Kibana 可视化。
5. 分布式事务
- 典型场景：跨服务事务（如订单创建与库存扣减）、金融交易最终一致性。
- 优势：通过事务消息（如 RocketMQ 半消息）实现最终一致性。例如，订单服务先发送半消息到 MQ，本地事务提交后 MQ 投递消息，若失败则回滚。
- 技术实现：二阶段提交（预提交 + 最终提交）结合消息重试机制。
6. 延迟消息
- 典型场景：订单超时未支付自动关闭、优惠券到期提醒、定时任务触发。
- 优势：替代传统轮询数据库方案，减少资源消耗。例如，订单支付超时消息延迟 30 分钟投递，触发关闭逻辑。
- 技术实现：RabbitMQ 死信队列（DLX）或 RocketMQ/Kafka 定时消息。
7. 数据分发与广播
- 典型场景：配置中心参数更新广播、实时数据同步（如价格变动通知多系统）。
- 优势：一份数据多消费者订阅，扩展性强。例如，商品价格修改后通过 MQ 广播，促销系统和库存系统同步更新。
- 技术实现：Topic 广播模式或 Fanout Exchange（RabbitMQ）。
8. 错误重试与容灾
- 典型场景：第三方接口调用失败重试、服务宕机后消息恢复。
- 优势：通过 MQ 重试队列和死信队列实现容错。例如，短信发送失败时消息进入重试队列，间隔递增重试直至成功或转入死信人工处理。
- 技术实现：ACK 确认机制 + 重试策略（如指数退避）。
技术选型建议
- 高吞吐日志场景：Kafka（支持百万级 TPS）。
- 金融级可靠性：RocketMQ（事务消息、顺序消息）。
- 复杂路由需求：RabbitMQ（灵活 Exchange 绑定规则）。
- 轻量级场景：ActiveMQ（简单易用，适合小规模系统）。
注意事项
- 避免滥用：同步调用更简单的场景（如验证码发送）优先使用多线程异步，而非引入 MQ。
- 消息丢失风险：需结合持久化、生产者确认、消费者手动 ACK 等机制保障可靠性。
- 监控与治理：需配套消息堆积报警、消费延迟监控、死信处理等运维能力。
