1、官网下载:http://rocketmq.apache.org/docs/quick-start/
2、rocket安装所需环境如下:
① 64bit OS, Linux/Unix/Mac is recommended;(Windows user see guide below)
② 64bit JDK 1.8+;
③ Maven 3.2.x;
④ Git;
⑤ 4g+ free disk for Broker server
3、unzip -O CP936 -o rocketmq-all-4.7.1-bin-release.zip
4、在tool.sh 中${JAVA_HOME}/jre/lib/ext后加上ext文件夹的绝对路径(jdk路径)
vim /app/rocketmq/bin/tools.sh 如JAVA_OPT="${JAVA_OPT}-Djava.ext.dirs=${BASE_DIR}/lib:${JAVA_HOME}/jre/lib/ext:${JAVA_HOME}/lib/ext:/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.252.b09-2.el7_8.x86_64/jre/lib/ext"
5、修改bin文件夹下runsever.sh和runbroker.sh文件 将java内存缩小到512m和256m。
6、vi broker.conf
#设置名称服务地址
namesrvAddr=ip地址:9876
#设置brokerIP地址
brokerIP1=ip地址
#关闭自动创建主题
autoCreateTopicEnable=false
#关闭自动创建订阅组
autoCreateSubscriptionGroup=false
6、启动mqnamesrv
nohup sh bin/mqnamesrv &
7、
nohup sh bin/mqbroker -n ip地址:9876 -c conf/broker.conf autoCreateTopicEnable=true &
8、创建topic
sh bin/mqadmin updatetopic -n ip地址:9876 -c DefaultCluster -t TopicTest
【注】
①DefaultCluster 为broker.conf 中brokerClusterName 值
②TopicTest 为topic名称
9、启动消费者
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
10、启动生产者
export NAMESRV_ADDR=ip地址:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
【注】端口号:9876 、10911