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