rocketmq之源码分析consumer启动流程(十)

  • Post author:
  • Post category:其他


基于consumer的启动流程,前期先基于类的顺序图来说明,可以一目了然,然后再基于源码进行分析

consumer的核心操作类:

DefaultMQPushConsumer:

MessageListener:消息监听,接受消息做处理

DefaultMQPushConsumerImpl:消息的核心处理

MQClientInstance:核心通信

PullAPIWrapper:服务请求拉取

ConsumeMessageService:消息消息


转载于:https://my.oschina.net/wangshuaixin/blog/3057637