From 06545375a2cf6421d8c290937137557e2cf2cc89 Mon Sep 17 00:00:00 2001 From: daniubi <804703017@qq.com> Date: Tue, 29 Jun 2021 19:05:05 +0800 Subject: [PATCH] =?UTF-8?q?2.1.7=20=E6=B6=88=E6=81=AF=E7=9A=84=20push=20?= =?UTF-8?q?=E5=AE=9E=E7=8E=B0--=E8=A1=A5=E5=85=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 感觉这样对初学者而言更直观一点。 --- .../distributed-system/message-queue/RocketMQ-Questions.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/docs/system-design/distributed-system/message-queue/RocketMQ-Questions.md b/docs/system-design/distributed-system/message-queue/RocketMQ-Questions.md index a41a4035..843d927a 100644 --- a/docs/system-design/distributed-system/message-queue/RocketMQ-Questions.md +++ b/docs/system-design/distributed-system/message-queue/RocketMQ-Questions.md @@ -172,6 +172,8 @@ class Broker { 1. 注意,RocketMQ 已经说了自己会有低延迟问题,其中就包括这个消息的 push 延迟问题 2. 因为这并不是真正的将消息主动的推送到消费者,而是 Broker 定时任务每5s将消息推送到消费者 +3. pull模式需要我们手动调用consumer拉消息,而push模式则只需要我们提供一个listener即可实现对消息的监听,而实际上,RocketMQ的push模式是基于pull模式实现的,它没有实现真正的push。 +4. push方式里,consumer把轮询过程封装了,并注册MessageListener监听器,取到消息后,唤醒MessageListener的consumeMessage()来消费,对用户而言,感觉消息是被推送过来的。 ### 2.1.8 消息重复发送的避免