基于consumer的启动流程,前期先基于类的顺序图来说明,可以一目了然,然后再基于源码进行分析
consumer的核心操作类:
DefaultMQPushConsumer:
MessageListener:消息监听,接受消息做处理
DefaultMQPushConsumerImpl:消息的核心处理
MQClientInstance:核心通信
PullAPIWrapper:服务请求拉取
ConsumeMessageService:消息消息
转载于:https://my.oschina.net/wangshuaixin/blog/3057637