rocketmq 关于rocketmq:RocketMQ学习十五消费进度提交 通过队列负载机制后，会调配给以后消费者一些队列，留神一个生产组能够订阅多个主题，正如下面 pullRequestQueue 中所示，topic_test、topic_test2 这两个主题都调配了一个队列。
rocketmq 关于rocketmq:RocketMQ学习十三消息的PUSH与PULL消费方式 在 RocketMQ里生产形式虽有PUSH与PULL两种，但实现机制实为 PULL 模式，PUSH 模式是一种伪推送，是对 PULL 模式的封装，每拉去一批音讯后，提交到生产端的线程池（异步），而后马上向 Broker 拉取音讯，即实现相似“推”的成果。
rocketmq 关于rocketmq:RocketMQ学习十三顺序消息延时消息与消息过滤 RocketMQ只能保障队列级别的音讯有序，如果要实现某一类音讯的程序执行，就必须将这类音讯发送到同一个队列，能够在音讯发送时应用 MessageQueueSelector，通过指定sharding key进而将同一类音讯发送到同一队列里，这样在CommitLog文件里音讯的程序就与发送时统一了。broker端抉择发送的队列能够参考之前是的文章：Rocke…
rocketmq 关于rocketmq:RocketMQ学习十二Consumer学习 生产端的次要性能有启动消费者，敞开消费者，同步或异步推或者拉取音讯，获取指定音讯生产队列的生产进度，获取以后正在解决的音讯生产队列，订阅主题，勾销订阅，注册并发生产模式监听器等性能。在 RocketMQ 的外部实现原理中，其实现机制为 PULL 模式，而 PUSH 模式是一种伪推送，是对 PULL 模式的封装。每拉去一批消…
rocketmq 关于rocketmq:RocketMQ学习十二消息刷盘 数据存储这一块，RocketMQ应用的是文件编程模型。为了进步文件的写入性能通常会引入内存映射机制，数据先写入页缓存而后再择机将页缓存数据刷盘到磁盘，写入波及性能与数据可靠性是必须要思考的。针对刷盘策略个别会有同步刷盘与异步刷盘，RocketMQ也是如此，默认应用异步刷盘。先来简略看下RocketMQ刷盘操作的代码块：
rocketmq 关于rocketmq:RocketMQ学习十一offset管理 通过上一篇咱们曾经晓得只有先从ConsumerQueue里获取到了CommitLog物理偏移量后才能够疾速的从CommintLog里找到对应的message。那ConsumerQueue里的信息又是如何定位的呢？这里就波及到咱们明天的主题：offset治理。在RocketMQ中，音讯生产实现后须要将offset存储下来，offset用来治理每个生产队列的不同生产组的生产进…
rocketmq 关于rocketmq:RocketMQ学习十消息存储 下面是从官网上找的一张图，producer发送音讯后，由broker生成CommitLog与ConsumerQueue文件，而后consumer依据ConsumerQueue里获取音讯在commitLog里的起始物理地址+message size后，拿到音讯进行生产。上面别离介绍下CommitLog,ConsumerQueue与IndexFile这三个文件。
rocketmq 关于rocketmq:RocketMQ学习九Broker分析 Broker次要缓存了路由信息，蕴含producer表,consumer表,consumerGroup表和topic表。这些信息是在ProducerManager，ConsumerManager，SubscriptionGroupManager，TopicConfigManager这几个类里进行治理的。
rocketmq 关于rocketmq:RocketMQ学习八NameServer分析 NameServer作为RocketMQ的注册核心，次要存储了哪些信息，如何存储，信息有变更时如何告诉进来的？上面咱们带着这几个问题一起剖析下NameServer
rocketmq 关于rocketmq:RocketMQ学习七Netty的应用 RocketMQ音讯队列集群次要包含NameServe、Broker(Master/Slave)、Producer、Consumer4个角色，根本通信流程如下:
