077-消费者消费代码举例

呃，下边我们定一下这个消费者啊，消费者。跟前面的不一样。消费者。好，首先。啊，这个。而这是。定义大家注意啊，这个定义的是个什么？MQ push consumer，看到吗？这定义呃，A个什么啊，Push。消费者，因为我们大家知道这个消费模式有push和push。那有哥们说这个，那push怎么定义，那你这个push有了，你这push还不好定义吗？是吧，我。我直接这样写吧。我另一个。Before，看到没有，就这个。就这个。呃，Ault，呃这个这个呃light a是吧，然后你可以。

给他写上。呃。而我们。这个注释掉啊，定义一个。下去是吧。呃，指定name啊，指定。呃，确定。它一样得是吧，哎，然后这个。前面我们见过吧，从哪开始消费啊？从第一个。是不是从第一条开始是吧。啊，决定从嗯，从B。条消息。开始。消费对吧，然后这是指定消费的。指定。

呃。消费。Topic。是不是tag tag我这所有的。然后紧接着在这我注册一个message。那我注册注册一个。呃，注册，呃这个。消息。呃，尖尖。变成器是吧，连电器你一旦。你注意啊，一旦呃。就是你那个，呃，消息队里边有了消息了，他马上就会触发。这个方法的执行干嘛consume message去消费？是吧，所以就是。啊，一旦啊，Broke中有了相应，呃，有了其订阅是。

消息是吧，你指定阅了，那么。触发。该方法的。就行。都刷这个执行。注意这个执行啊，它返回值是什么？返回值是你消费的状态啊返回值。七返回值为。嗯。没。当前。Consumer。呃，消费的状态，你消费是不是成功了。这个状态，他这有个返回值有啥用，谁谁谁要这个值啊。你想这个方法谁调用的？这是回调方法呀。回调是谁调用的？其实是我们的MQ在调用。对不对，所以这个状态，实际上这个状态是谁要的。是我们MQ。

调查。对吧，哎，然后呢，我这边做什么。哎，这这个messages看到没有messages，只不过这messages里边啊，你注意它这个message是。以这个形式出现的扩展。Message扩展以它形式出现的啊。呃，那那所以我们在这儿。就是。嗯。便利，实际上这是什么？这就是在消费消息啊。竹条。消费消息。对吧，主台消费消息，然后消费完毕，你只要能走到这儿，这是什么返回呃，消费状态。什么？消费。那我这是不是成功了，但你这里边如果有异常，你可以返回其他的啊。缺乏其他的。呃，再然后是吧，我们这个是开启。

开启。下面。际消费。对吧，开启开启消费啊，那么。在这儿其实大家想一下啊，记不记得我们之前说过，呃，我们消费者消费模式是不是两种，一种是广播式消费，一个是集群消费，默认是集群啊，那现在开始集群消费。你如果启用多个，呃，这这这这个当前这个进程啊，那么。他就是以集群的方式来消费的。当然我们这个。这个我现在想指定广播消费怎么办是吧，我们可以这样啊是。

Set。这个。你看。Mode。大家看这是什么b cutting。啊，这个是广播模式。是吧，就是。指定。采用什么？广播。嗯。模式。进行消费是吧，那默认是什么。啊，默认为。呃，这个。集群。啊，这两种区别来大家知道吧，广播模式是什么？呃，所有所有消息我全部都消费，呃，机器模式呢，大家一块一块来消费。

把这个注掉吧，哎。OK。这就可以了，那现在我们消费谁，Some some里边是不是消比较多一些嘛，是吧，我们现在就消费，从第一条开始消费是吧，好了。跑，跑起来。早起。你看。是不是那消费了这么多对吧？这里有很多数据啊，我们之前也都见过啊呃，Brokeer name是吧，ID，然后store size，然后q of s。这这这这个你看是不是也是条数对吧，然后呢。不就这这个消息啊，产生的时间，呃，被生产的时间啊，就是它的生产者是谁是吧？存储的时间啊，生产的时间，存储的时间是吧？呃，还有这个MGID，呃，这是producer它那个ID是吧？然后这在commit log里边的偏移量啊，这是个地址是吧？啊然后这这我们前面有很多的是不是都是见过的。

是吧？这个消费啊，这消消费，然后。我们看下这啊。消费者。消费者。嗯。消费者，这好像我们也看不到啥东西是吧？在这。我们的CG是吧。其他也就这了吧，嗯。能看到能看到这个定位组吗？是不是就它因为因为你注意啊，现在这个是。他可没有关掉啊，你看啊，我我现在。

把这清掉。现在我重新只要我发消息过来，因为他他这监听啊。我重新发消息啊。Some topic topic。发消息走。发送消息了，刚才这个清空了吧，你看是不是又有了。对不对，我清空。清空了啊，这个清空了。啊，然后这个。再来。走。它里边是不是又有，那说明什么，他一直在消费，只要你有数据，因为我这里边有监听器。对吧，这有监听器啊，有数据我马上就能。呃，就能消费。对不对，OK，给大家拷贝一下吧。

好，呃，这是我们，嗯，把这个发送类型说了一下，然后我们各自举了个例子，啊举了例子，然后我们又定定义了一个，呃。消费者。OK。