主要功能
- 异步解藕
- 流量削峰
- 数据分发
应用角色
- Nameserver
- Broker
- Product
- Consumer
角色
- 分组
- 主题
- 消息队列
- 偏移量
- tag
消息发送和接收/消费模式
- 点对点/广播/批量
- 同步/异步
消息分类
顺序/延时
消息存储
commitlog(元数据1G)、consumerqueue(逻辑 )、index(messagkey)、config(topic\groop等配置)
文件删除
过期删除 非当前写文件默认42小时
过期判断 最后一次更新到现在
删除时间点 4点、磁盘使用率
rocketmq零拷贝MMP
内存映射
rocketmq半事物
两阶段提交
生产队列选择/消费队列选择策略
- 默认选择队列+轮训+规避 生产者超过重试选规避/故障延时策略 超过重试次数 规避一段时间
- consumer默认平均/改为queue轮训
集群高可用
- 多master 消息分散到2个master
主挂不可写可以在从节点消费
同步复制/同步刷盘