RockMQ源码学习-consumer 获取消息(1)
2019-09-24
阅读 3 分钟
1.8k最近闲来无事,down了RocketMQ 4.5.2的源码学习一下,ok,进入主题 consumer.start()对应的调用如下图所示: 由上图可知,在DefaultMQPushConsumer.start()中 调用 MQClientInstance的构造方法,递归调用PullMessageService的构造方法。 由此说明了消息传递少不了这个PullMessageService帮忙。 DefaultMQPushConsumer.sta...