关于rocketmq:RocketMQ学习三Consumer临时

8次阅读

共计 422 个字符,预计需要花费 2 分钟才能阅读完成。

联合 https://blog.csdn.net/prestig… 作者文章
生产端的次要性能有启动消费者,敞开消费者,同步或异步推或者拉取音讯,获取指定音讯生产队列的生产进度,获取以后正在解决的音讯生产队列,订阅主题,勾销订阅,注册并发生产模式监听器等性能。
在 RocketMQ 的外部实现原理中,其实现机制为 PULL 模式,而 PUSH 模式是一种伪推送,是对 PULL 模式的封装。每拉去一批音讯后,提交到生产端的线程池(异步),而后马上向 Broker 拉取音讯,即实现相似“推”的成果。为什么要对拉取的根底上再封装出推送呢?次要是拉取模式对使用者不敌对,对使用者要求比拟高,封装成推送后的 API 简略。

别离介绍拉取与推送的具体流程。

RocketMQ 不保障音讯反复生产起因剖析(第 9 章)

ConsumeFromWhere 注意事项 (10 章)
订阅关系不统一导致音讯失落

Lite Pull 与 PUSH 模式之比照(11 章)
长轮询实现原理
PUSH 与 PULL 模式选型(12 章)

正文完
 0