CS-Notes 学习笔记
面试常问Java 后端 · 分布式与消息队列

怎样保证消息按顺序消费?

先自己想一想,再看参考要点

参考要点

  • 消息队列只保证单个队列(Kafka 的分区)内有序
  • 发送端按业务 Key(如订单号)把同一业务的消息发到同一个队列
  • 接收端一个队列只由一个线程顺序消费,Kafka 中一个分区只分给组内一个消费者,RabbitMQ 用单个消费者或单活跃消费者
  • 生产者重试可能让后发的消息先写入,Kafka 默认开启的幂等生产者用序号避免了这种乱序
  • 分区数改变后同一 key 可能落到别的分区,要预先规划分区数
在学习站中自测这道题看这道题所在的一天

学习站:先用面试题自评定级,按水平和面试日期排出每天的计划,自评过的题按间隔复习。免费、无需注册,记录只保存在自己的浏览器中。