MQ 生产-解决方案
如何保证消息不丢失?
三段式保障
生产者:重试 + 确认机制 + 本地消息表
服务端:持久化 + 多副本集群
消费者:手动ACK,业务成功再提交
如何保证消息幂等不重复?
全局唯一 MsgID 去重
业务单号幂等判断
Redis 防重锁
数据库唯一索引
消息积压如何处理?
紧急扩容消费者节点
优化消费逻辑、异步化非核心逻辑
异常消息隔离死信队列
分区扩容、队列拆分
如何保证消息顺序性?
有序消息绑定相同路由key,进入同一分区/队列
单消费者串行消费
RocketMQ 全局顺序消息
