RocketMQ学习三-Consumer临时
结合https://blog.csdn.net/prestig...作者文章
消费端的主要功能有启动消费者，关闭消费者，同步或异步推或者拉取消息，获取指定消息消费队列的消费进度，获取当前正在处理的消息消费队列，订阅主题，取消订阅，注册并发消费模式监听器等功能。
在 RocketMQ 的内部实现原理中，其实现机制为 PULL 模式，而 PUSH 模式是一种伪推送，是对 PULL 模式的封装。每拉去一批消息后，提交到消费端的线程池（异步），然后马上向 Broker 拉取消息，即实现类似“推”的效果。为什么要对拉取的基础上再封装出推送呢？主要是拉取模式对使用者不友好，对使用者要求比较高，封装成推送后的API简单。
分别介绍拉取与推送的具体流程。
RocketMQ 不保证消息重复消费原因分析（第9章）
ConsumeFromWhere 注意事项(10章)
订阅关系不一致导致消息丢失
【RocketMQ学习三-Consumer临时】Lite Pull 与 PUSH 模式之对比（11章）
长轮询实现原理
PUSH 与 PULL 模式选型（12章）
推荐阅读
- 放屁有这三个特征的，请注意啦！这说明你的身体毒素太多
- 一个人的旅行，三亚
- 2018-02-06第三天|2018-02-06第三天 不能再了，反思到位就差改变
- 第三节|第三节 快乐和幸福（12）
- android第三方框架（五）ButterKnife
- 遇到一哭二闹三打滚的孩子，怎么办┃山伯教育
- 三十年后的广场舞大爷
- 由浅入深理解AOP
- 一百二十三夜，请嫁给我
- 2018年9月5日，星期三，天气晴