RocketMQ架構原理

訊息模型。rocketmq主要由producer、broker、consumer三部分組成，其中producer負責生產訊息，consumer負責消費訊息，broker負責儲存訊息。broker在實際部署過程中對應一台伺服器，每個broker可以儲存多個topic的訊息，每個topic的訊息也可以分片儲存於不同的broker。message queue用於儲存訊息的實體地址，每個topic中的訊息位址儲存於多個message queue中。consumergroup由多個consumer例項構成。

訊息生產者。負責生產訊息，一般由業務系統負責生產訊息。乙個訊息生產者會把業務應用系統裡產生的訊息傳送到broker伺服器。rocketmq提供多種傳送方式，同步傳送、非同步傳送、順序傳送、單向傳送。同步和非同步方式均需要broker返回確認訊息，單向傳送不需要。

訊息消費者。負責消費訊息，一般是後台系統負責非同步消費。乙個訊息消費者會從broker伺服器拉取訊息、並將其提供給應用程式。從使用者應用的角度而言提供了兩種消費形式：拉取式消費、推送式消費。