DefaultLitePullConsumer 核心参数与实战

在《消息消费 API 与版本变更》中也提到 DefaultMQPullConsumer（PULL 模式）的 API 太底层，使用起来及其不方便，RocketMQ 官方设计者也注意到这个问题，为此在 RocketMQ 4.6.0 版本中引入了 PULL 模式的另外一个实现类 DefaultLitePullConsumer，即从 4.6.0 版本后，DefaultMQPullConsumer 已经被标记为废弃，故接下来将重点介绍 DefaultLitePullConsumer，并探究如何在实际中运用它解决相关问题。

DefaultLitePullConsumer 类图

首先我们来看一下 DefaultLitePullConsumer 的类图结构，如下图所示：

核心方法详解

核心方法说明如下。

void start()

 

启动消费者。

  

   

    

     

    
    

     

      void shutdown()
     
    
   

    

     

    
    

     

    
  
 

关闭消费者。

void subscribe(String topic, String subExpression)

 

按照主题与消息过滤表达式进行订阅。

void subscribe(String topic, MessageSelec
 

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

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