00:02
好,下面我们来看这个定阅关系的一致性,这个比较简单啊。嗯,这关系一致性是指的什么呢?是同一个消费者组啊,也就是group和ID相同是吧,同一个同一个消费者组里边。所有的consumer实力所定义的topic。然后tag。A。消息对消息的处理逻辑必须完全一致。否则消息消费的逻辑就会混乱。导致。甚至导致呃消息丢失。呃,这个啊给大家先说,呃这个tag和呃to和tag啊是必须完全一致的,那这个消费逻辑呢,如果你不一致。他也不会给你报错,但是呢,有可能会出现什么,这里面说到的,呃,消费逻辑混乱,然后消息丢失。好,我们一会儿来看啊。他说正确的对应关系是什么?
01:00
这定义关系啊,呃,我们现在举的例子呢,都是什么,都是这个多个消费者啊,定阅了多个topic,你看我现在啊,这一个消费者组,这一个消费者组。对吧,呃,这是我的这个这个Q啊,然后。我这里面所有的消费者定位的都是什么,Topic a tag。是一或者二都一样。是吧,都一样,而这个里边对应的是To B。Tag是什么?是所有星星就是所有。是吧,这是正确的啊,这是正确的啊,每个消费者组里边多个消费者实力,他的对位关系保持了一致。那么错误的关系。我们的错误关系呢,也就是说啊,我们对多个。大家看错误的关系,这儿给大家举了几个例子,是代码啊,代码给出这个具体的。给错误,就是你要代码这样写就错了啊。呃,大家看啊,这个错误是什么?变了不同的topic,你看这个代码。
02:06
这是CONSUMER1啊,一首group。呃,Group ID group ID是这样一个group ID是吧,然后呢,这里边儿,呃,我订阅。是吧,这个这个consumer是吧,点订阅订阅这我的主题。对应的这个主题,然后心对应的是所有。这下边是什么?这是监听器对吧,监听器,这就是我们的业务处理逻辑,呃,消对消息的处理逻辑啊。这个里边实际上是订阅了什么。啊,订阅了,呃。Topic为他。呃,他然后。Has为所有的。
03:00
消息。对吧,这这。这样写吧。就是这个啊,那这个呢。命运战士B,看到吧。这是B。是吧,然后也是星。是一样的,都是所,但关键什么不一样。就是这个topic不一样。是吧,就这里边是B啊。所以这,这是一种什么错误的恋人关系?你再看他的。哎,就定义了不同的态度。比如说我们大家看啊,这是A,这是A。不一样的TA就是星。所以。Or?喂。看着A。消息是吧。这个呢?
04:01
Tag为所有,那这俩是不是tag不一样?是一样的。对吧,这也是一种错误的定位关系。然后再看它。这个啊。在这个错误在于什么?两个cons定义了不同数量的topic。你看我这。这B是吧,也就是说我这里边儿啊。呃,该。呃,该。同学们订阅了。两个topic,两个主题。是吧,啊。就光说两个就行了。你看他呢?这边就一个。是吧,就一个,所以首先咱先不过不说tag的问题啊,先不说T,你数量上就已经不对了。
05:05
接下来一个啊。啊。这两个。Topic。对吧,不同数量的topic,你看这里边并没有给大家举例子,举什么例子啊,我这里边啊,呃,这个这个这个T也一样,Topic个也一样,Tag也一样,但什么不一样,处理逻辑不一样。处理逻辑如果不一样的话,他也属于他不会报错啊。但是你你定下来这不同的这些东西啊,他也不会报错,首先来说他不会报错,但这种关系错了。这种并列关系啊,你这样写大家说啊,执行的时候不报错,但是会乱套。你说啊,消费整个会乱套,所以你最好保持什么。这些都一致,然后呢,处理逻辑也一致,这样的话,出现的结果会是你预料到的结果。
06:00
如果这些东西只要出现不一致的地方了,那么出现的结果可能就是你预料不到的。啊,这就是我们说这关系它的一致性。这个是大家需要注意到它就行了啊。
我来说两句