阿里rocketmq與自建rocketmq

1、搭環境html

阿里rocketmq不用搭建,  https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.6.546.1787650eShM7hoapache

開源rocketmq(window+rocketmq)     https://www.cnblogs.com/amuge/articles/10275292.html安全

 

2、發送消息類型:多線程

 

3、名詞解釋  https://help.aliyun.com/document_detail/29533.html?spm=a2c4g.11186623.6.542.1cfa77d7wLCfvb分佈式

 消息相關名詞:spa

 Topic:消息主題 , 一級消息類型線程

 Tag:消息標籤,二級消息類型,用來進一步區分某個Topic下的消息分類htm

  Message:消息體對象

  MessageID:消息的全局惟一標識;blog

  Producer:消息生產者(消息發佈者)

  Producer實例:Producer 的一個對象實例,不一樣的 Producer 實例能夠運行在不一樣進程內或者不一樣機器上。Producer 實例線程安全,可在同一進程內多線程之間共享。

  consumer:消息消費者(消息訂閱者),負責接收消費消息

  Consumer 的一個對象實例,不一樣的 Consumer 實例能夠運行在不一樣進程內或者不一樣機器上。一個 Consumer 實例內配置線程池消費消息。

  Group 一類 Producer 或 Consumer,這類 Producer 或 Consumer 一般生產或消費同一類消息,且消息發佈或訂閱的邏輯一致。

  Group ID  Group 的標識。

  

消費相關名詞:

 集羣消費   一個 Group ID 所標識的全部 Consumer 平均分攤消費消息。例如某個 Topic 有 9 條消息,一個 Group ID 有 3 個 Consumer 實例,那麼在集羣消費模式下每一個實例平均分攤,只消費其中的 3 條消息

 廣播消費  一個 Group ID 所標識的全部 Consumer 都會各自消費某條消息一次。例如某個 Topic 有 9 條消息,一個 Group ID 有 3 個 Consumer 實例,那麼在廣播消費模式下每一個實例都會各自消費 9 條消息。

 

消息類型名詞:

定時消息  Producer 將消息發送到消息隊列 RocketMQ 服務端,但並不指望這條消息立馬投遞,而是推遲到在當前時間點以後的某一個時間投遞到 Consumer 進行消費,該消息即定時消息。

延時消息   Producer 將消息發送到消息隊列 RocketMQ 服務端,但並不指望這條消息立馬投遞,而是延遲必定時間後才投遞到 Consumer 進行消費,該消息即延時消息。

事務消息  消息隊列 RocketMQ 提供相似 X/Open XA 的分佈事務功能,經過消息隊列 RocketMQ 的事務消息能達到分佈式事務的最終一致。

 

順序消息  消息隊列 RocketMQ 提供的一種按照順序進行發佈和消費的消息類型, 分爲全局順序消息和分區順序消息。

全局順序消息   對於指定的一個 Topic,全部消息按照嚴格的先入先出(FIFO)的順序進行發佈和消費。

分區順序消息  對於指定的一個 Topic,全部消息根據 sharding key 進行區塊分區。同一個分區內的消息按照嚴格的 FIFO 順序進行發佈和消費。Sharding key 是順序消息中用來區分不一樣分區的關鍵字段,和普通消息的 key 是徹底不一樣的概念。

 

4、apache rocketmq名詞解釋

Producer  Group(生產組):相同角色組成的組

Name Server:爲producer和consumer提供路由(用戶broker發現)

Broker:提供輕量級的topic和queue機制處理消息存儲,同時支持推push和拉pull模式和主從結構的容錯機制

5、發送消息

http://rocketmq.apache.org/docs/simple-example/

http://rocketmq.apache.org/docs/order-example/

http://rocketmq.apache.org/docs/schedule-example/

http://rocketmq.apache.org/docs/transaction-example/

相關文章
相關標籤/搜索