centos7安装rocketmq

1.下载rocketmq;

[root@docker rocketmq]#    wget http://archive.apache.org/dist/rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip
--2021-12-02 17:14:35--  http://archive.apache.org/dist/rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip
Resolving archive.apache.org (archive.apache.org)... 138.201.131.134, 2a01:4f8:172:2ec5::2
Connecting to archive.apache.org (archive.apache.org)|138.201.131.134|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: 9080492 (8.7M) [application/zip]
Saving to: ‘rocketmq-all-4.2.0-bin-release.zip’

100%[=================================================================================================================================================>] 9,080,492   70.4KB/s   in 2m 26s 

2021-12-02 17:17:02 (60.8 KB/s) - ‘rocketmq-all-4.2.0-bin-release.zip’ saved [9080492/9080492]

2.解压rocketmq-all-4.2.0-bin-release.zip

[root@docker rocketmq]# unzip rocketmq-all-4.2.0-bin-release.zip 

3.启动nameserver：

[root@docker rocketmq]# cd bin/

[root@docker bin]# nohup sh mqnamesrv &

4.查看是否启动：

[root@docker bin]# jps -m
2464 Jps -m
2415 NamesrvStartup

5.查看启动日志：

[root@docker ~]# tail -f /root/logs/rocketmqlogs/namesrv.log 

6.启动boreak

[root@docker rocketmq]#nohup sh mqbroker -n localhost:9876 &
[2] 2684
[root@docker rocketmq]# 
[root@docker rocketmq]# nohup: ignoring input and appending output to ‘nohup.out’

7.启动broker时会卡顿，因为虚拟机内存和broker配置内存跟不上。

[root@docker bin]# vim runbroker.sh

#===========================================================================================
# JVM Configuration
#===========================================================================================
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
JAVA_OPT="${JAVA_OPT} -XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -XX:SurvivorRatio=8"
JAVA_OPT="${JAVA_OPT} -verbose:gc -Xloggc:/dev/shm/mq_gc_%p.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy"
JAVA_OPT="${JAVA_OPT} -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m"

[root@docker bin]# vim runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
JAVA_OPT="${JAVA_OPT} -XX:+UseConcMarkSweepGC -XX:+UseCMSCompactAtFullCollection -XX:CMSInitiatingOccupancyFraction=70 -XX:+CMSParallelRemarkEnabled -XX:SoftRefLRUPolicyMSPerMB=0 -XX:+CMSClassUnloadingEnabled -XX:SurvivorRatio=8 -XX:-UseParNewGC"
JAVA_OPT="${JAVA_OPT} -verbose:gc -Xloggc:/dev/shm/rmq_srv_gc.log -XX:+PrintGCDetails"

8.关闭NameServer和broker

# 1.关闭NameServer
sh mqshutdown namesrv
# 2.关闭Broker
sh mqshutdown broker

测试RocketMQ

发送消息
# 1.设置环境变量
   export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
  sh tools.sh org.apache.rocketmq.example.quickstart.Producer

接收消息
# 1.设置环境变量
  export NAMESRV_ADDR=localhost:9876
# 2.接收消息
  sh tools.sh org.apache.rocketmq.example.quickstart.Consumer