一、设计数据结构
针对交换机、队列、绑定、消息、待确认消息设计数据结构。
-
交换机集合 exchangeMap
数据结构:ConcurrentHashMap
key:交换机name value:交换机对象 -
队列集合 queueMap
数据结构: ConcurrentHashMap
key:队列name value:队列对象 -
绑定集合 bindingsMap
数据结构: ConcurrentHashMap 嵌套 ConcurrentHashMap
key:交换机名字 value: ConcurrentHashMap <key:队列名字 value:绑定对象> -
消息集合 messageMap
数据结构: ConcurrentHashMap
key:messageId value:message对象 -
队列消息集合
数据结构 : ConcurrentHashMap 嵌套 LinkedList
key:队列name value:LinkedList < Message > -
待确认消息集合
数据结构: ConcurrentHashMap 嵌套 ConcurrentHashMap
key:队列name value: ConcurrentHashMap < key:messageId value:Message对象>
二、管理集合
1.交换机
- 往交换机集合中添加 Exchange 对象
- 从交换机集合中删除Exchange 对象
- 根据exchangeName查找Exchange对象
2.队列
- 往队列集合中添加MSGQueue对象
- 从队列集合中删除MSGQueue对象
- 根据queueName查找MSGQueue对象
3.绑定
-
往绑定集合中添加新绑定
-
从绑定集合中删除绑定
-
根据 exchangeName 和 queueName查找唯一的Binding 对象
-
根据exchangeName查找该交换机的所有绑定关系
4.消息
- 往消息集合中添加新消息
- 从消息集合中删除消息
- 根据messageId查找Message对象
5.队列上的消息
-
往队列消息集合中发送消息
-
从队列集合中取出消息
-
统计队列上的消息总数
6.待确认消息
-
往待确认集合中添加消息
-
从待确认集合中删除消息
文章来源:https://www.toymoban.com/news/detail-693900.html -
根据messageId在待确认集合中查找Message对象
文章来源地址https://www.toymoban.com/news/detail-693900.html
7.恢复数据
- 将所有集合(除了待确认消息结合)清除
- 从硬盘上加载交换机、队列、绑定、消息到内存
到了这里,关于基于RabbitMQ的模拟消息队列之四——内存管理的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!