069-消费并发度的深入分析

好，下面我们来看这个消费并发度啊。嗯，这个其实相对简单一些啊，一般情况下啊，消费者端它的消费并发度啊，由。单线程。你注意啊，单节点线实数和这个节点。数量啊，共同决定，由这俩共同决定。啊，其值为单线程啊，这个单节点线程数乘以。单节点数。它的值啊，这它俩由他决定是怎么去乘出来的啊。你说太简单，其实这个是比前面那个还要复杂。要想说清楚这个东西啊，还是。有点不可能啊。

那是单节点线程数乘以节点。数量，那这里边啊，什么是单节点线程数。呃，就是我们。每个consumer啊，我们因为我们现在说这个我们每个啊，它所包含的现成的数量。那什么是节点数量？就我们group里边包含的数量。嗯，给大家写一下啊。就是呃，这个。三。啊，单节点。线程数。啊，就是。三个。Consumer。呃，所包含的。呃，线程数量是吧，然后就是节点数量。

Consumer。所包含的。那个。Consumer。数量啊，这这啊啊嗯。呃，然后不过啊呃，需通常需要优先调节单线单节点的线程数，我先调节它。把它调成最大。是吧，呃，如果单机硬件资源达到了上限。我调成最大了，也也也也已经到了上限了啊，则需要通过横向扩展，横向扩展就是我们增加我们的节点数量，就增加我们customer的数量。来提高消费变化度。对吧，来提高这个消费。嗯。这里边啊，我给大家这样这样说，这儿啊有个一般情况下。

有这么个东西啊，这。他不是所有情况。那这里边儿呢。需要注意这么一点啊。啊，这个我们后面要讲，现在还没有涉及到啊，对于什么普通消息。我们需要分类啊，在哪儿讲呢。在这。普通消息顺消息，延迟消息，消息看到了吧，啊，我们说对普通消息啊，延迟延迟消息。呃，这个以及事物消息。啊，并发。呃，计算啊。都是。都是都他。都是他。是吧？但是你注意。但对于。顺序消息。

对于顺序消息不是。嗯，但是。不同的。不同的顺序消息的消费并发。是吧，呃，等于。实际上。就就是由谁决定是吧，等于。Topic。Q区。是等于。Topic的Q的分区数量。对吧。但是这这个啊，呃，这这些其实就上面我们说这个好理解是吧，我be个consumer包含的现成数量，然后我这里边有多少，呃，有多少consumer这一乘是吧，就是干活的现成的数量就有了。

这都好说啊，前面的都是这样，但顺序消息是不一样的。等于这个东西，为什么呢？呃，老师在这儿给大家简单说一下啊。因为我们到后边会详细给大家说顺序消息啊。它分两类，一个是全局顺序消息，一个是分区顺序消息。我们需要分别给大家说一下。分别说一下啊，我们呃。咱们看啊，先说这个。全局。顺序消息。这儿还有一个。叫。分区。顺序关系。简单给大家说说啊。先说什么是全局顺序消息，全局顺序消息啊，就是说我这个啊。我整个这套里头只有一个分区。

只有一个Q分区。这样的话，我就可以保证了我这个topic里边所有的消息。被消灭的时候是顺序消灭的。你注意是顺序消费的，什么意思呢？大家看啊，我简单画个图啊，这是。我就是一个分区啊，里边啊有有很多。有很多消息啊，啊，每一个空就是一个消息。然后呢，我这儿有个consumer。我这有个consumer group，这里边consumer。这张卡都没。那么我所谓的顺序消息是指的什么？这里边儿进来的这个顺序和你消费的顺序是一样的。你不管谁。我们大家知道啊，一个我们的一个，呃，这个这个这个Q只能被一个线程。一个Q只能被一个consumer。交费这没问题吧，所以你看你这里边儿这个group里边夸嚓你来了四个，这四个里边是不是有三个。

