一、设计数据结构

二、实现管理方法

🍅 1、实现交换机管理

🍅 2、实现队列管理

🍅 3、实现绑定管理

🎈插入绑定操作

🎈删除绑定

🍅 4、进行消息管理

🍅 5、发送消息到指定队列

🍅 6、表示“未被确认”的消息管理

🍅 7、从硬盘上读取数据

三、测试交换机操作

🍅 1、“准备工作”和收尾工作

🍅 2、测试交换机

🍅 3、测试队列

🍅 4、测试绑定

🍅 5、测试消息的增删查

🍅 6、测试发送消息

🍅 7、测试 “未确认”的信息

🍅 8、测试从硬盘上读取数据

四、小结

一、设计数据结构

对于MQ来说，主要是以内存存储数据为主，硬盘存储数据为辅。

关于内存数据管理，作出如下的数据结构：

交换机：使用HashMap，key是name， value是Exchange对象

队列：使用HashMap，key是name，value是MSGQueue对象

绑定：使用嵌套的HashMap，key是exchangeName，value是一个HashMap（其中key是queueName，value是Binding对象）

消息：使用HashMap，key是messageId，value是Message

表示队列和消息之间的关联：使用嵌套的HashMap，key是queueName，value是一个LinkedList。LinkedList中每个元素又是一个Message对象。

表示“未被确认”的消息：关于未被确认：存储了当前队列中哪些消息被消费者取走了，但是还没有应答。使用嵌套的HashMap，key是queueName，value是HashMap（其中key是messageId，value是Message对象）。后续实现消息确认的逻辑，需要根据ack响应的内容，会提供一个messageId，根据该messageId把结构中的Message对象找到并且移除

这里有两种应答模式（ACK）:

1.自动应答，消费者取了元素，该消息就算是被应答，就可以被删除了

2.手动应答，消费者取了元素，该消息还不断被应答，需要消费者主动再调用一个basicAck方法，此时才被认为是真的应答了，才能删除这个消息。

由于，这个类会涉及到多线程的请求，所以这里的HashMap都统一使用ConcurrentHashMap，因为HashMap是线程不安全的，ConcurrentHashMap相对而来线程安全，所以上面说的使用HashMap都使用ConcurrentHashMap

public class MemoryDataCenter {
//    交换机:key是exchangeMame,value是exchange对象private ConcurrentHashMap<String, Exchange> exchangeMap = new ConcurrentHashMap<>();
//    队列：key表示queueName，value表示MSGQueue对象private ConcurrentHashMap<String, MSGQueue> queueMap = new ConcurrentHashMap<>();
//    绑定：第一个key表示exchangeName，第二个key表示queueName，value都表示Binding对象private ConcurrentHashMap<String,ConcurrentHashMap<String, Binding>> bindingsMap = new ConcurrentHashMap<>();
//    消息：key是messageId,value是Message对象private ConcurrentHashMap<String, Message> messageMap = new ConcurrentHashMap<>();
//    表示队列和消息之间的关联：key表示queueName,value表示一个Message链表，里面存放的是Message对象private ConcurrentHashMap<String, LinkedList<Message>> queueMessageMap = new ConcurrentHashMap<>();
//  表示“未被确认”的消息：第一个key表示queueName，第二个key表示messageId,value表示Message对象private ConcurrentHashMap<String,ConcurrentHashMap<String,Message>> queueMessageWaitAckMap = new ConcurrentHashMap<>();
}