消息消费 API 与版本变迁说明

从本篇开始我们将详细介绍 RockeMQ 的消息消费端的 API。

消息消费类图

RocketMQ 消费端的 API 如下图所示：

其核心类图如下所示。

MQAdmin

MQ 一些基本的管理功能，例如创建 Topic，这里稍微有点奇怪，消费端应该不需要继承该接口。该类在消息发送 API 章节已详细介绍，再次不再重复说明。

MQConsumer

MQ 消费者，这个接口定义得过于简单，如果该接口需要，可以将其子接口一些共同的方法提取到该接口中。

Set<MessageQueue> fetchSubscribeMessageQueues(final String topic)

 

获取分配该 Topic 所有的读队列。

MQPushConsumer

RocketMQ 支持推、拉两种模式，该接口是拉模式的接口定义。

void start()

 

启动消费者。

  

   

    

     

    
    

     

      void shutdown()
     
    
   

    

     

    
    

     

    
  
 

关闭消费者。

void registerMessageQueueListen
 

文章来源: blog.csdn.net，作者：中间件兴趣圈，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/prestigeding/article/details/109335885