消息队列在你的系统里起什么作用？怎么选型？

消息队列三大作用：异步——非核心链路异步化降低响应时间；解耦——生产方不关心谁消费，新增消费方不用改上游；削峰——突发流量先进队列，消费端按能力平稳处理。选型上 Kafka 吞吐高适合日志流，RocketMQ 功能全适合业务，RabbitMQ 灵活适合中小规模。

我落地过订单事件的通知解耦：订单状态机发布事件，短信、积分、推荐各自订阅。引入后必须处理三件事：不丢——生产端确认加 broker 持久化加消费端手动 ack；不重——消费端幂等；顺序——同一订单路由到同一分区。踩的坑是消费者重启时重复消费，靠业务 ID 幂等表解决。

我会先讲引入成本再讲收益：延迟不可见、一致性从强变最终、链路更长排障更难。所以决策标准是业务能不能接受秒级延迟、消费端是否可幂等。架构上关注：积压治理——扩消费者、批量消费、跳过可重算数据；可靠投递语义的三个层级；以及事务消息和本地消息表在最终一致里的角色。

追问『消息丢了怎么查』：分段确认——生产端确认记录、broker 存量对账、消费端 ack 位点，三段对齐定位丢失环节；『积压百万怎么处理』：先看消费能力，扩并行度，批量写，不可跳过的冷数据转储离线补；『为什么不用 MQ 做强一致』：MQ 是最终一致工具，跨库强一致要别的事务方案。