25、从集群角度拆解Kafka的架构设计与实现

你好,我是文强。 上节课讲完了RocketMQ,这节课我们再来看一下流消息领域的消息队列Kafka。 因为我们之前在[第16讲]已经详细描述了,基于ZooKeeper和KRaft来构建集群的两种方式,在这里就不再重复。这节课我们会详细分析 Kafka...

深入拆解消息队列47讲

26、从集群角度拆解Pulsar的架构设计与实现

你好,我是文强。 上节课我们讲完了 Kafka ,这节课我们再来看一下消息队列领域最新的成员 Pulsar。在开始学习本节课之前,你可以先复习一下[第13讲],这样的话你对本节内容吸收得会更好。 我们在基础篇讲过,从设计定位上来看,Pulsar 是作...

深入拆解消息队列47讲

27、基础功能:Topic、分区、订阅等基本功能是如何实现的

你好,我是文强。 在基础篇和进阶篇,我们构建了一个分布式的消息队列集群。接下来我们就开始往这个集群里面添加各种功能。我们会用八节课来分析消息队列的基本功能、顺序消息和幂等、延时和定时消息、事务消息、死信队列和优先级队列、消息查询、Schema、Web...

深入拆解消息队列47讲

28、顺序消息和幂等:如何实现顺序消息和数据幂等

你好,我是文强。 这节课我们来讲一下消息队列中的顺序消息和幂等机制实现。 在消息队列中,消息是否能有序是一个常常被问到的问题。因为在我们的业务中,比如在有序事件处理、数据实时增量同步等情况下,就需要消息队列支持顺序消息的机制。接下来我们就来看看消息队...

深入拆解消息队列47讲

29、延时消息:如何实现高性能的定时、延时消息

你好,我是文强。 上节课我们讲完了顺序消息和幂等机制,这节课我们来看看消息队列中的定时和延时消息是如何实现的。在消息队列中,定时和延时消息的底层技术实现是一样的,我们后面统一用延时消息来称呼。下面我们从延时消息的使用场景和定义讲起。 延时消息的场景和...

深入拆解消息队列47讲

30、事务消息:如何实现一个完整的事务消息模块

你好,我是文强。 上节课我们讲完了延时消息,这节课我们来看看消息队列中的事务消息。作为一个研发人员,我们对于事务的概念可以说是如雷贯耳了,最熟悉的应该就是MySQL或Redis的事务。 事务有一个特点,它的概念很明确,也很常见,但是它在不同的存储引擎...

深入拆解消息队列47讲
1345678