都不管用。就这一个网游。他在消费他。对吧，他在消费，那他在消费，消费的时候也是一个一个读的，按顺序读的。一次即使你这里面有多个这个节点里面有多个线程，这多个线程它也是一个一个读，我读完它。读了这条消息。在读。这条消息再读这条消息，再读这条，它是按顺序的。也就是说，在同一个时刻。在同一个时刻。只会有一个线程。来来这个读取来处理。这个消息。那么这是什么？这是全局顺序消息啊。全局生效行。也就是说呃简单写一下啊，就是呃该呃类型消息的topic。

只有一个Q。去是吧。啊，然后七可以。保证可以保证。来。Topic。呃的所有消息被什么顺序消费？对肾消费，这个肾消费是需要有保证的啊。啊，为了。保证，呃，这个全局。顺序性。Consumer。在。时刻。同一时刻啊，只能有一个。看这会啊。一个。现场。

一。的现场。来进行。所以其并发。十几就是一。一那你是是是什么东西，一不就正好就是你的分区的数量嘛，一对吧。那什么叫分区？顺序消息的分期顺应消息是这样的。嗯。啊，我这个to啊，这个topic。然后里边。一。二。三我有三个分区。是吧，我有三个分区，然后我这边是group。Group，当然group啊，呃，我们可以有三个，也可以有两个是吧，都行，无所谓，你四个肯定只有三个起作用吧，两个的话那无所谓了，你对于他来说，比如说这俩有他消费，这个有他消费。

你从他的角度来说，你站在他的角度来说，他一样是只有一个。消费者在消费是吧，所以意思是一样的啊，那钱假设我现在有三个，三个啊本啊一个对一个是吧，一个对一个。所谓的分区顺序是它可以保证。就我在这个这个分区里边这些消息。可以被他。顺序的消费。它里边的。这些消息可以被他顺序的消费，同样的道理。是吧，可以被它是一条，但是。我不能保证这些分区之间消息的消费具有持续性，因为我们大家知道这这是假设啊，他们都是来自于同一个生产者。这个生产这个消息呢，哎，第一条写他，第二条写他，第三条写他。

啊，123在这儿啊，123456789是吧，是这样的。那我产生的顺序是一在这儿。四在这。那我消费的时候，是不是我消完一再消费二呢，那不是。我没法保证。我向完一向完四。可能我这边这个二还没有消费呢。就我不能保证他们之间的消息具有有序性。但是我可以保证这一个里边的只有有序性。这叫什么？这叫分区顺序消息。那这种情况下啊，一样，大家看一下这种情况下。就是你这个并发并发度是什么，因为这个里边是不是也是一个抗的一个线程在消费它。同一时刻in consumer的呃一个呃线程在读这儿的数据。

那这样的话，整体上来说相当于什么，我这个consumer group是不是有三个consumer的三个线程在消费这里边儿的。数据。消费这里边儿数据，那为什么这有三个，是因为你这的Q有三个。所以我的并发度实际上是几是三。是不是你Q的数量。这就理解了吧，所以分区顺序消息啊是什么？就是类型消息。行。Topic。有多个。Q。对吧。呃，怎么写？仅可以保证。的每个Q。

分区中的消息被。顺序。呃，消费就是它只能保证，那你每个Q里边的啊，呃，这个适应消费对吧？啊不能保证。呃，整个。消息。消消消消消息，呃的顺序消息对吧。那为了啊。保证啊，这个分区啊顺序。水形是吧，每个Q。奔曲州。对。消息。每个分区，每个分区中消息是不是在这个group。中。嗯，在这个group中的同一时刻。

只能有一个。Consumer。的一个。建成。进行消费对吧。呃。即在同意。十颗。最多是不是会出现。多个Q分区有。多个。Consumer。啊。多个。县城。是不是并行消费？对。并发。是什么？Topic。分区。对不对。

哎，这是我们给大家啊这个引申的啊，引申但是关于这块呃，全局消息啊和这个顺序这个呃，全局顺序消息和分期申请消息啊，我们到呃第九章。那不是第九章了，呃，我们到这个第四章啊，第四章再详细给大家说啊，这个你先做个了解就可以了。我们这个消费变化度啊。呃，好。