https://yq.aliyun.com/articles/624207?utm_content=m_1000012577 vi runserver.sh vi runbroker.sh 配置ip cat conf/broker.conf namesrvAddr = 192.168.40.129:9876 brokerIP1 = 192.168.40.129 nohup sh bin/mqnamesrv > logs/rocketmqlogs/namesrv.log 2>&1 & nohup sh bin/mqbroker -n localhost:9876> logs/rocketmqlogs/broker.log 2>&1 & nohup sh bin/mqbroker -n 192.168.40.129:9876> logs/rocketmqlogs/broker.log 2>&1 & ./bin/mqadmin clusterList 发送消息 export NAMESRV_ADDR=localhost:9876 bin/tools.sh org.apache.rocketmq.example.quickstart.Producer 接收消息 bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer /home/tools/rocketmq/bin/mqadmin updateTopic -n '192.168.40.129:9876' -c DefaultCluster -t TopicTest > rocketmq默认不带可视化控制台,需要去单独编译一个工具 https://github.com/apache/rocketmq-externals ### 1. git clone源码 ```git clone https://github.com/apache/rocketmq-externals``` ### 2. 切换版本 ``` git checkout rocketmq-console-1.0.0 ``` ### 3. 编译为jar ``` mvn clean package -Dmaven.test.skip=true ``` ### 4. 启动 ``` # jar包在target目录下面,你可以放在一台服务器上面运行 java -jar rocketmq-console-ng-1.0.0.jar --server.port=8081--rocketmq.config.namesrvAddr=192.168.40.129:9876 java -jar rocketmq-console-ng-1.0.1.jar --server.port=8081 --rocketmq.config.namesrvAddr=192.168.40.129:9876 # --server.port springboot内置tomcat的端口号,默认8080; # --rocketmq.config.namesrvAddr nameserver的地址 ``` http://rocketmq.apache.org/docs/order-example