一、Rocketmq

1、下载

https://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

2、解压

unzip rocketmq-all-4.7.1-bin-release.zip -d /usr/local/
mv /usr/local/rocketmq-all-4.7.1-bin-release /usr/local/rocketmq
cd /usr/local/rocketmq/bin

3、修改内存

vim runbroker.sh

# 修改内存
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"


vim runserver.sh

# 修改内存
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

4、启动

启动 mqnamesrv

nohup sh mqnamesrv > namesrv.log &

启动 broker

nohup sh mqbroker -n localhost:9876 > broker.log &

5、测试

发送消息

# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876

# 2.使用安装包的Demo发送消息
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

接受消息 

# 1.接收消息
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

6、关闭 Rocketmq

# 关闭NameServer
sh mqshutdown namesrv

# 关闭Broker
sh mqshutdown broker

7、mqadmin

sh mqadmin topicList -n localhost:9876

注意：openjdk 安装的要设置 JAVA_HOME 环境变量：例如：/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.242.b08-0.el7_7.x86_64/

二、rocketmq-console

1、下载

git clone https://github.com/apache/rocketmq-externals.git

2、打包

cd /opt/software/rocketmq-externals/rocketmq-console/

mvn clean package -Dmaven.test.skip=true

3、运行

# 指定 端口与 IP

java -jar rocketmq-console-ng-1.0.0.jar \
--server.port=7070 \
--rocketmq.config.namesrvAddr=192.168.2.102:9876 > rocketmq-console.log 2>&1 &

4、测试