下載和構(gòu)建

配置環(huán)境變量
在/etc/profile最后添加

JAVA_HOME=/soft/jdk1.8.0_111
MAVEN_HOME=/soft/maven/apache-maven-3.5.3

CLASSPATH=.:$JAVA_HOME/lib.tools.jar
PATH=$JAVA_HOME/bin:$MAVEN_HOME/bin:$PATH
export JAVA_HOME MAVEN_HOME CLASSPATH PATH     

export rocketmq=/soft/RocketMQ/rocketmq-rocketmq-all-4.2.0/distribution/target/apache-rocketmq

使變量生效
. /etc/profile

從 https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip 下載 4.2.0 的源碼版本仅颇，執(zhí)行以下命令來解壓4.2.0源碼版本并構(gòu)建二進(jìn)制文件忘瓦。

unzip rocketmq-all-4.2.0-source-release.zip

cd rocketmq-all-4.2.0/

mvn -Prelease-all -DskipTests clean install -U

構(gòu)建成功

linux下RocketMQ的安裝

由于可能會(huì)提示內(nèi)存不足
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)

調(diào)整一下 /soft/RocketMQ/rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin目錄下的
runbroker.sh 和 runserver.sh的參數(shù)

vi runbroker.sh/
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m"
JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=256m"

vi runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m"

進(jìn)入到目錄 ：
cd distribution/target/apache-rocketmq/bin

這里需要構(gòu)建一個(gè)存放log的目錄 /soft/RocketMQ/rocketmqlogs

啟動(dòng)nameserver
nohup sh mqnamesrv >/soft/RocketMQ/rocketmqlogs/mqnamesrv.log 2>&1 &

啟動(dòng)broker
nohup sh mqbroker -n localhost:9876 >/soft/RocketMQ/rocketmqlogs/broker.log 2>&1 &

按照模版啟動(dòng)境蜕，模版的新建在文章最后凌停，可以解決api連不上的問題
nohup sh mqbroker -c broker.p -n localhost:9876 >/soft/RocketMQ/rocketmqlogs/broker.log 2>&1 &

linux下RocketMQ的安裝

出現(xiàn)這樣就是成功

linux下RocketMQ的安裝

發(fā)送和接收消息
在發(fā)送/接收消息之前台诗，我們需要告訴客戶名稱服務(wù)器的位置赐俗。RocketMQ 提供了多種方法來實(shí)現(xiàn)這一點(diǎn)。為了簡(jiǎn)單起見粱快，我們使用環(huán)境變量NAMESRV_ADDR

發(fā)送消息：

export NAMESRV_ADDR=localhost:9876

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

linux下RocketMQ的安裝

接收消息

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

linux下RocketMQ的安裝

關(guān)閉服務(wù)器

sh bin/mqshutdown broker    //停止 broker

sh bin/mqshutdown namesrv   //停止 nameserver

linux下RocketMQ的安裝

幾個(gè)常用的命令
上面幾個(gè)啟動(dòng)和關(guān)閉 name server 和 broker 的就不再說了，

查看集群情況 ./mqadmin clusterList -n 127.0.0.1:9876
查看 broker 狀態(tài) ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911 (注意換成你的 broker 地址)
查看 topic 列表 ./mqadmin topicList -n 127.0.0.1:9876
查看 topic 狀態(tài) ./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (換成你想查詢的 topic)
查看 topic 路由 ./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic

===================================================================
安裝web可視化客戶端

1.下載文件(/usr/local目錄下)
https://github.com/apache/rocketmq-externals 地址下載并從本地上傳到服務(wù)器

2.解壓(/usr/local目錄下)

yum install -y unzip zip 前提是：unzip解壓文件無法使用

unzip rocketmq-externals-master.zip 解壓文件

3.修改配置文件(usr/local/rocketmq-externals-master/目錄下)

find -name application.properties 可以查看到兩個(gè)文件都在rocketmq-console文件目錄下

vim application.properties

rocketmq.config.namesrvAddr=192.168.143.128:9876（ip1:port;ip2:port）

4.編譯(usr/local/rocketmq-externals-master/rocketmq-console/目錄下)

mvn clean package -Dmaven.test.skip=true 如果失敗多編譯幾次--可能是網(wǎng)絡(luò)問題

linux下RocketMQ的安裝

編譯成功后，在rocketmq-console目錄下會(huì)生成一個(gè)目錄：target目錄流炕，該目錄下有啟動(dòng)rocketmq界面的jar文件

5.啟動(dòng)web(usr/local/rocketmq-externals-master/rocketmq-console/target目錄下)

java -jar rocketmq-console-ng-1.0.0.jar 啟動(dòng) ---當(dāng)終端斷了該服務(wù)就會(huì)停止

nohup java -jar rocketmq-console-ng-1.0.0.jar >>/soft/RocketMQ/rocketmqlogs/log.out 2>&1 &
后臺(tái)啟動(dòng) --當(dāng)終端斷了也不會(huì)停止服務(wù)

linux下RocketMQ的安裝

說明啟動(dòng)成功

http://192.168.143.128:8080

linux下RocketMQ的安裝

==================================================================

用java代碼實(shí)現(xiàn)API的過程中需要注意的幾個(gè)問題

1、出現(xiàn)connect to 172.17.42.1:10909 failed
原因分析：我第一次使用的是rocketmq-client-3.4.6干旧，第二次使用的是rocketmq-client-3.5.7椎眯，都出現(xiàn)了這個(gè)問題。但是原來使用rocketmq-client-3.2.5卻不會(huì)出現(xiàn)這個(gè)問題舔稀。
（1）目前這種寫法Rocket默認(rèn)開啟了VIP通道掌测，VIP通道端口為10911-2=10909。若Rocket服務(wù)器未啟動(dòng)端口10909夜郁，則報(bào)connect to <：10909> failed拂酣。
（2）解決方式：增加一行代碼
producer.setVipChannelEnabled(false);

linux下RocketMQ的安裝

2婶熬、出現(xiàn)connect to 172.17.42.1:10911 failed
還是外網(wǎng)內(nèi)網(wǎng)ip的問題
最后經(jīng)過多方搜索,在官方的用戶說明里看到下面的方法
在bin目錄下面配置模版

linux下RocketMQ的安裝

修改后的broker.p文件

namesrvAddr=127.0.0.1:9876
brokerIP1=192.168.143.128
brokerName=localhost
brokerClusterName=DefaultCluster
brokerId=0
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
rejectTransactionMessage=false
fetchNamesrvAddrByAddressServer=false
storePathRootDir=/root/store
storePathCommitLog=/root/store/commitlog
flushIntervalCommitLog=1000
commitIntervalCommitLog=1000
flushCommitLogTimed=false
deleteWhen=04
fileReservedTime=72
maxTransferBytesOnMessageInMemory=262144
maxTransferCountOnMessageInMemory=32
maxTransferBytesOnMessageInDisk=65536
maxTransferCountOnMessageInDisk=8
accessMessageInMemoryMaxRatio=40
messageIndexEnable=true
messageIndexSafe=false
haMasterAddress=
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
cleanFileForciblyEnable=true
transientStorePoolEnable=false

啟動(dòng)broker的時(shí)候用規(guī)定的模版文件
nohup sh mqbroker -c broker.p -n localhost:9876 >/soft/RocketMQ/rocketmqlogs/broker.log 2>&1 &