rocketmq pushconsumer

RocketMQ的PushConsumer是一种消息消费者模式，它是基于拉取模型的实现。尽管消息消费被称为Push，但实际上仍然是通过拉取的方式来获取消息。\[1\]在RocketMQ中，消费者有两种模式，一种是push模式，另一种是pull模式。在push模式中，当服务端有消息时，将消息推送到客户端。而在pull模式中，客户端需要不断轮询请求服务端来获取新的消息。\[3\]不过，无论是push模式还是pull模式，实际上都是采用消费端主动拉取的方式，即consumer轮询从broker拉取消息。\[3\]在PushConsumer中，轮询过程被封装在内部，并通过注册MessageListener监听器来消费消息。当消息到达时，会唤醒MessageListener的consumeMessage()方法来进行消费，给用户一种消息被推送过来的感觉。\[3\]而在PullConsumer中，用户需要自己编写获取消息的逻辑，首先通过打算消费的Topic获取MessageQueue的集合，然后遍历MessageQueue集合，针对每个MessageQueue批量获取消息，一次取完后记录该队列下一次要取的开始offset，直到取完了再切换到另一个MessageQueue。\[3\]所以，PushConsumer是RocketMQ中用于实现push模式消息消费的一种消费者。
#### 引用[.reference_title]
- *1* [RocketMQ实战-初探PushConsumer限流机制实现原理](https://blog.csdn.net/Huangjiazhen711/article/details/127746551)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insert_down28v1,239^v3^insert_chatgpt"}} ] [.reference_item]
- *2* [rocketmq源码-consumer拉取消息（push模式）](https://blog.csdn.net/CPLASF_/article/details/128311025)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insert_down28v1,239^v3^insert_chatgpt"}} ] [.reference_item]
- *3* [rocketMQ之consumer的push和pull模式](https://blog.csdn.net/qq_26896085/article/details/104958768)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insert_down28v1,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]