RocketMQ安裝
一、使用源碼安裝
1、下載源碼 git clone https://github.com/apache/incubator-rocketmq.git
2、移動文件至/usr/local/rocketmq
3、編譯部署
cd rocketmq
mvn -Prelease-all -DskipTests clean install -U
二、環境變量配置
1、修改/etc/profile文件，使用命令：vim /etc/profile，將如下內容追加到文件末尾
export ROCKETMQ_HOME=/usr/local/rocketmq/distribution/target/apache-rocketmq
export PATH=$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH
2、/etc/profile文件修改后，必須刷新才能有效使用，使用指令：
source /etc/profile
三、修改服務器內存
由於RocketMQ默認配置要求很高，比如內存至少就要4個G，開發調試環境根本吃不消，所以開始啟動前需要先修改這些參數。否則的話，會遇到內存分配或者不夠的問題。
a)vim /usr/local/rocketmq/distribution/target/apache-rocketmq/bin/tools.sh
b)vim /usr/local/rocketmq/distribution/target/apache-rocketmq/bin/runbroker.sh
c)vim /usr/local/rocketmq/distribution/target/apache-rocketmq/bin/runserver.sh
四、啟動NameServer、Broker
a)指定broker使用IP
cd /usr/local/rocketmq/distribution/target/apache-rocketmq
b)編寫配置文件
echo "brokerIP1=自己的IP地址" > conf/broker.properties
c)啟動mqnamesrc
nohup sh bin/mqnamesrv &
d)啟動mrbroker 啟動時通過 -c 加載配置文件
nohup sh bin/mqbroker -n IP地址:9876 -c conf/broker.properties &
e) jps 執行jps查看進程
f)查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log
tail -f ~/logs/rocketmqlogs/broker.log
五、發送和接收消息
發送/接收消息之前,需要告訴客戶端 NameServer 地址。為簡單起見,我們使用環境變量 NAMESRV_ADDR。
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
六、關閉服務器
1、同樣都是在 RocketMQ 安裝目錄下的 distribution/target/apache-rocketmq 目錄下執行命令
2、與啟動順序相反進行關閉，先關閉 broker、在關閉 nameserv
src=
常用命令
除了上面幾個命令之外，還有如下一些較常用的命令，ip請以實際為准：
查看集群情況： ./mqadmin clusterList -n 127.0.0.1:9876
查看 broker 狀態： ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911
查看 topic 列表： ./mqadmin topicList -n 127.0.0.1:9876
查看 topic 狀態： ./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (換成想查詢的 topic)
查看 topic 路由： ./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic
七、RocketMQ-Console安裝
1、使用git命令下載項目源碼，由於我們僅需要rocketmq-console，故下載此項目對應分支即可。
git clone -b release-rocketmq-console-1.0.0 https://github.com/apache/rocketmq-externals.git
2、進入項目文件夾並修改配置文件
cd rocketmq-externals/rocketmq-console/
vi src/main/resources/application.properties
#管理后台訪問上下文路徑，默認為空，如果填寫，一定要前面加“/”，后面不要加，否則啟動報錯
server.contextPath=/rocketmq
#訪問端口
server.port=8080
#spring.application.index=true
spring.application.name=rocketmq-console
spring.http.encoding.charset=UTF-8
spring.http.encoding.enabled=true
spring.http.encoding.force=true
#logback配置文件路徑
logging.config=classpath:logback.xml
#if this value is empty,use env value rocketmq.config.namesrvAddr NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876
#Name Server地址，修改成你自己的服務地址
rocketmq.config.namesrvAddr=10.0.74.198:9876;10.0.74.199:9876
#if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true
rocketmq.config.isVIPChannel=
#rocketmq-console's data path:dashboard/monitor
rocketmq.config.dataPath=/tmp/rocketmq-console/data
#set it false if you don't want use dashboard.default true
rocketmq.config.enableDashBoardCollect=true
3、將項目打成jar包，並運行jar文件。
$ mvn clean package -Dmaven.test.skip=true
$ java -jar target/rocketmq-console-ng-1.0.0.jar
#如果配置文件沒有填寫Name Server
$ java -jar target/rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr='10.0.74.198:9876;10.0.74.199:9876'
4、啟動成功后，訪問地址http://localhost:8080/rocketmq, 即可進入管理后台操作。