RocketMQ中的核心机制

Broker是RocketMQ的核心组件，完成接受Producer生产的消息、处理Consumer的消费消息的请求、消息的持久化、以及HA等等。 消息的存储和发送 作为一个优秀的分布式队列，需要达到实时性、高吞吐量、高可用的要求。为了满足高可用性，通常的做法就是将消息进行持久化，入磁盘，RocketMQ也是如此。同时，磁盘的读取速度需要与网络传速速度匹配才能提高消息队列的性能，举个例子，读取本地的

>>阅读原文<<