消費(fèi)者從Broker中獲取消息的方式有兩種：pull拉取方式和push推動(dòng)方式。消費(fèi)者組對(duì)于消息消費(fèi)的模式又分為兩種：集群消費(fèi)Clustering和廣播消費(fèi)Broadcast...
發(fā)簡(jiǎn)信
IP屬地：澳門(mén)
-
RocketMQ(十)——消息的消費(fèi) -
理論上是這樣的，但一般來(lái)說(shuō)，master使用raid鏡像策略，slave就不必再使用了。
RocketMQ(六)——集群搭建理論
1.數(shù)據(jù)復(fù)制與刷盤(pán)策略 復(fù)制策略復(fù)制策略是Broker得Master與Slave間得數(shù)據(jù)同步方式。分為同步復(fù)制與異步復(fù)制： 同步復(fù)制：消息寫(xiě)入master后，master會(huì)等...
-
主從和RAID10解決的是不同問(wèn)題，主從是多機(jī)器下的一種集群模式，目的是為了分擔(dān)單節(jié)點(diǎn)的壓力，提高系統(tǒng)性能。RAID10是單個(gè)服務(wù)器的磁盤(pán)存儲(chǔ)策略，防止出現(xiàn)某塊磁盤(pán)不可用導(dǎo)致數(shù)據(jù)丟失的問(wèn)題，旨在保證數(shù)據(jù)可靠性
RocketMQ(六)——集群搭建理論
1.數(shù)據(jù)復(fù)制與刷盤(pán)策略 復(fù)制策略復(fù)制策略是Broker得Master與Slave間得數(shù)據(jù)同步方式。分為同步復(fù)制與異步復(fù)制： 同步復(fù)制：消息寫(xiě)入master后，master會(huì)等...
-
RocketMQ(九)——indexFile除了通過(guò)通常的指定Topic進(jìn)行消息消費(fèi)外，rocketMQ還提供了根據(jù)Key進(jìn)行查詢的功能。該查詢是通過(guò)store目錄中的index子目錄中的indexFile進(jìn)行索引實(shí)現(xiàn)...
-
RocketMQ(八)——消息的存儲(chǔ)RocketMQ中的消息存儲(chǔ)在本地文件系統(tǒng)中，這些相關(guān)文件默認(rèn)在當(dāng)前用戶主目錄下的store目錄中。 abort：該文件在Broker啟動(dòng)后會(huì)自動(dòng)創(chuàng)建，正常關(guān)閉Broker，...
-
RocketMQ(七)——消息的生產(chǎn)
1.消息的生產(chǎn)過(guò)程 Producer可以將消息寫(xiě)入到某Broker中的某Queue中，經(jīng)歷的如下過(guò)程： Producer發(fā)送消息之前，會(huì)先向NameServer發(fā)出獲取消息T...
-
RocketMQ(擴(kuò)展)——磁盤(pán)陣列RAID1.RAID歷史 1988 年美國(guó)加州大學(xué)伯克利分校的 D. A. Patterson 教授等首次在論文 “A Case of Redundant Array of Inex...
-
RocketMQ(六)——集群搭建理論1.數(shù)據(jù)復(fù)制與刷盤(pán)策略 復(fù)制策略復(fù)制策略是Broker得Master與Slave間得數(shù)據(jù)同步方式。分為同步復(fù)制與異步復(fù)制： 同步復(fù)制：消息寫(xiě)入master后，master會(huì)等...
-
RocketMQ(五)——控制臺(tái)安裝與啟動(dòng)RocketMQ有一個(gè)可視化的的dashboard，通過(guò)該控制臺(tái)可以直觀的看到很多數(shù)據(jù) 1.下載 下載地址：https://github.com/apache/rocketm...
-
RocketMQ(四)——安裝與啟動(dòng)1.環(huán)境準(zhǔn)備 2.下載 下載地址：https://rocketmq.apache.org/[https://rocketmq.apache.org/] 我下載的是4.9.2版...
-
RocketMQ(三)——系統(tǒng)架構(gòu)RocketMQ架構(gòu)上主要分為四部分構(gòu)成： 1.Producer 消息生產(chǎn)者，負(fù)責(zé)生產(chǎn)消息。Producer通過(guò)MQ的負(fù)載均衡模塊選擇相應(yīng)的Broker集群隊(duì)列進(jìn)行消息投遞，...
-
RocketMQ(二)——基本概念1.消息(Message) 消息是指，消息系統(tǒng)所傳出信息的物理載體，生產(chǎn)和消費(fèi)數(shù)據(jù)的最小單位，每條消息必須屬于一個(gè)主題 2.主題(Topic) Topic表示一類(lèi)消息的集合，...
-
RocketMQ(一)——概述
由于之前整理過(guò)activeMQ的文章，關(guān)于MQ的概述就不詳細(xì)介紹了MQ的作用①限流削峰②異步解耦③數(shù)據(jù)收集 1.MQ常見(jiàn)協(xié)議 一般情況下MQ的實(shí)現(xiàn)是要遵循一些常規(guī)性協(xié)議的。常...
-
SpringCloud(46)——Seata1.Seata模式 Seata有四種模式 有AT、TCC、SAGA、XA模式我們?cè)跍y(cè)試時(shí)候使用的是AT模式 2.Seata組件 Seata有三個(gè)組件，TC、TM、RM，那么我...
-
SpringCloud(45)——Seata的使用環(huán)境準(zhǔn)備 我們準(zhǔn)備好三個(gè)服務(wù) 訂單服務(wù)Order-Module庫(kù)存服務(wù)Storage-Module賬戶服務(wù)Account-Module 業(yè)務(wù)需求：下訂單->減庫(kù)存->扣余額-...
-
SpringCloud(44)——Seata數(shù)據(jù)庫(kù)環(huán)境準(zhǔn)備1.分布式事務(wù)業(yè)務(wù)說(shuō)明 這里我們會(huì)創(chuàng)建三個(gè)服務(wù)，一個(gè)訂單服務(wù)，一個(gè)庫(kù)存服務(wù)，一個(gè)賬戶服務(wù)。 當(dāng)用戶下單時(shí)，會(huì)在訂單服務(wù)中創(chuàng)建一個(gè)訂單，然后通過(guò)遠(yuǎn)程調(diào)用庫(kù)存服務(wù)來(lái)扣減下單商品的...
-
SpringCloud(43)——Seata簡(jiǎn)介與安裝1.分布式事務(wù)的問(wèn)題 當(dāng)我們的單體應(yīng)用被拆分成微服務(wù)應(yīng)用，原來(lái)的三個(gè)模塊被拆分成三個(gè)獨(dú)立的應(yīng)用，分別使用三個(gè)獨(dú)立的數(shù)據(jù)源，業(yè)務(wù)需要調(diào)用三個(gè)服務(wù)來(lái)完成。例如：下訂單的操作需要不...
-
SpringCloud(42)——Sentinel持久化1.問(wèn)題描述 經(jīng)過(guò)我們多次的測(cè)試發(fā)現(xiàn)，一旦重啟服務(wù)后，sentinel配置的規(guī)則就被初始化了，需要我們重新再配置，如果上生產(chǎn)環(huán)境的話肯定需要持久化的。 2.持久化效果 例如我...
-
SpringCloud(41)——Sentinel自定義回滾方法配置我們都知道Sentinel默認(rèn)的回滾提示是Blocked by Sentinel而且我也給大家演示了如何寫(xiě)自定義的回滾方法。 但是這樣寫(xiě)還有一些問(wèn)題：①依照現(xiàn)有條件，我們自定...
-
SpringCloud(40)——Sentinel熱點(diǎn)Key什么是熱點(diǎn)？我們看一下官網(wǎng)的解釋 我個(gè)人理解，之前的流控和降級(jí)是針對(duì)接口級(jí)別來(lái)進(jìn)行限流的，而熱點(diǎn)可以做到更細(xì)粒度的限流，從參數(shù)的角度來(lái)進(jìn)行限流。 回滾方法之前的case，當(dāng)觸...