以下采用的是apache rocketmq 4.2.0版本 相关文档如下

#download
wget http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip   
unzip rocketmq-all-4.2.0-source-release.zip
cd rocketmq-all-4.2.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq

目录 distribution/target/apache-rocketmq 是编译后的产出 可复制这个目录安装MQ的机器上,这里复制到/usr/local/

共享一份编译后的文件方便以后再次使用

https://pan.baidu.com/s/1ZyUOKFm-t8cJDQuH68QydQ

启动NameServer

cd /usr/local/apache-rocketmq
nohup sh bin/mqnamesrv &

查看日志tail -f ~/logs/rocketmqlogs/namesrv.log 启动成功后打印The Name Server boot success…

启动Broker

这里需要注意一下就是 如果当前机器上有多张网卡的情况,最好指定一个IP, 有可能消费端正好就和MQ选择的网卡不通

vim conf/broker.conf 指定IP 访问多网卡的情况 并配置好nameserver的地址 也可以使用mqbroker启动参数-n指定nameserver地址

brokerIP1=192.168.1.2
namesrvAddr=192.168.1.3:9876

启动broker -c参数指定配置文件

nohup sh bin/mqbroker -c config/broker.properties &

查看一下集群列表

sh bin/mqadmin clusterList -n  localhost:9876

发送/接收消息

Producer

 
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

能发送表示OK

Consumer

 
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

能接收到之前发送的消息表示OK

关闭MQ

 
sh bin/mqshutdown broker

sh bin/mqshutdown namesrv