主要功能
- 異步解藕
- 流量削峰
- 數(shù)據(jù)分發(fā)
應(yīng)用角色
- Nameserver
- Broker
- Product
- Consumer
角色
- 分組
- 主題
- 消息隊(duì)列
- 偏移量
- tag
消息發(fā)送和接收/消費(fèi)模式
- 點(diǎn)對點(diǎn)/廣播/批量
- 同步/異步
消息分類
順序/延時(shí)
消息存儲
commitlog(元數(shù)據(jù)1G)、consumerqueue（邏輯 ）摩泪、index（messagkey）形帮、config（topic\groop等配置）
文件刪除
過期刪除 非當(dāng)前寫文件默認(rèn)42小時(shí)
過期判斷 最后一次更新到現(xiàn)在
刪除時(shí)間點(diǎn) 4點(diǎn)、磁盤使用率
rocketmq零拷貝MMP
內(nèi)存映射
rocketmq半事物
兩階段提交
生產(chǎn)隊(duì)列選擇/消費(fèi)隊(duì)列選擇策略
- 默認(rèn)選擇隊(duì)列+輪訓(xùn)+規(guī)避 生產(chǎn)者超過重試選規(guī)避/故障延時(shí)策略 超過重試次數(shù) 規(guī)避一段時(shí)間
- consumer默認(rèn)平均/改為queue輪訓(xùn)
集群高可用
- 多master 消息分散到2個(gè)master
主掛不可寫可以在從節(jié)點(diǎn)消費(fèi)
同步復(fù)制/同步刷盤
