RocketMQ——Consumer篇:PUSH模式下拉取消息服务的线程(PullMessageService)

只有在PUSH模式下才会使用PullMessageService服务线程,该线程主要是对pullRequestQueue:LinkedBlockingQueue<PullRequest>队列进行监测,处理该队列中的PullRequest请求对象;同时该线程也提供了两种拉取方式,分别是当即拉取和延迟拉取两种;web 1 拉取消息的处理逻辑 在该线程的run方法中,循环地不间断地从pullReques
相关文章
相关标签/搜索