RocketMQ介紹

RocketMQ是一款由阿里巴巴開源的分布式消息中間件。它具有低延遲、高吞吐量、高可用性和高可靠性等特點(diǎn)，適用于構(gòu)建具有海量消息堆積和異步解耦功能的應(yīng)用系統(tǒng)。

1.1.基本概念

• ? 生產(chǎn)者（Producer）：也稱為消息發(fā)布者，是RocketMQ中用來構(gòu)建并傳輸消息到服務(wù)端的運(yùn)行實(shí)體。
• ? 主題（Topic）：Topic是RocketMQ中消息傳輸和存儲(chǔ)的頂層容器，用于標(biāo)識(shí)同一類業(yè)務(wù)邏輯的消息；Topic是一個(gè)邏輯概念，并不是實(shí)際的消息容器；
• ? 消息隊(duì)列（MessageQueue）：隊(duì)列是RocketMQ中消息存儲(chǔ)和傳輸?shù)膶?shí)際容器，也是消息的最小存儲(chǔ)單元。
• ? 消費(fèi)者（Consumer）：也稱為消息訂閱者，是RocketMQ中用來接收并處理消息的運(yùn)行實(shí)體。
• ? 消費(fèi)者組（ConsumerGroup）：消費(fèi)者組是RocketMQ中承載多個(gè)消費(fèi)行為一致的消費(fèi)者負(fù)載均衡分組。和消費(fèi)者不同，消費(fèi)者組是一個(gè)邏輯概念。
• ? NameServer：可以理解成注冊(cè)中心，負(fù)責(zé)更新和發(fā)現(xiàn)Broker服務(wù)。在NameServer的集群中，NameServer與NameServer之間是沒有任何通信的，它是無狀態(tài)的。
• ? Broker：可以理解為消息中轉(zhuǎn)角色，負(fù)責(zé)消息的存儲(chǔ)和轉(zhuǎn)發(fā)，接收生產(chǎn)者產(chǎn)生的消息并持久化消息；當(dāng)用戶發(fā)送的消息被發(fā)送到Broker時(shí)，Broker會(huì)將消息轉(zhuǎn)發(fā)到與之關(guān)聯(lián)的Topic中，以便讓更多的接收者進(jìn)行處理。

1.2消息模型

1.3.部署模型

2.下載RocketMQ

RocketMQ的官網(wǎng)地址：https://rocketmq.apache.org/
Github地址：https://github.com/apache/rocketmq
下載地址：https://rocketmq.apache.org/zh/download/ 當(dāng)前最新的版本為5.1.0，本教程安裝5.1.0版本。

3.安裝RocketMQ

3.1.安裝前需要準(zhǔn)備一個(gè)CentOS7的Linux機(jī)器，使用的Linux版本如下：

uname -a

3.2.安裝JDK

推薦使用JDK1.8版本?？梢允褂谜n件資料包或者自行下載tar.gz包。

1.統(tǒng)一規(guī)劃目錄，創(chuàng)建app文件夾，在創(chuàng)建jdk文件夾，將jdk的包上載到 /app/jdk目錄下然后解壓

cd ..
mkdir app
cd app/
mkdir jdk
cd jdk/
tar -zxvf jdk-8u171-linux-x64.tar.gz

2.配置jdk環(huán)境變量，將JAVA_HOME變量加上;將path路徑替換成相應(yīng)配置

vi /etc/profile

#jdk解壓后的目錄路徑
export JAVA_HOME=/app/jdk/jdk1.8.0_171/
PATH=$JAVA_HOME/bin:$PATH:$HOME/.local/bin:$HOME/bin

3.更新配置并查看jdk版本，顯示以下信息則安裝成功。

source /etc/profile
java -version

3.3.安裝RocketMQ

3.3.1.將安裝包上傳到/app/rocketMQ目錄下

# 先在app目錄下創(chuàng)建rocketMQ文件夾
cd ..
mkdir rocketMQ

# 上傳到/app/rocketMQ目錄然后解壓（也可以先解壓在上傳，推薦上傳后解壓）
cd rocketMQ/
unzip rocketmq-all-5.1.0-bin-rease.zip

3.3.2 配置rocketMQ環(huán)境變量

#將ROCKETMQ_HOME變量加上，在path路徑加上$ROCKETMQ_HOME/bin:

vi /etc/profile
#rocketMQ路徑
export ROCKETMQ_HOME=/app/rocketMQ/rocketmq-all-5.1.0-bin-rease
export PATH=$ROCKETMQ_HOME/bin:JAVA_HOME/bin:$PATH:$HOME/.local/bin:$HOME/bin
#namesrc后續(xù)broker會(huì)使用到，先加上
export NAMESRC_ADDR='woker1:9876;worker2:9876;worker3:9876'

3.3.3 更新配置

source /etc/profile

ROCKETMQ_HOME的環(huán)境變量是必須要單獨(dú)配置的，如果不配置的話，啟動(dòng)NameSever和Broker都會(huì)報(bào)錯(cuò)。這個(gè)環(huán)境變量的作用是用來加載$ROCKETMQ_HOME/conf下的除broker.conf以外的幾個(gè)配置文件。所以實(shí)際情況中，可以不按這個(gè)配置，但是一定要能找到配置文件。這樣RocketMQ就安裝完成了。

3.4.RocketMQ工作原理

官網(wǎng)5.0版本速覽鏈接：https://rocketmq.apache.org/zh/version/

