一、java环境配置

此处不赘述，请参阅： https://www.cnblogs.com/ostrich-sunshine/p/8414677.html

source ~/.profile

source ~/.bash_profile

source /etc/profile

/Library/Java/JavaVirtualMachines/jdk1.8.0_192.jdk/Contents/Home

/usr/libexec/java_home

二、rocketMq 安装

1.解压与编译

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

2.启动Name Server服务

# 1.启动NameServer
nohup sh bin/mqnamesrv &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log

输出：The Name Server boot success. 表示成功

3.修改内存大小

RocketMq默认内存较大，启动Borker如果因为内存不足启动失败，需要修改如下配置文件，修改JVM内存大小

• runborker.sh

• runserver.sh

改为： JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

4.启动borker

# 1.启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log 

输出： The broker[%s, 172.30.30.233:10911] boot success...

5. 查看是否启动

 ~/Documents/rocketmq  jps
83195 NamesrvStartup
84572 BrokerStartup
86174 Jps

6.关闭rocketMq

# 关闭NameServer
sh bin/mqshutdown namesrv
# 关闭Borker
sh bin/mqshutdown broker

三、测试发送数据与接受数据

最好开两个命令行窗口

• 发送数据：设置环境变量，启动生产者

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

• 接受数据：设置环境变量，启动消费者

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