一、RocketMQ 1、架構(gòu)圖片 2、角色分類 (1)、Broker RocketMQ 的核心,接收 Producer 發(fā)過(guò)來(lái)的消息、處理 Consumer 的消費(fèi)消息請(qǐng)求、消息的持 久化存儲(chǔ)、
RocketMQ消息隊(duì)列,專業(yè)消息中間件,既可為分布式應(yīng)用系統(tǒng)提供異步解耦和削峰填谷的能力,同時(shí)也具備互聯(lián)網(wǎng)應(yīng)用所需的海量消息堆積、高吞吐、可靠重試等特性,是應(yīng)對(duì)企業(yè)業(yè)務(wù)峰值時(shí)刻必備的技術(shù)。云片由于業(yè)
RocketMQ本文檔主要是rocketmq實(shí)際代碼使用,常見詞語(yǔ)介紹等查看其他文檔一 下載http://rocketmq.apache.org/release_notes/release-notes
“得益于MQ削峰填谷,系統(tǒng)解耦,操作異步等功能特性,在互聯(lián)網(wǎng)行業(yè),可以說(shuō)有分布式服務(wù)的地方,MQ都往往不會(huì)缺席?!庇砂⒗镒匝械腞ocketMQ更是經(jīng)歷了多年的雙十一高并發(fā)挑戰(zhàn),其中4.3.0版本推出了
前言 我們都知道,RocketMQ在代碼級(jí)別對(duì)連接服務(wù)器進(jìn)行了限制,基本上可以理解為一個(gè)JVM進(jìn)程中只能連接一個(gè)NameServer,但實(shí)際應(yīng)用場(chǎng)景中,我們可能會(huì)在架構(gòu)設(shè)計(jì)層面上對(duì)RocketMQ進(jìn)行
一、最近公司在做隊(duì)列的技術(shù)選型,經(jīng)過(guò)調(diào)研,決定使用rocketmq作為整個(gè)架構(gòu)的隊(duì)列層,我們之前的公司是用RabbitMQ,集群部署參考我之前的文章:RabbitMQ集群部署;rocketmq集群由N
說(shuō)在前面 RocketMQ在底層存儲(chǔ)上借鑒了Kafka,但是也有它獨(dú)到的設(shè)計(jì),本文主要關(guān)注深刻影響著RocketMQ性能的底層文件存儲(chǔ)結(jié)構(gòu),中間會(huì)穿插一點(diǎn)點(diǎn)Kafka的東西以作為對(duì)比。 例子 Comm
說(shuō)在前面 Apache RocketMQ-4.3.0正式Release了事務(wù)消息的特性,順著最近的這個(gè)熱點(diǎn)。第一篇文章,就來(lái)聊一下在軟件工程學(xué)上的長(zhǎng)久的難題——分布式事務(wù)(Distributed Tr
引入MQ后的架構(gòu)演進(jìn) MQ的選擇 消息隊(duì)列對(duì)比參照表: RocketMQ vs. ActiveMQ vs. Kafka: 參考至: 消息隊(duì)列對(duì)比參照表 RocketMQ vs. ActiveMQ
消息過(guò)濾 消息過(guò)濾是指消費(fèi)者不希望消費(fèi)topic里的所有消息,而是只消費(fèi)部分特定的消息。從topic中挑選出這些特定的消息,就是所謂的消息過(guò)濾。通過(guò)消息過(guò)濾可以實(shí)現(xiàn)消息的分流處理,例如生產(chǎn)者生產(chǎn)的消息