1、介紹
RocketMQ是一款分佈式、隊列模型的消息中間件,支持集羣模式、消費者負載均衡,提供了豐富的消息機制。
2、安裝
1.JDK安裝
安裝過程見:http://www.javashuo.com/article/p-pkoyeeqb-ve.html
2.獲取安裝包
wget https://archive.apache.org/dist/rocketmq/4.5.2/rocketmq-all-4.5.2-bin-release.zip
3.解壓
unzip rocketmq-all-4.5.2-bin-release.zip
mv rocketmq-all-4.5.2-bin-release /usr/local/
4.建立軟連接
ln -s /usr/local/rocketmq-all-4.5.2-bin-release/ /usr/local/rockermq
5.建立日誌目錄
/usr/local/rocketmq/store/{commitlog,consumequeue,index,abort}
touch checkpoint
6.配置環境變量
vim /etc/profilejava
ROCKETMQ_HOME=/usr/local/rocketmq PATH=$PATH:$ROCKETMQ_HOME/bin
7.使環境變量生效
source /etc/profile
8.修改配置
vim /usr/local/rocketmq/conf/2m-2s-sync/broker-a.propertiesgit
#所屬集羣名字 brokerClusterName=rocketmq-cluster #broker名字,注意此處不一樣的配置文件填寫的不同 brokerName=broker-a #0 表示 Master,>0 表示 Slave brokerId=0 #nameServer地址,分號分割 namesrvAddr=172.16.120.101:9876;172.16.120.102:9876 #在發送消息時自動建立服務器不存在的topic,默認建立的隊列數 defaultTopicQueueNums=4 #是否容許 Broker 自動建立Topic,建議線下開啓,線上關閉 autoCreateTopicEnable=false #是否容許 Broker 自動建立訂閱組,建議線下開啓,線上關閉 autoCreateSubscriptionGroup=false #Broker 對外服務的監聽端口 listenPort=10911 haListenPort=10912 #刪除文件時間點,默認凌晨 4點 deleteWhen=04 #文件保留時間,默認 48 小時 fileReservedTime=18 #commitLog每一個文件的大小默認1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue每一個文件默認存30W條,根據業務狀況調整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #檢測物理文件磁盤空間 diskMaxUsedSpaceRatio=88 #存儲路徑 storePathRootDir=/usr/local/rocketmq/store #commitLog 存儲路徑 storePathCommitLog=/usr/local/rocketmq/store/commitlog #消費隊列存儲路徑存儲路徑 storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue #消息索引存儲路徑 storePathIndex=/usr/local/rocketmq/store/index #checkpoint 文件存儲路徑 storeCheckpoint=/usr/local/rocketmq/store/checkpoint #abort 文件存儲路徑 abortFile=/usr/local/rocketmq/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 異步複製Master #- SYNC_MASTER 同步雙寫Master #- SLAVE brokerRole=SYNC_MASTER #刷盤方式 #- ASYNC_FLUSH 異步刷盤 #- SYNC_FLUSH 同步刷盤 flushDiskType=ASYNC_FLUSH #checkTransactionMessageEnable=false #發消息線程池數量 #sendMessageThreadPoolNums=128 #拉消息線程池數量 #pullMessageThreadPoolNums=128 #強制指定本機IP,須要根據每臺機器進行修改。官方介紹可爲空,系統默認自動識別,但多網卡時IP地址可能讀取錯誤 brokerIP1=172.16.120.101
注:slave須要在broker-a-s.properties配置文件中修改以下三行
brokerName=broker-a #注意這一行的名稱要和master的保持一致
brokerId=1 #這個ID要跟master的不一致
brokerRole=SLAVE #要配置爲從
9.內存設置(根據實際內存配置)
#nameserver
vim /usr/local/rocketmq/bin/runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
#broker
vim /usr/local/rocketmq/bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512g"
10.啓動服務
nohup mqnamesrv &
nohup mqbroker -c /usr/local/rocketmq/conf/2m-2s-sync/broker-a.properties &
11.中止服務
mqshutdown namesrv
mqshutdown broker
3、控制檯部署
1.獲取安裝包
git clone https://github.com/apache/rocketmq-externals.git
2.修改配置
cd cd rocketmq-externals/rocketmq-console/
vim src/main/resources/application.propertiesgithub
server.port=8088 rocketmq.config.namesrvAddr=172.16.120.101:9876
3.編譯
mvn clean package -Dmaven.test.skip=true
4.啓動服務
nohup java -jar -Xms1g -Xmx1g rocketmq-console-ng-1.0.1.jar &
5.驗證
訪問:http://172.16.120.101:8088apache