设计MQ的思路

分布式

首先这个mq得支持可伸缩性吧，就是需要的时候快速扩容，就可以增加吞吐量和容量，那怎么搞？设计一个分布式系统，参照一下kafka的设计理念，broker->topic->pratition,每个partition放一个机器，就存一部分数据。如果现在资源不够了，简单呀，给topic增加partition，然后做数据迁移，增加机器，不就可以存放更多的数据，提供更高的吞吐量

持久性

期次你得考虑一下这个mq的数据要不要落地磁盘吧？那肯定要了，落地磁盘才能保证进程挂了数据就丢了。那落磁盘的时候怎么落啊？顺序写，这样就没有磁盘随机读写的寻址开销，磁盘顺苏读写的性能是很高的，这就是kafka的思路。

可用性

期次你考虑一下你的mq的可用性啊？这个事儿，具体参考之前可用性那个环节讲解的kafka的高可用保障机制。多副本->leader&follower->broker挂了重新选举leader即可对外服务。

能不能支持数据0丢失啊？可用的，参考我们之前说的那个kakfa数据零丢失方案。