053-两种消息消费模式

好，下面我们来看消费模式啊。消费模式呢，我们前面其实给大家也简单的说过，那么有两种啊，一个广播模式啊，一个是集群模式。广播模式什么呢？广播模式下啊，广播消费模式下相同的consumer group。当每个consumer实例都啊接收同一个的全量消息。这每条消息都会被发送到o group中，每个O里什么意思，就是它里边，比如说这个队列啊，这个队里边，呃，这个消息。啊12345这五条消息会他会收到这五条，他也会收到五条，他也会收到五条，他也会收到五条。他们各自都会收到这五条消息，都会对这五条消息进行分别的消费。了，你想并不是说啊，我这个消息啊，发给你们EEE给你们啊，就就同时都给你们了，不是这样的啊，因为你要用的是比如说拉取方式。

要是拉取方式的话，那就是谁消费谁的，我消费完了我就从里边读啊，啊，我第一条消费完了，我读第二条。第二条我读第三条，可能我都消费到第三条了，他可能才消费第一条。他可能都已经消费到。第四条。他可能也销完毕了，所以这这是不一样的啊，消费进度是不一样的。然后集群消费是什么呢？就大家一块儿消费。集群模式下相同，呃，Consumer group里边每个consumer实例。平均，你注意平均分摊啊，这句话很重要啊。平均分摊。啊，同一个topic的消息，每条消息。

只会被发送到中的某个，注意啊，这是某个。这是某个。你看他是什么？它是每个。什么意思？这是吧，这是这个这个五条消息是吧，平均分。哎。这条消息一号啊，123455个消息是吧，一号给他。二号消息给他，三号消息给他，四号消息给他，五号消息又给他平均分的。他只会消费了一和五，他只消费了二，他只消费了三，只消费了四。而这个呢？他消费了五条，他有五条，他也五条，他也五条是吧，这个大家就清楚了，这个清楚啊，一个是广播模式，一个是集群模式。

那么这里面就刚才涉及到什么一个消费进度的问题，消费进度啊。我们前面给大家其实也也也说过啊，也说过，那我们看广播模式下啊，社会进度保存在哪，保存在端。就我们刚才说这是吧，他可能现在啊，已经消费完两条了，该消费第三条消息了。他可能第一条还没有签完呢。他可能。第四条已经消费完了，他可能所有的已经消费完毕了，所以每个人的消费进度不一样，那你说这个东西保持在哪。啊，谁消费的进度，谁自己各自保存就行了。按照你们自己保存的进行消费。但是。但是所以讲啊。保存，因为广式每个消费消消费进，所以各自保证各自的消费进度。

那集群模式就不一样，经营模式是大家一块儿来消费的。消费记录是保存在里面的。Consumer，所有的consumer共同消费同一个中的消息。同一条消息只会被消费一次。所以这个消费进度呢，会参与到消费的负载均衡里边。所以消费进度需要是共享的，也就是说这里边儿。哎，我我我这儿消费完一呃一条了啊。然后我该消费第几条呢？我看一下消费到哪了，发现就。已经消费到第四条了，为什么？1234，第四他也读走了，也消耗完了。是吧，退吧，第四条啊，我已经消费到这了，那我在读的时候读谁就读第五了。就把它读走了，因为我每次要读的时候，消费的时候，我要先看看现在消费到哪儿了。这个消费记录放在哪里边？

是吧，哎，这个大家就清楚了啊，就清楚了。好，这是我们说的这个。消费模式两种啊。