Open GejinZ opened 5 years ago
[第四组]
Fix issue #1.
用来在内存中存储数据的数据结构是 CurrentMap：private final ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId */, List<MessageExtBrokerInner>>> 数据存入时，根据topic和queueId可以唯一确定一个List，把message存入到对应的List中。 取数据时，根据topic和queueId和offset从对应的List中取出需要查找的message.
private final ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId */, List<MessageExtBrokerInner>>>
[第四组]
What is the purpose of the change
Fix issue #1.
Brief changelog
用来在内存中存储数据的数据结构是 CurrentMap：
private final ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId */, List<MessageExtBrokerInner>>>数据存入时，根据topic和queueId可以唯一确定一个List，把message存入到对应的List中。 取数据时，根据topic和queueId和offset从对应的List中取出需要查找的message.