訊息佇列(三)RocketMQ如何儲存訊息

2021-09-20 16:28:55 字數 516 閱讀 8792

rocket的訊息是有consume queue和commit log組成。

consume queue

consume queue是訊息的邏輯佇列,相當於字典目錄,用來指定訊息在物理檔案(commit log)上的位置,我們可以在配置中指定consumequeue和commitlog儲存的目錄。每乙個topic下的每個queue都有乙個對應的consumqueue檔案。

consume queue中的儲存單元是20位元組長度的二進位制資料,順序讀寫

訊息存放的物理檔案,每台broker上的commit log被本機所有的queue共享不做任何區分。訊息儲存內容長度不固定,檔案順序寫,隨機讀。

rocketmq 訊息佇列

rocketmq 是乙個分布式的訊息佇列,主要有product,broker,consumer,nameserver組成,提供流量的削峰填谷,非同步通知,應用解耦的功能。rocketmq和kafka功能上比較相似,但是在底層架構上還是有很多不同,比如kafka中每個topic下的每個partitio...

訊息佇列之RocketMq

rocketmq 是阿里巴巴在2012年開源的分布式訊息中介軟體,有點什麼的就不多說了,就直接將怎麼用。rocketmq大概就是真麼一種結構,具體的使用流程就是,訊息生產者 producer 將訊息發布到訊息中心,消費者 consumer 啟動監聽,當監聽到訊息時去訊息中心拿訊息。而nameserv...

訊息佇列 RocketMQ 01

訊息佇列中介軟體是分布式系統中重要的元件,它主要解決的問題是 應用解耦 非同步訊息 流量削鋒等問題。實現高效能,高可用,可伸縮和最終一致性架構。目前使用較多的訊息佇列有 activemq rabbitmq zeromq kafka metamq rocketmq等。訊息即資料。一般訊息的體量不會很大...