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

只有在PUSH模式下才會使用PullMessageService服務線程,該線程主要是對pullRequestQueue:LinkedBlockingQueue<PullRequest>隊列進行監測,處理該隊列中的PullRequest請求對象;同時該線程也提供了兩種拉取方式,分別是當即拉取和延遲拉取兩種;web 1 拉取消息的處理邏輯 在該線程的run方法中,循環地不間斷地從pullReques
相關文章
相關標籤/搜索