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