1. 首先需要明确地提出 消息中间件的几个重要角色，分别是生产者、消费者、Broker、注册中心。

2. 简述下消息中间件数据流转过程，无非就是 生产者生产消息，发送至Broker，Broker可以暂缓消息，然后消费者再从Broker获取消息，用于消费。

3. 而注册中心用于服务的发现包括：Broker的发现、生产者的发现、消费者的发现，当然还包括下线，可以说服务的高可用离不开注册中心。

4. 然后开始讲述实现要点： 各个模块的通信基于Netty然后自定义协议来实现 ，注册中心可以利用Zookeeper、consul、eureka、nacos等等，也可以像RockerMQ自己实现简单的namesrv

5. 为了考虑扩容和整体的性能，采用分布式思想，就像kafka一样采取分区理念， 一个Topic分为多个partition，并且为了保证数据可靠性，采取多副本存储，即Leader和follower ，根据性能和数据可靠的权衡提供异步和同步的输盘存储

6. 还可以利用 选举算法保证Leader挂了之后follower可以顶上 ，保证消息队列的高可用

7. 为了提供消息的可靠性， 利用本地文件系统来存储消息 ，并且采用顺序写的方式来提高性能

8. 根据消息队列的特性 利用内存映射、零拷贝进一步提升性能 ，还可以利用像kafka这种批处理思想提高整体的吞吐量。

衍生问题

1. Netty是什么？各注册中心之间的选型对比？

2.选举算法，Bully 算法、Raft 算法、ZAB 算法等等？

3.分区，这个分区和 RocketMQ 的队列有什么不同？具体分区要怎么实现？

4.顺序写，为什么要顺序写啊？内存映射和零拷贝又是什么啊？RocketMQ 和 Kafka 用了哪个吗?

5.消息的写入如何存储、消息的索引如何生成等等？有没有看过消息中间件的源码？