高并发下 MQ 如何保证顺序消费?

8点一课 | 每天进步一点点
¥1-1= 0
去购买 奖¥1.00

讲师介绍

韦木 前硅谷上市公司技术总监

15 年互联网研发经验,具备从单体架构迁移到微服务架构经验;曾将整体环境搭建时间从 1 个月缩短到 1 分钟;2 次在新公司引入大数据计算框架,实现数据统计结算以及客户个性化服务;多次亿级、十亿级数据量处理经历,将响应时间从缩短到秒级。

课程介绍

一些程序员同学会简单使用MQ,比如写“生产”与“消费”的代码;但一旦进入高并发场景就屡屡出错,尤其面对海量线程消费,又必须顺序消费时,尤为如此。

这一期前硅谷上市公司技术总监韦木,将从代码底层原理的角度,剖析MQ的时序机制;并还原各个MQ业务场景,带你应对常见的3大意外事故。

本课目录(思路导航,学习不迷茫)

时序的业务场景如何保证同一个订单的消息,会按顺序消费?RocketMQ保证顺序消费的机制

PullMessageService

RebalanceService触发doRebalance()

意外事件的处理

消息消费失败了,该队列后面的消息会不会堵塞住?

若订单多了,需增加消费者来确保效率,会碰到什么扩容问题?

生产时怎么保证消息顺序?

本课核心图