rocketmq知识脑图

生产者生产消息，mq确认消息未送达

消费这消费消息，消费成功消息费送达

消费者挂掉，reblance

10s 扫描, cleanResourceInterval

物理磁盘 85%, 不在接收消息,返回失败,

清理 凌晨四点 deleteWhen 或到达磁盘清理阈值

文件保留72h

无状态

拉区broker的消息到 本地队列 [链接](https://blog.csdn.net/iie_libi/article/details/54236502), 默认1000, pullThresholdForQueue

pullInterval 设置拉去时间间隔

消费进度, 默认为5秒, 每隔一段时间将各个队列的消费进度存储到对应的broker上

broker 与所有的nameserver 长连接

borker 心跳, 30s, 心跳包包含topic配置信息。nameserver 10s 扫描存活的broker,2分钟无心跳,断开连接

断开 broker挂掉, 心跳超时 nameserver主动断开连接, 跟新topic 与 broker的对应关系, 不会通知消费者

单个生产者和 一个nameserver保持长连接, 果该nameserver挂掉，自动连接下一个直到有可用连接为止。

轮询时间 30s, 如果broker挂点, 生产者需要30s才能知道, 期间 消息发送失败; 该时间由DefaultMQProducer的pollNameServerInteval参数决定，可手动配置。

单个生产者 和 所有关联的broker保持长连接,和 NS没有心跳

- 心跳 30s heartbeatBrokerInterval； broker每隔10秒钟（此时间无法更改），扫描所有还存活的连接，若某个连接2分钟内（当前时间与最后更新时间差值超过2分钟，此时间无法更改）没有发送心跳数据，则关闭连接。

单个消费者和一台nameserver保持长连接，定时查询topic配置信息，如果该nameserver挂掉，消费者会自动连接下一个nameserver，直到有可用连接为止，并能自动重连。

默认情况下，消费者每隔30秒从nameserver获取所有topic的最新队列情况，这意味着某个broker如果宕机，客户端最多要30秒才能感知。该时间由DefaultMQPushConsumer的pollNameServerInteval参数决定，可手动配置。

单个消费者和该消费者关联的所有broker保持长连接。

心跳默认情况下，消费者每隔30秒向所有broker发送心跳，该时间由DefaultMQPushConsumer的heartbeatBrokerInterval参数决定，可手动配置。broker每隔10秒钟（此时间无法更改），扫描所有还存活的连接，若某个连接2分钟内（当前时间与最后更新时间差值超过2分钟，此时间无法更改）没有发送心跳数据，则关闭连接，并向该消费者分组的所有消费者发出通知，分组内消费者重新分配队列继续消费

消费者挂掉；心跳超时导致broker主动关闭连接; 旦连接断开，broker会立即感知到，并向该消费者分组的所有消费者发出通知，分组内消费者重新分配队列继续消费

同步消息: send

异步消息： SendCallback

顺序消息： sendMessageOrderly, MessageQueenSelector

单项消息: sendOneWAY

延时消息：message.setDelayLevel()

批量消息：<4M

事务消息： 半消息; 提交，回滚，中间态；回查15次,transactionCheckMax

Topic

Tag

tag: tag1||tag2, *

sql: putUserProperty,MessageSelector.bySql("i > 5")

集群模式（默认），多groupid通过集群订阅模式，实现广播消费；
多个group订阅同一个topic, 如果同一个group有多个消费者，则同group构成集群消费

广播（MessageModel.BROADCASTING）

存储介质

双主双从：主负责写, 主从负责读

nameserver: 无状态

broker: 上报状态

主从复制

producer

consumer

顺序消息的重试: 自动触发,应避免阻塞

无序消息(集群模式): 16次, 4h16分钟, 死信队列, 设置重试次数,同一group 设置一个,全部都生效

最大重试次数,依然失败, %DLQ%

有效期也是3天

面向group id, 和topic无关