一個(gè)完善的消息中間件，監(jiān)控是必不可少的功能。通過監(jiān)控我們可以查看系統(tǒng)的運(yùn)行情況，是否出現(xiàn)異常，是系統(tǒng)穩(wěn)定性和運(yùn)維的基礎(chǔ)。 1、監(jiān)控平臺搭建 下載地址：https://gith...
發(fā)簡信
IP屬地：海南
-
RocketMQ運(yùn)維監(jiān)控 -
RocketMQ刷盤策略
我們都知道RocketMQ的消息是持久化到文件的，具體的消息的刷盤策略是什么，是發(fā)送一條消息就直接持久化到文件中嗎？作為一款高性能的消息中間件這樣做肯定不行，至少性能上不允許...
-
RocketMQ消息重試
RocketMQ為了保證消息被消費(fèi)采用ACK確認(rèn)機(jī)制，消費(fèi)者消費(fèi)消息時(shí)需要給Broker反饋消息消費(fèi)的情況，成功或失敗，對于失敗的消息會(huì)根據(jù)內(nèi)部算法一段時(shí)間后重新消費(fèi)。會(huì)一直...
-
RocketMQ內(nèi)存映射前面幾節(jié)我們講解的都是RocketMQ應(yīng)用層面也有一些關(guān)于源碼的分析講解，消息的存儲只是簡單的分析沒有深入的探討其中的內(nèi)部機(jī)制，我們都知道RocketMQ是基于文件存儲的消息...
-
RocketMQ權(quán)限控制
RocketMQ作為一款優(yōu)秀的中間件，應(yīng)用領(lǐng)域非常廣泛，金融、電商、電信、醫(yī)療、社科、安保等不同的領(lǐng)域都有其大規(guī)模的應(yīng)用，無疑安全性很受質(zhì)疑，因?yàn)閮?nèi)部沒有安全相關(guān)的業(yè)務(wù)模塊，...
-
RocketMQ主從同步RocketMQ作為一款優(yōu)秀的分布式消息中間件，分布式系統(tǒng)的一個(gè)很重要的特點(diǎn)就是要保證系統(tǒng)的高可用(HA)，RocketMQ則是通過主從同步機(jī)制保證系統(tǒng)的高可用。 1、概述 ...
-
RocketMQ事務(wù)消息在微服務(wù)架構(gòu)中，隨著服務(wù)的逐步拆分，數(shù)據(jù)庫私有已經(jīng)成為共識，這也導(dǎo)致所面臨的分布式事務(wù)問題成為微服務(wù)落地過程中一個(gè)非常難以逾越的障礙，但是目前尚沒有一個(gè)完整通用的解決方案。為...
-
RocketMQ消息過濾消息過濾包括基于表達(dá)式過濾與基于類模式兩種過濾模式。其中表達(dá)式過濾又分為TAG和SQL92模式，分別介紹各自的過濾機(jī)制，及代碼示例內(nèi)容，深入探消息過濾的原理。 1、TAG模式...
-
RocketMQ存儲文件
RocketMQ存儲路徑默認(rèn)是${ROCKRTMQ_HOME}/store,主要存儲消息、主題對應(yīng)的消息隊(duì)列的索引等。 1、概述 查看其目錄文件 commitlog:消息的存...
-
RocketMQ延遲消息
延時(shí)消息即消息發(fā)送后并不立即對消費(fèi)者可見，而是在用戶指定的時(shí)間投遞給消費(fèi)者。比如我們現(xiàn)在發(fā)送一條延時(shí)30秒的消息，消息發(fā)送后立即發(fā)送給服務(wù)器，但是服務(wù)器在30秒后才將該消息交...
-
RocketMQ推拉模式
消費(fèi)者客戶端有兩種方式從消息中間件獲取消息并消費(fèi)。嚴(yán)格意義上來講，RocketMQ并沒有實(shí)現(xiàn)PUSH模式，而是對拉模式進(jìn)行一層包裝，名字雖然是 Push 開頭，實(shí)際在實(shí)現(xiàn)時(shí)，...
-
RocketMQ消費(fèi)位置
RocketMQ創(chuàng)建消費(fèi)者的時(shí)指定了Topic主題及Tag,我們發(fā)現(xiàn)新創(chuàng)建的消費(fèi)者消費(fèi)不了歷史的數(shù)據(jù)，只能消費(fèi)掉創(chuàng)建以后消費(fèi)者發(fā)送的數(shù)據(jù)。這是什么原因，我們能把所有的消息都消...
-
RocketMQ消費(fèi)模式RocketMQ提供兩種消費(fèi)策略CLUSTERING集群消費(fèi)(默認(rèn))和BROADCASTING廣播消費(fèi)，在創(chuàng)建Consumer消費(fèi)者時(shí)可以指定消費(fèi)策略，策略不同其內(nèi)部機(jī)制也不...
-
RocketMQ順序消息我們知道消息隊(duì)列的特性導(dǎo)致其消息不是順序進(jìn)行消費(fèi)的，RocketMQ沒有提供所謂的順序消息來供我們使用，但是有時(shí)候一些場景需要需要順序的去接收消息。今天我們重點(diǎn)討論一下如何實(shí)...
-
RocketMQ安裝部署
準(zhǔn)備 操作系統(tǒng)：CentOS-6.9-x86_64-bin-DVD1.iso 依賴環(huán)境：gcc 4.4.7.rar、jdk-8u121-linux-x64.tar.gz 安裝...
-
RocketMQ快速入門本章簡單講講RocketMQ的入門操作，消息發(fā)送和消息接收。 引入 rocketmq-client 編寫Producer 查看結(jié)果 編寫Consumer 查看結(jié)果 看到消費(fèi)的...
-
RocketMQ簡單介紹一、簡介 RocketMQ是阿里開源的一款分布式消息中間件，滿足線上海量消息堆積的需求， 在2016年底捐贈(zèng)給Apache開源基金會(huì)成為孵化項(xiàng)目，2017年正式成為了Apac...
-
30個(gè)適合摘抄的句子，文藝且悲涼（已更新）以前養(yǎng)成的一個(gè)習(xí)慣，只要是喜歡的句子都會(huì)找一個(gè)特定的本子記下來，但覺得自己的字著實(shí)難看，無法寫出那些句子的靈魂，漸漸的，也偷了個(gè)懶，存到了備忘錄或者用說說記錄。 以下是我無聊...
