1. 程式人生 > >消息隊列(二)RocketMQ介紹

消息隊列(二)RocketMQ介紹

封裝 rgb llc ron adding consumer add 生產 提交

RocketMQ介紹

基於發布訂閱的隊列模型消息中間件,服務端使用JAVA編寫,客戶端支持JAVA、C++。阿裏2012年開源,之後作為Apache基金會的一個項目進行維護。是一款低延遲、高可靠、可伸縮、易於使用的中間件。在Github上有相關介紹。

支持的部署架構


角色說明

角色
說明
Producer
生產者,用於將消息發送到MQ,生產者本身既可以是生成消息,也可以對外提供接口,由外部來調用接口,再由生產者將受到的消息發送給MQ。
Producer Group
生產者組,將同樣角色生產者分組在一起。同一生產組的不同生產者實例都會被Broker告知提交或者回滾事務
Consumer

消費者,從Broker拉取消息進行消費。從應用角度來說有兩類消費者:

  • PullConsumer:主動拉取消息,一旦拉取到消息,應用的消費進程進行初始化

  • PushConsumer:封裝消息拉取,消費進程和內部







應用場景


消息隊列(二)RocketMQ介紹