你好，我是文强。今天我们讲消息队列的客户端。 先问你一个问题：你在使用消息队列的SDK生产消费数据的时候，是否会有疑问，SDK底层是怎么工作的，由哪些功能模块组成呢？接下来我们会用三节课来详细分析一下这个问题。 消息队列的客户端主要包含生产、消费、集...

你好，我是文强。上节课我们讲了生产端，这节课我们来讲讲消费端。 从技术上看，消费端SDK和生产端SDK一样，主要包括客户端基础功能和消费相关功能两部分。客户端基础功能在上一节讲过，我们就不再重复。 从实现来看，消费相关功能包括消费模型、分区消费模式、...

你好，我是文强。 这节课我们继续来讲消费端，上节课我们学习了消费模型的选择和分区消费模式设计，这节课我们将学习剩下的三部分，也就是消费分组（订阅）、消费确认、消费失败处理。 消费分组消费分组是用来组织消费者、分区、消费进度关系的逻辑概念。为什么需要消...

你好，我是文强。 在基础篇开篇的时候，我们说过最基础的消息队列应该具备通信协议、网络模块、存储模块、生产者、消费者五个模块。在之前的课程中，我们详细分析了这五个模块的选型、设计和实现思路，接下来我们从消息和流的角度，用四节课的篇幅分别讲一下消息方向的...

你好，我是文强。 上节课我们分析了RabbitMQ在通信协议、网络模块、存储模块、生产者、消费者这五个模块的设计思路。这节课我们用同一个思路来讲讲 RocketMQ。 有一个蛮有意思的现象，从我们的统计数据来看，RabbitMQ的用户数是最多的。但是...

你好，我是文强。 上节课我们分析了RocketMQ在通信协议、网络模块、存储模块、生产者、消费者这五个模块的设计思路。这节课同样还是分析 Kafka 在这五个模块的设计实现。 在学习的过程中，你会发现Kafka和RocketMQ的架构是非常像的，那为...