RocketMQ5.0 引入了全新的彈性無狀態(tài)代理模式，將當(dāng)前的Broker職責(zé)進(jìn)行拆分，對(duì)于客戶端協(xié)議適配、權(quán)限管理、消費(fèi)管理等計(jì)算邏輯進(jìn)行抽離，獨(dú)立無狀態(tài)的代理角色提供服務(wù)，Broker則繼續(xù)專注于存儲(chǔ)能力的持續(xù)優(yōu)化。值得注意的是RocketMQ 5.0的全新模式是和4.0的極簡架構(gòu)模式相容相通的，5.0的代理架構(gòu)完全可以以Local模式運(yùn)行，實(shí)現(xiàn)與4.0架構(gòu)完全一致的效果。開發(fā)者可以根據(jù)自身的業(yè)務(wù)場(chǎng)景自由選擇架構(gòu)部署，本教程也是部署的Local模式。

RocketMQ啟動(dòng)流程如下：

• ? 啟動(dòng)NameServer
• ? 啟動(dòng)Broker

3.5 NameServer服務(wù)搭建

啟動(dòng)NameServer非常簡單，在$ROCKETMQ_HOME/bin目錄下有個(gè)mqnamesrv。直接執(zhí)行這個(gè)腳本就可以啟動(dòng)RocketMQ的NameServer服務(wù)。
由于RocketMQ默認(rèn)預(yù)設(shè)的JVM內(nèi)存是4G，這是RocketMQ給我們的最佳配置。但是通常我們用虛擬機(jī)的話都是不夠4G內(nèi)存的，所以需要調(diào)整下JVM內(nèi)存大小。修改的方式是直接修改runserver.sh。

3.5.1 修改NameServer啟動(dòng)配置

cd rocketmq-all-5.1.0-bin-release/bin/
vi runserver.sh
# 將JAVA_OPT="${JAVA_OPT} -Server-Xms4g -Xmx4g -Xmn2g 修改為 -server Xms512m -Xmx512m -Xmn256m"

3.5.2 啟動(dòng)NameServer

NameServer的配置修改完成，然后我們用靜默啟動(dòng)的方式啟動(dòng)NameServer服務(wù)，啟動(dòng)完成后在nohup.out里看到這一條關(guān)鍵日志就是啟動(dòng)成功。并且使用jps指令可以看到有一個(gè)NamesrvStartup進(jìn)程。

#靜默啟動(dòng)
nohup ./mqnamesrc &

#查看日志
tail -f nohup.out

3.6 Broker服務(wù)搭建

啟動(dòng)Broker的腳本是runbroker.sh。Broker的默認(rèn)預(yù)設(shè)內(nèi)存是8G，啟動(dòng)前，如果內(nèi)存不夠，同樣需要調(diào)整下JVM內(nèi)存。修改的方式是直接修改runbroker.sh。

3.6.1 修改broker啟動(dòng)腳本配置

vi runbroker.sh
#將JAVA_OPT="${JAVA_OPT} -server Xms8g -Xmx8g" 修改為JAVA_OPT="${JAVA_OPT} -server Xms512m -Xmx512m"

3.6.2 修改broker配置文件

#修改Broker資源配置文件，允許自動(dòng)創(chuàng)建Topic
cd ../conf/
vi broker.conf

#允許自動(dòng)創(chuàng)建topic
autoCreateTopicEnable=true
#添加nameserver地址
namesrvAddr=localhost:9876

3.6.3 啟動(dòng)broker服務(wù)

Broker的配置修改完成，然后我們用靜默啟動(dòng)的方式啟動(dòng)Broker服務(wù)，同樣是檢查nohup.out日志, 并且jps指令可以看到一個(gè)BrokerStartup進(jìn)程。

1.回到bin目錄下，靜默啟動(dòng)Broker
cd ../bin
nohup ./mqbroker -c ../conf/broker.conf &
2.查看日志，顯示如下即顯示成功********每次啟動(dòng)broker時(shí)都要關(guān)注是否注冊(cè)到目標(biāo)nameserver上（name server isworker：9876）
tail -f nohup.out
jps

3.7 測(cè)試RocketMQ消息發(fā)送與消費(fèi)

在RocketMQ的安裝包中，提供了一個(gè)tools.sh工具可以用來在命令行快速驗(yàn)證RocketMQ服務(wù)。

1.我們?cè)赽in錄下執(zhí)行以下命令測(cè)試消息發(fā)送，默認(rèn)會(huì)發(fā)1000條消息，發(fā)送完成自動(dòng)關(guān)閉

export NAMESRV_ADDR=‘localhost:9876’
./tools.sh org.apache.rocketmq.example.quickstart.Producer

2.出現(xiàn)以下提示則代表消息發(fā)送成功

3 執(zhí)行一下命令測(cè)試消息接收，Consumer執(zhí)行不會(huì)自動(dòng)關(guān)閉，會(huì)一直掛起等待新消息過來

export NAMESRV_ADDR=‘localhost:9876’
./tools.sh org.apache.rocketmq.example.quickstart.Consumer

4 出現(xiàn)以下提示則代表消息接收成功

3.8 關(guān)閉RocketMQ服務(wù)

在bin目錄下通過腳本關(guān)閉服務(wù)

1 關(guān)閉Broker

sh ./mqshutdown broker

2 關(guān)閉NameServer

sh ./mqshutdown namesrv

3 查看服務(wù)

?

閱讀原文：https://mp.weixin.qq.com/s/NyBCC2E3EfCEuHRuGFtTiw