RocketMQ原理
2022-08-22 10:14:29 16 举报RocketMQ存储原理
作者其他创作
大纲/内容
m1
TagHashCode
xx
n1
menu
10
send
send(msg2)
n4
0
2
hash(\"binlog#1001\") % totalSlotNum=n1hash(\"binlog#1111\") % totalSlotNum=n3hash(\"binlog#1002\") % totalSlotNum=n2hash(\"binlog#1112\") % totalSlotNum=n4
p8
inst
3
p6
8
5
20
9
p5-p4+1
n2
p9
p1
n3
success
p7
send(msg1)
40
order
Head
send(msg3)
msgId:1111
8 Bytes
4
7
send(msg4)
commit log offset
Dispatch
send(msg5)
msgId:1114
ReputMessageService ThreadLoopCommitLog ——ConsumeQueue
ConsumeQueue
p3-p2+1
p4
p9-p8+1
p7-p6+1
1
m2
Index File
6
msgId:1112
CommitLog
p5
CommitLogOffset
Size
p3
p2
msgId:1115
p1+1
4 Bytes
msgId:1113
0 条评论
下一页
