官網(wǎng)地址：http://rocketmq.apache.org/docs/quick-start/

快速啟動(dòng)

下載源碼包，解壓并構(gòu)建

unzip rocketmq-all-4.4.0-source-release.zip cd rocketmq-all-4.4.0/ mvn -Prelease-all -DskipTests clean install -U cd distribution/target/apache-rocketmq/bin

修改runbroker.sh 和 runserver.sh的參數(shù)
目錄distribution/target/apache-rocketmq/bin下放置的相關(guān)的腳本

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m" JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=512m"

在distribution下創(chuàng)建日志目錄/logs

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

//啟動(dòng)nameserver nohup sh target/apache-rocketmq/bin/mqnamesrv > ./logs/namesrv.log 2>&1 &//啟動(dòng)broker nohup sh target/apache-rocketmq/bin/mqbroker -n localhost:9876 > ./logs/broker.log 2>&1 &//使用jps命令查看是否啟動(dòng)成功 [root@4c33afef76b9 distribution]# jps 16963 NamesrvStartup 17019 BrokerStartup 18686 Jps

測(cè)試

//發(fā)送消息 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

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

//distribution/target/apache-rocketmq/bin目錄下執(zhí)行 sh bin/mqshutdown broker sh bin/mqshutdown namesrv

可視化平臺(tái)

在GitHub 中搜索 rocketmq-externals，其中 rocketmq-console 就是 RocketMQ 可視化控制臺(tái)。
https://github.com/apache/rocketmq-externals

修改配置文件

find -name application.properties 文件路徑./rocketmq-console/src/main/resources/application.propertiesvim application.properties rocketmq.config.namesrvAddr=192.168.143.128:9876

編譯打包啟動(dòng)

mvn clean package -Dmaven.test.skip=truePID=`ps aux | grep "rocketmq-console"| grep -v grep | awk '{print $2}'` echo "kill process is ${PID}" kill -9 ${PID}nohup java -jar target/rocketmq-console-ng-1.0.1.jar >>/rocketmq_console.log 2>&1 &

查看 http://10.96.114.151:8080

總結(jié)

以上是生活随笔為你收集整理的RocketMQ初识的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。