rocketmq-pullmessage
文档摘要
该文所涉及的 RocketMQ 源码版本为 4.9.3。 RocketMQ 消息拉取流程 之前在消费者启动流程中描述过 MQClientInstance 的启动流程，在启动过程中会启动 PullMessageService，它继承了 ，并且 ServiceThread 实现了 Runnable 接口，所以是单独启动了一个线程 PullMessageService 的 run 方法如下： 只要没有停止，线程一直会从 PullRequestQueue 中获取 PullRequest 消息拉取任务，如果队列为空，会一直阻塞，直到有 PullRequest 被放入队列中，如果拿到了 PullRequest 就会调用 pullMessage 方法拉取消息 添加 PullRequest
评论区
(0)
U